如何使用Spring integration在Springboot中集成Mqtt详解.docx

第

如何使用Spring?integration在Springboot中集成Mqtt详解

目录前言关于SpringIntergrationSpringIntergration核心组件Message（消息）MessageChannel（消息管道）MessageEndpoint（消息切入点）MessageTransformer（消息转化器）MessageFilterMessageRouter（消息路由）Splitter（分割器）Aggregator（聚合器）ServiceActivatorChannelAdapter（管道适配器）开始集成引入spring-integration-mqtt依赖创建Mqtt配置类修改配置文件application.yml创建三个管道添加Mqtt客户端工厂添加Mqtt管道适配器添加消息生产者添加出站处理器添加消息接收器添加消息发送器自定义编解码器实现自己的编解码器修改MqttConfig修改MqttSenderReceiver修改动态修改订阅主题End附录最终MqttConfig完整代码最后

前言

接触Mqtt最开始用的是SpingMVC引入MqttClientJar包自己实现收发重连等操作，而现在则使用SpringIntegration进行集成。其复杂度和代码简洁度天差地别。所以特别写下此文章算是对自己的一个记录。也希望观看到此文章的人少走一点弯路，哪怕只有一步。

当然有精力的话最好还是使用Client自己实现一遍对自己来说也是一种提高，生产环境，我建议使用SpringIntegration集成

关于SpringIntergration

介绍关于SpringIntegration的一些概念性的东西，如果只想知道怎么集成可跳过该部分

SpringIntegrationprovidesanextensionoftheSpringprogrammingmodeltosupportthewellknownEnterpriseIntegrationPatterns.ItenableslightweightmessagingwithinSpring-basedapplicationsandsupportsintegrationwithexternalsystemsthroughdeclarativeadapters.ThoseadaptersprovideahigherlevelofabstractionoverSpringssupportforremoting,messaging,andscheduling.

大致意思是

SpringIntegration为许多著名的企业级集成方案提供了扩展接口它能够在基于Sping的应用中进行轻量级消息传递支持声明式适配器与发布系统进行集成（见Mqttsend消息的实现）这些适配器在Spring对远程调用，消息传递和系统调度提供了更高层次的抽象

SpringIntergration核心组件

Message（消息）

Message是对消息的包装，在Spring系统中传递的任何消息都会被包装为Message。可以理解为是SpringIntegration消息传递的基本单位

MessageChannel（消息管道）

消息管道：Message在MessageChannel中进行传递，生产者向管道中投递消息，消费者从管道中取出消息。SpringIntegration支持两种消息传递模型，point-to-point（点对点模型），Publish-subscribe（发布订阅模型）有多种管道类型。

本次使用点对点模型，消息管道类型DirectChannel

MessageEndpoint（消息切入点）

消息切入点：消息在管道中流动那必定会有某些流入或流出的点亦或是在某个位置（即特定函数）需要对消息进行处理，过滤，格式转换等。这些点即为MessageEndpoint（实际为某些处理函数），例如消息发送，消息接收都是MessageEndpoint。

MessageTransformer（消息转化器）

消息转化器：是将消息进行特定转换例如将一个Object序列化为Json字符串

MessageFilter

消息过滤器，过滤掉特定消息。例如在管道中发送的含username和age属性的User对象，如果当前消息（一个User实例的包装）的age1