本文共 1643 字，大约阅读时间需要 5 分钟。
源博客地址:
MQTT交流群:221405150
简介
前面这些章节，讲的基本上都是属于netty对MQTT周边的一些处理，由于MQTT协议总共目前可用的消息类型有14个，如果再加上对应的事件处理加载一起那就估计大概有14*3个handler，如果每个来讲一遍，难免有些枯燥，而且知识点会很分散，思考再三，想把整体的MQTT消息以及对应的事件处理作为一节来介绍，我们只讲它整体的实现思路、处理流程即可，这样对需要自己写broker的朋友的帮助应该是非常大的，这也符合最初写此系列博客的初衷。
热身
一、Callback
1、分类
HiveMQ的Callback总体分为同步、异步两种callback，其中部分异步callback被标记为lowlevel。
2、同步
可以看出同步的callback主要分为broker的callback、安全相关的callback、OnConnectCallback、OnPublishReceivedCallback、OnSubscribeCallback，这些回调都是使用异步线程调用。
broker在启动和关闭时，会触发OnBrokerStart和OnBrokerStop，用户可在broker启动的时候做一些自己的处理，例如数据库连接池的创建，spring context的创建等等；在broker关闭时，可以关闭数据库连接池等操作。
安全相关的主要包括Authentication、Authorization,主要是做连接认证和授权；可以写第三方plugin去做Authentication和Authorization。
OnConnectCallback、OnPublishReceivedCallback、OnSubscribeCallback，用户可以在client连接、client publish、client subscribe的时候做一些处理。
3、异步
- 异步callback主要包括一些mqtt消息回调、认证完成回调等等，用户可以根据自己的需求开发一些个性化插件定制属于自己的broker业务。
4、lowlevel
- lowlevel属于异步callback的一部分，都是mqtt消息的回调。
5、CallbackExecutor
- 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)感知的同步。