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

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

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

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

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