一、简介

MQTT 全称为 Message Queuing Telemetry Transport（消息队列遥测传输）是一种基于发布/订阅范式的“轻量级”消息协议，由 IBM 发布。

目前使用比较广泛的就是 mqtt 3.1.1（2014年制定），mqtt 5.0（2018年制定），Mqtt5特性详见：https://www.emqx.io/cn/mqtt/mqtt5

二、mica-mqtt

为了深入了解 mqtt 协议的，在今年 9 月左右基于 t-io 开发了 mica-mqtt，mqtt 编解码直接基于 netty codec-mqtt 模块进行的调整，当时 netty 还不支持 mqtt5 协议。

netty 的 codec-mqtt 比较成熟，大多数 java 的 mqtt-broker 也是基于它实现的。下面我主要介绍我是如何将 netty 的 codec-mqtt 移植到 t-io 的。

三、mqtt5协议移植

前 2 周发现 netty 的 codec-mqtt 已经支持 mqtt5 协议了，花了一点时间对它进行了升级，下面跟我一起来看看我是怎么处理的。

3.1 copy 源码

先直接 copy 源码，对代码进行初步的调整，

1. ObjectUtil.checkNotNull改为 jdk 的Objects.requireNonNull
2. CharsetUtil.UTF_8调整为 StandardCharsets.UTF_8
3. 重写toString方法

3.2 ByteBuf 转 ByteBuffer

netty 中采用 ByteBuf 来解析协议，t-io 则是使用的 ByteBuffer，那么我们最大的任务就是将 ByteBuf 转成 ByteBuffer 了。

ByteBuf vs ByteBuffer 方法对比

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

3.3 mqtt5 encodeProperties 处理

由于 ByteBuffer 是定长的，初始化的时候就需要指定长度，在 encodeProperties 我自定义了一个WriteBuffer做数据承载，最后转成byte[]返回。

图示WriteBuffer

WriteBuffer底层是 t-io 自带原作者为 biezhi（王爵）同学的FastByteBuffer。

四、效果（mqtt5协议）

4.1 使用 MQTTX 客户端

4.2 使用 mica-mqtt 客户端

五、待办

由于精力有限，mica-mqtt 目前还属于试验性质。希望有更多的同学可以参与进来。

1. topic 的绑定。
2. 实现基础的 mqtt-broker 功能。

说明：另外可以参考 zbus 来处理消息或者实现内部的集群。

六、关于 t-io

t-io 是一款简单、高性能、低延迟的网络中台。t-io 解决了其它网络框架没有解决的用户痛点，帮助企业节约大量人力成本。

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