一、簡介

MQTT 全稱為 Message Queuing Telemetry Transport(消息隊列遙測傳輸)是一種基于發(fā)布/訂閱范式的“輕量級”消息協(xié)議，由 IBM 發(fā)布。

目前使用比較廣泛的就是 mqtt 3.1.1(2014年制定)，mqtt 5.0(2018年制定)，Mqtt5特性詳見：https://www.emqx.io/cn/mqtt/mqtt5

二、mica-mqtt

為了深入了解 mqtt 協(xié)議的，在今年 9 月左右基于 t-io 開發(fā)了 mica-mqtt，mqtt 編解碼直接基于 netty codec-mqtt 模塊進行的調整，當時 netty 還不支持 mqtt5 協(xié)議。

netty 的 codec-mqtt 比較成熟，大多數(shù) java 的 mqtt-broker 也是基于它實現(xiàn)的。下面我主要介紹我是如何將 netty 的 codec-mqtt 移植到 t-io 的。

三、mqtt5協(xié)議移植

前 2 周發(fā)現(xiàn) netty 的 codec-mqtt 已經支持 mqtt5 協(xié)議了，花了一點時間對它進行了升級，下面跟我一起來看看我是怎么處理的。

3.1 copy 源碼

先直接 copy 源碼，對代碼進行初步的調整，

ObjectUtil.checkNotNull改為 jdk 的Objects.requireNonNull

CharsetUtil.UTF_8調整為 StandardCharsets.UTF_8

重寫toString方法

3.2 ByteBuf 轉 ByteBuffer

netty 中采用 ByteBuf 來解析協(xié)議，t-io 則是使用的 ByteBuffer，那么我們最大的任務就是將 ByteBuf 轉成 ByteBuffer 了。

ByteBuf vs ByteBuffer 方法對比

ByteBufByteBuffer

writeByte	put
writeBytes	put
writeShort	putShort
writeInt	putInt
getByte	get
getBytes	get
getShort	getShort
getInt	getInt

3.3 mqtt5 encodeProperties 處理

由于 ByteBuffer 是定長的，初始化的時候就需要指定長度，在 encodeProperties 我自定義了一個WriteBuffer做數(shù)據(jù)承載，最后轉成byte[]返回。

圖片

圖示WriteBuffer

圖片

WriteBuffer底層是 t-io 自帶原作者為 biezhi(王爵)同學的FastByteBuffer。

圖片

四、效果(mqtt5協(xié)議)

4.1 使用 MQTTX 客戶端

4.2 使用 mica-mqtt 客戶端

五、待辦

由于精力有限，mica-mqtt 目前還屬于試驗性質。希望有更多的同學可以參與進來。

topic 的綁定。

實現(xiàn)基礎的 mqtt-broker 功能。

說明：另外可以參考 zbus 來處理消息或者實現(xiàn)內部的集群。

六、關于 t-io

t-io 是一款簡單、高性能、低延遲的網絡中臺。t-io 解決了其它網絡框架沒有解決的用戶痛點，幫助企業(yè)節(jié)約大量人力成本。

t-io技術白皮書：https://www.tiocloud.com/tio.pdf

t-io 官方基礎 t-io 的 IM(譚聊) 1.4 萬人大群，邀你一起來耍！！！

譚聊產品介紹：https://www.tiocloud.com/tioim.pdf

七、相關連接

mica-mqtt：https://gitee.com/596392912/mica-mqtt

t-io：https://gitee.com/tywo45/t-io

總結

以上是生活随笔為你收集整理的java mqtt协议_基于 tio 实现 mqtt5 协议之 micamqtt的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。