简介

前面这些章节，讲的基本上都是属于netty对MQTT周边的一些处理，由于MQTT协议总共目前可用的消息类型有14个，如果再加上对应的事件处理加载一起那就估计大概有14*3个handler，如果每个来讲一遍，难免有些枯燥，而且知识点会很分散，思考再三，想把整体的MQTT消息以及对应的事件处理作为一节来介绍，我们只讲它整体的实现思路、处理流程即可，这样对需要自己写broker的朋友的帮助应该是非常大的，这也符合最初写此系列博客的初衷。

热身

一、Callback

1、分类

HiveMQ的Callback总体分为同步、异步两种callback，其中部分异步callback被标记为lowlevel。

2、同步

可以看出同步的callback主要分为broker的callback、安全相关的callback、OnConnectCallback、OnPublishReceivedCallback、OnSubscribeCallback，这些回调都是使用异步线程调用。

1. broker在启动和关闭时，会触发OnBrokerStart和OnBrokerStop，用户可在broker启动的时候做一些自己的处理，例如数据库连接池的创建，spring context的创建等等；在broker关闭时，可以关闭数据库连接池等操作。

2. 安全相关的主要包括Authentication、Authorization,主要是做连接认证和授权；可以写第三方plugin去做Authentication和Authorization。

3. OnConnectCallback、OnPublishReceivedCallback、OnSubscribeCallback，用户可以在client连接、client publish、client subscribe的时候做一些处理。

3、异步

1. 异步callback主要包括一些mqtt消息回调、认证完成回调等等，用户可以根据自己的需求开发一些个性化插件定制属于自己的broker业务。

4、lowlevel

1. lowlevel属于异步callback的一部分，都是mqtt消息的回调。

5、CallbackExecutor

1. CallbackExecutor就是所有异步调用callback处理的Executor，由hivemq统一调配；用户可使用配置内部参数来控制其线程数；来保证broker的性能；CallbackExecutor由CallbackExecutorProvider创建提供。

三、Plugin*Handler

在netty handlers一览中介绍了很多plugin*handler；这些handler都是监听netty的用户自定义event来对callback进行回调

正戏

下来就通过mqtt的connect消息的整个调用处理流程来示例一下mqtt消息和事件处理。

流程较多，部分细节处理做了减免描述，为了让大家更清晰地了解消息的处理、事件的处理、以及其相互之间的触发方式，大家如果自己写broker，没必要生搬硬套按照这样的步骤去处理(只要按照mqtt标准/建议的处理流程去处理即可)，目的是为了大家了解其处理机制提供一个思路而已。

总结

1、所有的mqtt消息的handler与callbackhandler都是通过netty的自定义event来实现交互的，callbackhandler几乎都是动态加入到pipeline中以减少内存的消耗。

2、所由callbackhandler都使用CallbackExecutor去异步调用callback，并监听对应完成的event来进行交互。

由上可以看出，所有流程都是采用异步处理，同时限制Executor线程数来限制异步同时处理过多，使用netty自定义event来达到相互的交互、以及客户端(plugin、mqtt client)感知的同步。

MQTT交流群:221405150