#
# 如何二次封裝MQTT開源組件moquette ## 一、前言 MQTT作為物聯網領域最主流的輕量級通信協議，其開源實現moquette以其輕量級和高性能著稱。但在實際企業級應用中，直接使用原生
首先解釋一下mqtt協議的session的概念，因為只有有了session才會存在消息質量保證一說 如果清理會話（CleanSession）標志被設置為0，服務端必須基于當前會話（使用客戶端標識符識別
一. 前言在下載，編譯，運行moquette源代碼之后，肯定想加入自己的邏輯。但是又不想過多的修改源代碼，為了以后的升級。所以最好另外做個插件，單獨的jar包moquette源代碼編譯：http://
本文講解moquette對UNSUBSCRIBE和DISCONNECT的處理 先說UNSUBSCRIBE，代碼比較簡單 public void processUnsubscribe(Chann
一. 簡介moquette是一個Java版本的mqtt協議broker實現github源代碼： https://github.com/andsel/moquettegoogle moquet
先上一個圖，大概說明一下moquette 的類之間的關系 一.ProtocolProcessor類該類是moquette里面的最終要的類，負責所有報文的處理，持有所有各模塊功能的實現對象的引用，
這一篇開始講解moqutte對SUBSCRIBE報文的處理 代碼不復雜public void processSubscribe(Channel channel, MqttSubscribeMessag
moquette的集群功能是通過Hazelcast來實現的，對Hazelcast不了解的同學可以自行Google以下。在講解moquette的集群功能之前需要講解一下moquette的攔截器，因為mo
