设备消息推送项目结构

mqtt客户机1

redis缓存

mqtt接收消息队列

mqtt发送消息队列

日志

客户端

连续下发3次未回复错误消息集合

已发未回复消息集合

业务日志

mqtt客户机2

redis key说明:mqtt客户机集合(map):  BASEDATA:SCH:DEVSERVER:DEVICES 待下发消息队列(queue):  QUEUE:DATA:DEVICE:MESSAGE:设备Seq已下发消息集合(map): SET:DATA:DEVICE:MESSAGE:设备Seq未回复错误消息集合(map): SET:DATA:DEVICE:MESSAGE:ERROR:设备Seq

mqtt收发消息线程池

mqlistener设备推送消息监听

device-server服务

异常日志

mqtt客户机信息集合

mqtt通讯日志

service:dubbo-consumer

服务端

待下发消息队列

分等级保存

mqtt控制器内存