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
