消息系统的设计（二: 系统架构设计和数据库设计）

所属分类：MySQL PHP

在开发中，我们期望消息的发送与业务系统进行解耦，这样做的好处是，可以是业务代码与消息系统的发送完全分离，不会因为消息发送的快慢程度而影响业务系统处理。因此，我们使用队列来完成消息的推送。

消息流程图：

① 创建消息类型队列

在之前我们将消息按类型分类，例如：财务消息、文章消息、审核消息等，同样，我们可以根据业务拆分为几个业务队列，用来存储消息推送的参数。

② 推送参数存入队列

在业务触发消息推送后，我们可以将推送的一些参数，使用func_get_args()获取参数并存入业务队列。

③ 将消息ID和推送目标用户存入推送渠道队列

在业务队列出队列后，我们可以将一些参数如：跳转信息、跳转参数等存入数据库，并将推送目标和消息ID存入渠道队列

④ 消息推送并记录推送结果

在渠道队列出队列后，我们根据渠道完成消息的推送，并记录推送结构。

下面我们进行数据库实体设计：

消息类型表（message_type）：

用于存储消息类型以及其对应的队列名称，如： {msg_type_id : 1, msg_type_name: '财务消息', msg_type_icon: '', msg_type_queue:'q:msg_type:finance'}

消息动作表（message_action）:

用于记录触发消息推送的动作表，将来如果需要做用户消息订阅，可以从此表取数据，并做扩展表实现消息订阅。

消息模板表（message_tpl）

用于存储提醒消息和验证码消息的内容，因为某个动作触发需要对多个渠道进行消息推送，所以单独一张表处理。

消息中间表（message）

对于提醒消息和验证码消息：在推送参数出业务队列即第三步中，我们将一部分参数存入此表， push_channels 来源于 message_tpl 中的推送动作所关联的所有渠道。

对于自定义消息：由推送参数中决定推送渠道和msg_type_id。

消息接收人表（message_receiver）

用于存储消息的接收人信息和额外的数据。

在进推送渠道队列之前，如果接收人类型是角色，则将角色ID转换为user_id

消息推送记录表（message_push_log）

web消息（web_sned_message）

web消息表，记录表，在出渠道web消息队列后，存储到此表。

公告不进行推送，直接存储到此表。

消息阅读表（message_read）