RabbitMQ使用情况: 发消息 -- 有 收消息 -- 有 == 收消息处理流程: == 记录log表 --> handler处理 --> 正常;抛异常 --> 记录错误日志,消息报文信息(文件形式,多而杂,只保存2天左右,容易丢失数据) == 发消息处理流程: == 发送前未保存消息报文,异常时记录错误日志(文件形式,多而杂,只保存2天左右,容易丢失数据) == 待确定改进点: == 接收消息: 1、新建表 task_exception_log 保存收到消息处理时出异常的消息报文,对外提供接口(超级管理员权限),可以通过表的id或id列表,批量执行,重新模拟收消息处理流程 2、对外提供接口(白名单),在切换掉MQ后,可以通过该接口模拟接收MQ消息,之后走原来一整套逻辑即可。 发送消息: 1、配置后台超级管理员权限管理功能,可以切换消息发送模式,使用rabbitMq或直接调用接口等 2、发送消息统一出口前,判断使用哪种模式即可