一、mqtt的使用
2.0版本新搭建了基于netty的mqttBroker,同時也對使用emq進行的優(yōu)化,
舊版本使用emq與新版本區(qū)別:
二、topic管理
topic管理將放在該類統(tǒng)一管理,標記是 發(fā)布topic/訂閱topic

emq客戶端訂閱主題代碼簡化:將 TopicType類訂閱屬性全部進行訂閱

消息回調(diào)方法更新:
接收到的消息,將會根據(jù)需要,根據(jù)topic分Channel將消息緩存到網(wǎng)關模塊進行消息處理,降低回調(diào)客戶端的消息高峰,提高數(shù)據(jù)處理轉(zhuǎn)發(fā)能力,數(shù)據(jù)處理效率。

三、基于Netty搭建的MQTT
基于redis進行集群搭建,后續(xù)會更高效率的方案搭建集群
啟動類如下圖所示

四、emq與netty-mqtt的切換
無論是使用emq還是 netty-mqtt,處理消息數(shù)據(jù)都一樣??梢远x一,但不支持同時使用
控制使用哪個mqtt的配置是 :
