spring-integration-mqtt 订阅多个主题，并不同主题处理方法不同的代码

您可以使用Spring Integration的MessageHandler来处理收到的MQTT消息。在此基础上，您可以使用不同的处理方法来处理不同的主题。以下是一个示例代码：

@Configuration
@EnableIntegration
public class MqttConfig {

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

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

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

    @Autowired
    private MqttMessageHandler messageHandler;

    @Bean
    public MqttConnectOptions mqttConnectOptions() {
        MqttConnectOptions options = new MqttConnectOptions();
        options.setUserName(username);
        options.setPassword(password.toCharArray());
        return options;
    }

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

    @Bean
    public IntegrationFlow mqttInFlow() {
        return IntegrationFlows.from(
                inboundAdapter(),
                e -> e.poller(Pollers.fixedDelay(5000)))
                .handle(messageHandler)
                .get();
    }

    @Bean
    public MessageProducerSupport inboundAdapter() {
        MqttPahoMessageDrivenChannelAdapter adapter =
                new MqttPahoMessageDrivenChannelAdapter(
                        "mqttInbound",
                        mqttClientFactory(),
                        "topic1", "topic2", "topic3");
        adapter.setCompletionTimeout(5000);
        adapter.setConverter(new DefaultPahoMessageConverter());
        adapter.setQos(1);
        return adapter;
    }

}

在上面的代码中，我们使用了`MqttPahoMessageDrivenChannelAdapter`来订阅多个主题。在`inboundAdapter()`方法中，我们传入了多个主题。在`mqttInFlow()`方法中，我们将`messageHandler`作为处理器来处理收到的MQTT消息。您可以根据需要编写不同的处理器来处理不同的主题。