spring-integration-mqtt 详解多topic订阅代码示例

Spring Integration MQTT 提供了一个方便的方式来集成 MQTT 客户端到 Spring 应用程序中。下面是一个示例代码，演示如何在 Spring Integration 中使用 MQTT 子协议实现多个主题的订阅。

首先，需要在 Spring 配置文件中声明 MQTT 连接工厂和 MQTT 输入通道：

<bean id="mqttClientFactory" class="org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory">
    <property name="userName" value="${mqtt.username}" />
    <property name="password" value="${mqtt.password}" />
</bean>

<int-mqtt:message-driven-channel-adapter id="mqttInbound"
        client-factory="mqttClientFactory"
        auto-startup="true"
        url="${mqtt.url}"
        topics="topic1,topic2,topic3"
        qos="2"
        converter="mqttDefaultPahoMessageConverter"
        channel="mqttInputChannel"/>

在这个示例中，我们使用 `DefaultMqttPahoClientFactory` 来创建 MQTT 连接工厂，`mqtt.username` 和 `mqtt.password` 属性用于设置连接的用户名和密码。`mqttInbound` 是一个消息驱动的通道适配器，用于从 MQTT 代理服务器接收消息。`mqtt.url` 属性设置了 MQTT 服务器的 URL，`topics` 属性设置了要订阅的主题列表，`qos` 属性设置了消息的服务质量，`converter` 属性设置了消息转换器，`mqttInputChannel` 是一个输入通道，用于接收 MQTT 消息。

接下来，可以在 Spring 配置文件中声明一个消息处理器，用于处理接收到的 MQTT 消息：

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

<bean id="mqttMessageHandler" class="com.example.MqttMessageHandler"/>

在这个示例中，我们使用 `service-activator` 元素来声明一个消息处理器，`mqttInputChannel` 是输入通道，`mqttMessageHandler` 是消息处理器的引用，`handleMessage` 方法用于处理接收到的消息。`MqttMessageHandler` 是一个自定义的消息处理器，它实现了 `MessageHandler` 接口：

public class MqttMessageHandler implements MessageHandler {
    @Override
    public void handleMessage(Message<?> message) throws MessagingException {
        // 处理接收到的消息
    }
}

在 `handleMessage` 方法中，可以获取到接收到的 MQTT 消息，然后进行处理。

总之，以上是一个简单的示例，演示了如何在 Spring Integration 中使用 MQTT 子协议实现多个主题的订阅。需要注意的是，要在 Spring 配置文件中导入 `int-mqtt` 命名空间和 `int` 命名空间。