1 篇博文 含有标签「消息」

分享文件给用户、文件订阅、系统通知、审批流等功能需要消息支持，现在需要建立一种可靠的消息收发机制。

架构​

• 发送者将消息发送到系统消息队列中，发送返回成功。

• 系统消息处理器负责从队列中读取消息并处理，完成后将最终消息放到个人消息收件箱中，然后将消息放入通知消息队列中。

• 通知消息处理器将消息推送给在线用户。

用户场景​

"小明发送一个文件给研发部所有人员。"

实现方法：

1. 小明将文件消息发送到系统消息队列中，发送完成。
2. 消息处理器取出消息，解析内容，读取文件信息，并生成最终的文件消息内容。将消息依次写入研发部所有人员的个人收件箱中，然后将消息放入通知消息队列中。
3. 推送消息处理器将消息推送给在线的研发部人员。在集群化部署场景，用户会随机连接到不同的连接池上，因此每个推送消息处理器只给自己的连接池中的研发部成员推送消息。