spring boot mqtt订阅者怎么订阅多个主题

使用Spring Boot MQTT时，可以通过配置文件或代码的方式订阅多个主题。以下是两种方法：

配置文件方式

在application.properties或application.yml文件中，添加如下配置：

spring.mqtt.subscribe.topics=topic1,topic2,topic3

其中，多个主题之间用逗号分隔。

代码方式

在Spring Boot的配置类中，注入MqttPahoClientFactory，并通过它创建MqttMessageListenerContainer，然后设置订阅的主题：

@Configuration
public class MqttConfig {

    @Autowired
    private MqttPahoClientFactory mqttPahoClientFactory;

    @Value("${spring.mqtt.subscribe.topics}")
    private String[] topics;

    @Bean
    public MqttMessageListenerContainer mqttMessageListenerContainer() {
        DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();
        container.setConnectionFactory(mqttPahoClientFactory);
        container.setClientId("clientId");
        container.setConcurrency("3-5");
        container.setRecoveryInterval(10000);
        container.setSubscriptionRegistry(new MqttSubscriptionRegistry(topics));
        container.setMessageListener(new MqttMessageListener());
        return container;
    }
}

class MqttSubscriptionRegistry implements SubscriptionRegistry {

    private final String[] topics;

    MqttSubscriptionRegistry(String[] topics) {
        this.topics = topics;
    }

    @Override
    public void registerSubscription(MqttPahoClientSubscription subscription) {
        for (String topic : topics) {
            subscription.addTopic(topic, subscription.getRequestedQos()[0]);
        }
    }

    @Override
    public void unregisterSubscription(MqttPahoClientSubscription subscription) {
        // do nothing
    }
}

class MqttMessageListener implements MessageListener {

    @Override
    public void onMessage(Message message) {
        // handle message
    }
}

在上述代码中，MqttSubscriptionRegistry类实现SubscriptionRegistry接口，重写registerSubscription方法，在其中添加订阅的主题。在MqttMessageListenerContainer的setMessageListener方法中，设置订阅的消息处理器。