MQ服务原理图1.1

Message

生产者

P-C Map Data

反向消费线程Thread1

消费结果判定

消息中间件

消费成功/重试结束，记录消费日志

消息分发Thread5

Queue1：原始消息缓存队列

更新P-C Map数据

MessageWrapper

反向消费服务

Http

定时消息消费Thread4

管理员

读取MQ消息Thread6

Queue3：包含连接对象的消息队列

消息批量入库Thread3

HTTP Request

处理消费结果线程Thread2

HttpServlet

Queue2：即时消息队列

1、权限校验2、数据校验3、return

消息接收服务

备注：一、反向消费线程1、从消息队列获取消息2、将消息封装成Http协议消息体3、发送socket请求4、将消息封装成messageWrapper记录发送时间，超时时间等5、循环到1二、处理消费结果线程1、获取Queue3中的消息2、消息是否已经响应完毕3、用http协议解析socket数据3、如果响应成功，入库，记录消费日志4、如果响应失败，返回消费队列Queue1继续下次消费三、Queue3队列有可能会特别大，消息会积压在该队列等待消费者响应，Queue3可以考虑使用队列组，Thread2可以考虑使用线程池四、关于服务器硬重启问题？？？禁止五、P-C Map 数据是指生产者与消费者映射关系数据，发送广播消息时，需要读取该数据。有两种方式维护该数据，一种是发送Http请求指令，另一种是直接更新DB数据，服务周期的从DB中更新

消费者

Queue4：包含连接对象的消息队列

消费失败，重新消费

DB

HTTP Response