当前位置：首页 > news >正文

开源统一消息中心：轻松实现多业务系统的消息分发与管理

news 2026/3/26 19:53:11

开源统一消息中心：轻松实现多业务系统的消息分发与管理

一、为什么需要统一消息中心？

在企业信息化建设中，往往存在多个独立业务系统（如设备管理平台、执法系统、OA系统等），每个系统都可能需要向用户发送通知、告警或待办消息。传统做法是各自开发消息模块，导致重复建设、接口不统一、状态无法追踪等问题。

统一消息中心（Unified Message Platform，UMP）正是为解决这一痛点而生。它提供了一套标准化的消息收发能力，将消息分发、推送/拉取、状态回执、重试机制等通用功能集中管理，让业务系统只需关注自身逻辑，即可实现可靠的消息送达。

二、项目概述

UMP 是一个基于 Spring Boot + MyBatis-Plus 构建的轻量级消息中间件，支持：

多种消息类型：个人消息（点对点）、部门消息、自定义范围消息（含组织、区域、角色等）
双模式分发：推送模式（主动回调业务方） + 拉取模式（业务方主动轮询）
全生命周期管理：消息发送 → 分发 → 接收/拉取 → 阅读 → 归档，状态全程可追溯
可靠重试：失败消息自动重试，支持指数退避，超限后永久失败
灵活认证：基于 AppKey/AppSecret 的应用认证，支持 JWT Token

项目已在多个实际业务场景中验证，具备高扩展性和稳定性。

三、核心功能亮点

1. 智能读写扩散策略

个人消息（USER）：采用“读扩散”模式，消息写入收件箱表（ump_msg_inbox），每个接收者一条记录。查询时只需扫描单表，适合小范围精准送达。
部门/自定义消息（DEPT/CUSTOM）：采用“写扩散”模式，仅存储一条广播记录（ump_msg_broadcast），接收记录按需创建（仅在业务方上报状态时写入），有效避免海量数据存储。

2. 广播接收记录按需创建

接收记录表（ump_broadcast_receive_record）仅在业务系统上报“已接收”、“已拉取”或“已阅读”时生成，采用UPSERT保证幂等。
未上报时，系统通过“候选广播集 - 已有记录”动态计算未处理消息，无需预创建记录。

3. 游标分页拉取

拉取接口使用游标（cursorId = 时间戳,ID）代替传统分页，避免深度分页性能问题，支持断点续传。

4. 状态机管理

消息主表（ump_msg_main）状态严格按状态机流转：RECEIVED→DISTRIBUTING→DISTRIBUTED→PUSHED/PULL→BIZ_RECEIVED/BIZ_PULLED→READ。
支持重试状态（DIST_RETRY、PUSH_RETRY），失败任务可自动重试。

5. 开箱即用的开放式API

提供 RESTful 接口，覆盖发送、拉取、状态上报、查询、认证等所有操作。
接口签名防重放，支持 MD5 校验，确保安全性。

四、技术架构

核心数据表

表名	描述
`ump_msg_main`	消息主表，存储消息内容、状态、发送方等
`ump_msg_inbox`	收件箱表，个人消息接收记录
`ump_msg_broadcast`	广播筒表，部门/自定义消息记录
`ump_broadcast_receive_record`	广播接收记录表，按需存储个人接收/阅读状态
`ump_msg_queue`	消息队列任务表，负责异步分发与重试
`ump_poll_cursor`	拉取游标表，记录每个应用的轮询进度

关键流程

消息发送：业务系统调用/open/message/send→ 平台验证 → 根据fsdx类型写入收件箱或广播筒 → 创建队列任务 → 返回消息ID。
拉取消息：业务系统调用/open/message/poll→ 平台返回游标分页的未处理消息（个人按未读，广播按未上报）。
状态上报：业务系统处理完成后调用/open/message/received等接口 → 平台更新收件箱/广播接收记录状态 → 同步更新主表统计。

五、快速开始

1. 环境要求

JDK 17+
MySQL 8.0+
Maven 3.6+

2. 获取源码

gitclone https://github.com/radarfyh/unified-message-center.gitcdfeng-message-center

3. 初始化数据库

执行docs/sql/*.sql脚本，脚本中含有数据库创建和所有表创建指令。

4. 修改配置

feng-config工程封装了nacos3.1.1。
在nacos中修改数据库连接、Redis 配置等。

5. 启动服务

mvn cleaninstallcdfeng-message-center-biz/targetjava-jarfeng-message-center-biz-1.0.0.jar

6. 测试接口

以发送消息为例：

# 获取 tokencurl-XPOST"http://localhost:11100/oauth2/token"\-H"Authorization: Basic REVWSUNFX01HTVRfUExBVEZPUk06RE1QZTdmOGE5YjBjMWQyZTNmNGE1YjZjN2Q4ZTlmMGExYjI="\-H"Content-Type: application/x-www-form-urlencoded"\-d"grant_type=app_key&scope=server&timestamp=1700000000000&nonce=abc123&signature=xxx"# 发送个人消息curl-XPOST"http://localhost:11000/ump/open/message/send"\-H"Authorization: Bearer eyJ..."\-H"Content-Type: application/json"\-d'{ "yybs": "DEVICE_MGMT_PLATFORM", "fsdw": "石家庄市应急管理局", "fsdwdm": "SJZ_YJGLJ", "fsr": "张三", "fsrzjhm": "110101199001011234", "fsdx": "USER", "xxlx": "NOTICE", "xxbt": "测试消息", "xxnr": "这是一条测试消息内容", "jsrzjhm": "110101199001011235", "cldz": "http://localhost:8089/api/test" }'