wiki:rabbitmq

RabbitMQ使用情况:

发消息 -- 有

收消息 -- 有

收消息处理流程:

记录log表 --> handler处理 --> 正常;抛异常 --> 记录错误日志,消息报文信息(文件形式,多而杂,只保存2天左右,容易丢失数据)

发消息处理流程:

发送前未保存消息报文,异常时记录错误日志(文件形式,多而杂,只保存2天左右,容易丢失数据)

待确定改进点:

接收消息:

1、新建表 task_exception_log 保存收到消息处理时出异常的消息报文,对外提供接口(超级管理员权限),可以通过表的id或id列表,批量执行,重新模拟收消息处理流程

2、对外提供接口(白名单),在切换掉MQ后,可以通过该接口模拟接收MQ消息,之后走原来一整套逻辑即可。

发送消息:

1、配置后台超级管理员权限管理功能,可以切换消息发送模式,使用rabbitMq或直接调用接口等

2、发送消息统一出口前,判断使用哪种模式即可