一、配置线程池
二、MQTT订阅生产消息
三、接收处理消息
四、接收消息处理接口
五、消费消息内容
六、MQTT数据处理基础类
七、MQTT的连接类
八、消息回调,一般是失败以后,进行重连接等处理
九、生产消息回调
十、线程异常情况下,处理MQTT自动停止或开启
十一、正常topic业务处理
十二、MQTT的alication.yml的配置
pom.xml的版本号:<mqtt.integration.version>5.4.2</mqtt.integration.version>