springboot 集成 MQTT 订阅接收多个 topic

Spring Boot 集成 MQTT 订阅接收多个 topic 的基本步骤如下：

1. 添加依赖：首先需要在 Spring Boot 项目的 pom.xml 文件中添加 MQTT 客户端库的依赖。常用的库有 Eclipse Paho MQTT Java Client。比如添加如下依赖：

<dependency>
    <groupId>org.eclipse.paho</groupId>
    <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
    <version>1.2.5</version>
</dependency>

2. 配置 MQTT 连接属性：通过配置文件（比如 application.properties 或 application.yml）定义 MQTT 服务器连接的相关属性，如服务器地址、端口、用户名、密码等。

# application.properties 示例
mqtt.url=tcp://broker.hivemq.com:1883
mqtt.username=user
mqtt.password=password

3. 配置 MQTT 客户端：创建一个配置类，并使用 `@Configuration` 注解标记。通过 `@Bean` 注解创建并配置 `MqttConnectOptions` 和 `MqttPahoClientFactory`。这样 Spring Boot 容器会自动配置 MQTT 客户端，并且可以根据需要自动注入。

@Configuration
public class MqttConfig {

    @Value("${mqtt.url}")
    private String url;

    @Value("${mqtt.username}")
    private String username;

    @Value("${mqtt.password}")
    private String password;

    @Bean
    public MqttConnectOptions mqttConnectOptions() {
        MqttConnectOptions mqttConnectOptions = new MqttConnectOptions();
        mqttConnectOptions.setServerURIs(new String[]{url});
        mqttConnectOptions.setUserName(username);
        mqttConnectOptions.setPassword(password.toCharArray());
        return mqttConnectOptions;
    }

    @Bean
    public MqttPahoClientFactory mqttClientFactory() {
        DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory();
        factory.setConnectionOptions(mqttConnectOptions());
        return factory;
    }
}

4. 实现消息监听器：创建一个类实现 `MqttMessageListener` 接口或使用 `@MqttMessageSubscriber` 注解，定义消息接收的方法，然后订阅需要接收消息的 topic。

@Service
public class MqttReceiver implements MqttMessageListener {

    @Override
    @MqttMessageSubscriber(topic = "topic1")
    public void processMessage(String data) {
        // 处理接收到的消息
    }

    @Override
    @MqttMessageSubscriber(topic = "topic2")
    public void processMessage(String data) {
        // 处理接收到的消息
    }
}

通过以上步骤，Spring Boot 应用就能够集成 MQTT 并订阅多个 topic 接收消息了。