springboot集成spring-integration-mqtt

Spring Boot provides easy integration with the Spring Integration framework for implementing messaging and integration patterns. Spring Integration provides support for various messaging protocols, including MQTT, a lightweight publish/subscribe messaging protocol.

To integrate Spring Integration with MQTT in Spring Boot, follow these steps:

1. Add the following dependencies to your `pom.xml` file:

<dependency>
    <groupId>org.springframework.integration</groupId>
    <artifactId>spring-integration-core</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.integration</groupId>
    <artifactId>spring-integration-mqtt</artifactId>
</dependency>

2. Create a configuration class for MQTT integration:

@Configuration
@EnableIntegration
public class MqttIntegrationConfig {

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

    @Value("${mqtt.client.id}")
    private String clientId;

    @Bean
    public MessageChannel mqttInputChannel() {
        return new DirectChannel();
    }

    @Bean
    public MqttPahoClientFactory mqttClientFactory() {
        DefaultMqttPahoClientFactory factory = new DefaultMqttPahoClientFactory();
        MqttConnectOptions options = new MqttConnectOptions();
        options.setServerURIs(new String[] { brokerUrl });
        factory.setConnectionOptions(options);
        return factory;
    }

    @Bean
    public MessageProducer inbound() {
        MqttPahoMessageDrivenChannelAdapter adapter = new MqttPahoMessageDrivenChannelAdapter(
                clientId, mqttClientFactory(), "topic1", "topic2");
        adapter.setCompletionTimeout(5000);
        adapter.setConverter(new DefaultPahoMessageConverter());
        adapter.setQos(1);
        return adapter;
    }

    @Bean
    public MessageHandler mqttMessageHandler() {
        return new MessageHandler() {
            @Override
            public void handleMessage(Message<?> message) throws MessagingException {
                System.out.println("Received MQTT message: " + message.getPayload());
            }
        };
    }

    @Bean
    public IntegrationFlow mqttInFlow() {
        return IntegrationFlows.from(inbound())
                .handle(mqttMessageHandler())
                .channel(mqttInputChannel())
                .get();
    }
}

3. Configure the MQTT broker URL and client ID in your application properties file:

mqtt.broker.url=tcp://localhost:1883
mqtt.client.id=myClientId

4. Use the `mqttInputChannel` channel to send messages to the MQTT broker. For example:

@Autowired
private MessageChannel mqttInputChannel;

public void sendMqttMessage(String payload) {
    mqttInputChannel.send(MessageBuilder.withPayload(payload).build());
}

With these steps, you can easily integrate MQTT messaging with your Spring Boot application using Spring Integration.