使用 spring-integration-mqtt 接收客户端消息

Spring Integration提供了一种方便的方式来使用MQTT协议与MQTT代理进行通信。以下是使用spring-integration-mqtt接收客户端消息的基本步骤：

1. 添加spring-integration-mqtt依赖项到您的项目中。

2. 在您的Spring配置文件中创建一个MqttPahoMessageDrivenChannelAdapter bean，用于接收消息。配置包括MQTT代理的连接信息和要订阅的主题。

<int-mqtt:message-driven-channel-adapter id="mqttInbound"
    client-id="clientId1"
    url="tcp://localhost:1883" 
    topics="myTopic1,myTopic2"
    channel="mqttInputChannel"/>

3. 创建一个消息通道来接收从MQTT代理发送的消息。

<int:channel id="mqttInputChannel"/>

4. 创建一个消息处理器bean，用于处理接收到的消息。

<bean id="mqttHandler" class="com.example.MyMqttMessageHandler"/>

5. 将消息通道与消息处理器关联起来。

<int:service-activator input-channel="mqttInputChannel"
    ref="mqttHandler" method="handleMessage"/>

6. 创建一个消息处理器类，实现MessageHandler接口，并实现handleMessage方法。在该方法中，您可以处理接收到的消息并执行任何必要的操作。

public class MyMqttMessageHandler implements MessageHandler {
    @Override
    public void handleMessage(Message<?> message) throws MessagingException {
        String topic = message.getHeaders().get("mqtt_topic").toString();
        String payload = message.getPayload().toString();
        System.out.println("Received MQTT message on topic " + topic + ": " + payload);
    }
}

7. 启动应用程序并开始接收来自MQTT代理的消息。