springboot集成mqtt 发布/订阅

Spring Boot 是一个用于快速构建 Spring 应用程序的框架，而 MQTT 是一种轻量级的消息传递协议。将 Spring Boot 和 MQTT 集成可以让我们更加容易地创建一个可靠的、实时的通信系统。以下是如何将 Spring Boot 集成 MQTT 发布/订阅的步骤：

1. 引入 MQTT 相关依赖：在 pom.xml 文件中添加以下依赖：

<dependency>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-mqtt</artifactId>
<version>1.1.3.RELEASE</version>
</dependency>

2. 配置 MQTT：在 application.properties 文件中添加以下配置：

# MQTT 配置
mqtt.client.id=spring-boot-mqtt
mqtt.username=username
mqtt.password=password
mqtt.url=tcp://localhost:1883

3. 编写发布代码：使用 Spring Integration 的 PublishSubscribeChannel 和 MqttPahoMessageHandler 来向 MQTT 发布消息。

@Autowired
private MessageChannel mqttOutboundChannel;

public void sendToMqtt(String message) {
mqttOutboundChannel.send(MessageBuilder.withPayload(message).build());
}

4. 编写订阅代码：使用 Spring Integration 的 MqttPahoMessageDrivenChannelAdapter 和 MessageHandler 来实现订阅。

@Bean
public MessageChannel mqttInputChannel() {
return new DirectChannel();
}

@Bean
public MqttPahoMessageDrivenChannelAdapter mqttInbound() {
String clientId = MqttAsyncClient.generateClientId();

MqttPahoMessageDrivenChannelAdapter adapter =
new MqttPahoMessageDrivenChannelAdapter(mqtt.url, clientId,
mqtt.topic);

adapter.setCompletionTimeout(5000);
adapter.setConverter(new DefaultPahoMessageConverter());
adapter.setQos(1);
adapter.setOutputChannel(mqttInputChannel());

return adapter;
}

@Bean
@ServiceActivator(inputChannel = "mqttInputChannel")
public MessageHandler handler() {
return message -> {
String payload = message.getPayload().toString();
System.out.println("MQTT Received: " + payload);
};
}

通过以上步骤，我们可以轻松地集成 MQTT 发布/订阅功能。注意，在实际的应用程序中，我们需要为 MQTT 客户端定义一个独特的客户端 ID，并在订阅消息时指定选择的 MQTT 主题。这可以确保不同的客户端能够接收到正确的消息。