1. 概述
本文继续介绍IM系统核心功能之二，分别是
- 消息收发
- RabbitMQ设计
2. 消息收发流程
流程图
如下图，关于消息审计Auditor功能，遵从消息上行->消息审计->消息下行流程
- 如果审计
成功，则publish消息给receiver，走消息下行流程 - 如果审计
失败，则publish消息给sender，告知特定msgId的消息审计失败audit-fail，以及具体原因
im-message-send-receive.png
那么，在客户端的消息发送状态变更如下：
- 发送中，消息进入消息展示框，客户端执行send流程
- 未读（发送成功），收到send-ack后，显示
未读，或发送成功 - 发送失败，超过3分钟没有收到send-ack，则显示
发送失败，期间可以每分钟自动重发一次。失败后，支持手动重发（seq_id不变） - 审计失败，收到audit-fail后，显示
审计失败，及失败原因 - 已读，收到read-ack后，显示
已读
im-message-status-in-client.png
代码实现
- 消息上行
im-message-send.png
- 消息下行
im-message-receive.png
3. RabbitMQ应用设计
单聊
以user1@region1/desktop向user2@region1/desktop发送消息为例，介绍MQ消息流转流程
- SM1收到
PackageType=send的message，查询在线用户列表，补充receiver信息，从user2改成user2@region1/desktop，然后PublishRoutingKey=user.user1@region1/desktop.send到Exchange - Exchange会自动分发给
Recorder和Auditor两个服务 - Auditor收到
packageType=send的message，完成message审计工作 - 如果审计成功，则Publish
RoutingKey=user.user2@region1/desktop.receive到Exchange - 如果审计失败，则Publish
RoutingKey=user.user1@region1/desktop.audit-fail到Exchange - 如果SM1收到
RoutingKey=user.user1@region1/desktop.audit-fail的消息，则告知user1@region1/desktop - 如果SM3收到
RoutingKey=user.user2@region1/desktop.receive的消息，则下行消息给user2@region1/desktop - 如果Broker收到
RoutingKey=user.user2@region1/desktop.receive的消息，则判断user2@region1/desktop是否在其他Region，如果在，则下行消息给对应Region的Broker，否则，丢弃该消息
如果Broker收到其他Region的下行消息，则直接Publish
RoutingKey=user.user2@region1/desktop.receive到Exchange，不再走Auditor
群聊
以user1@region1/desktop向group1发送消息为例，介绍MQ消息流转流程
- SM1收到
PackageType=send的message，如果receiver是群组，则直接PublishRoutingKey=user.user1@region1/desktop.send到Exchange - Exchange会自动分发给
Recorder和Auditor两个服务 - Auditor收到
packageType=send的message，完成message审计工作 - 如果审计成功，则Publish
RoutingKey=group.group1.receive到Exchange - 如果审计失败，则Publish
RoutingKey=user.user1@region1/desktop.audit-fail到Exchange - 如果SM1收到
RoutingKey=user.user1@region1/desktop.audit-fail的消息，则告知user1@region1/desktop - 如果任何一个SM收到
RoutingKey=group.group1.receive的消息，则根据群组元数据，下行消息给当前SM管理的所有在线群组成员 - 如果Broker收到
RoutingKey=group.group1.receive的消息，则判断其他Region是否存在group1的在线用户，如果存在，则下行消息给对应Region的Broker，否则，丢弃该消息
如果Broker收到其他Region的下行消息，则直接Publish
RoutingKey=group.group1.receive到Exchange，不再走Auditor
BindingKey:
- SM的BindingKey，正则表达式：
^(user|group){1}.[a-zA-Z0-9@/]{32,}.(receive|audit-fail){1}$ - Auditor的BindingKey，正则表达式：
^user.[a-zA-Z0-9@/]{32,}.(send){1}$ - Recorder的BindingKey，正则表达式：
*.*.* - Broker的BindingKey，正则表达式：
^(user|group){1}.[a-zA-Z0-9@/]{32,}.(receive){1}$
im-rabbitmq-design.png
4. 小结
下文将介绍IM系统分布式部署方案。
网友评论