SpringBoot2.0集成MQTT消息推送功能实现

这几天在弄后端管理系统向指定的Android客户端推送消息的功能模块，查阅了网上很多博客介绍的许多方式，最终选择基于MQTT协议来实现，MQTT是一个轻量级的消息发布/订阅协议，它是实现基于手机客户端的消息推送服务器的理想解决方案。

实现MQTT协议的中间件有很多，我用的是Apollo服务器，如何搭建MQTT服务器，请查阅其他资料。这里，主要介绍SpringBoot2.0集成MQTT实现消息推送的功能。好，正式开始：

本文采用Gateway绑定的方式，网上也有介绍但不全面，还有其他采用Paho MQTT Client库的方式实现的。

第一，pom配置，我们需要引入相关jar：

<dependency>

<groupId>org.springframework.integration</groupId>

<artifactId>spring-integration-stream</artifactId>

</dependency>

<dependency>

<groupId>org.springframework.integration</groupId>

<artifactId>spring-integration-mqtt</artifactId>

</dependency>

第二，配置MQTT服务器基本信息，在springBoot配置文件application.properties中配置，添加如下：

#MQTT配置信息

#MQTT-用户名

spring.mqtt.username=admin

#MQTT-密码

spring.mqtt.password=password

#MQTT-服务器连接地址，如果有多个，用逗号隔开，如：tcp://127.0.0.1:61613，tcp://192.168.2.133:61613

spring.mqtt.url=tcp://127.0.0.1:61613

#MQTT-连接服务器默认客户端ID

spring.mqtt.client.id=mqttId

#MQTT-默认的消息推送主题，实际可在调用接口时指定

spring.mqtt.default.topic=topic

第三，配置MQTT 消息推送配置类，

/**

* 〈一句话功能简述〉<br>

* 〈MQTT发送消息配置〉

*

* @author AnswerChang

* @create 2018/6/4

* @since 1.0.0

*/

@Configuration

@IntegrationComponentScan

public class MqttSenderConfig {

@Value("${spring.mqtt.username}")

private String username;

@Value("${spring.mqtt.password}")

private String password;

@Value("${spring.mqtt.url}")

private String hostUrl;

@Value("${spring.mqtt.client.id}")

private String clientId;

@Value("${spring.mqtt.default.topic}")

private String defaultTopic;

@Bean

public MqttConnectOptions getMqttConnectOptions(){

MqttConnectOptions mqttConnectOptions=new MqttConnectOptions();

mqttConnectOptions.setUserName(username);

mqttConnectOptions.setPassword(password.toCharArray());

mqttConnectOptions.setServerURIs(new String[]{hostUrl});

mqttConnectOptions.setKeepAliveInterval(2);

return mqttConnectOptions;

}

@Bean

public MqttPahoClientFactory mqttClientFactory() {

DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory();

factory.setConnectionOptions(getMqttConnectOptions());

return factory;

}

@Bean

@ServiceActivator(inputChannel = "mqttOutboundChannel")

public MessageHandler mqttOutbound() {

MqttPahoMessageHandler messageHandler = new MqttPahoMessageHandler(clientId, mqttClientFactory());

messageHandler.setAsync(true);

messageHandler.setDefaultTopic(defaultTopic);

return messageHandler;

}

@Bean

public MessageChannel mqttOutboundChannel() {

return new DirectChannel();

}

第四，配置MqttGateway消息推送接口类，在sendToMqtt(String data,@Header(MqttHeaders.TOPIC)String topic)接口中，data为发送的消息内容，topic为主题。指定topic，则我们的接口可以根据需要，向不同的主题发送消息，方便灵活应用。如果不指定，则使用默认配置的主题。