springboot mqtt demo

以下是一个使用 Spring Boot 框架实现 MQTT 协议的示例代码：

首先，需要在 pom.xml 文件中添加以下依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-integration</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.integration</groupId>
    <artifactId>spring-integration-mqtt</artifactId>
    <version>5.5.0</version>
</dependency>

然后，在 application.properties 文件中添加以下配置：

mqtt.broker=tcp://localhost:1883
mqtt.clientId=myClientId
mqtt.topic=myTopic

接下来，创建一个 MQTT 配置类，用于配置 MQTT 的连接和消息处理：

@Configuration
@EnableIntegration
public class MqttConfig {

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

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

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

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

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

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

    @Bean
    @ServiceActivator(inputChannel = "mqttInputChannel")
    public MessageHandler mqttMessageHandler() {
        return message -> {
            String payload = message.getPayload().toString();
            System.out.println("Received message: " + payload);
            // 处理接收到的消息
        };
    }

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

}

在上述代码中，我们创建了一个 MqttPahoClientFactory 实例来配置 MQTT 连接参数。然后，我们创建了一个 MessageChannel 实例来接收 MQTT 消息。接着，我们创建了一个 MessageProducer 实例来监听指定的 MQTT 主题，并将消息发送到 MessageChannel。然后，我们创建了一个 MessageHandler 实例来处理接收到的 MQTT 消息。最后，我们创建了一个 IntegrationFlow 实例将上述组件连接在一起。

最后，创建一个 Spring Boot 应用程序的入口类，并启动应用程序：

@SpringBootApplication
public class Application {

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }

}

现在，你可以使用 MQTT 客户端向指定的主题发送消息，并在控制台上查看接收到的消息。