SpringBoot 集成mqtt

在Spring Boot中集成MQTT（Message Queuing Telemetry Transport）是一个常见的需求，尤其是在需要实现物联网（IoT）通信时。MQTT是一种轻量级的、基于发布/订阅模式的消息传输协议，广泛用于低带宽、不可靠或高延迟的网络环境中。

以下是一个基本的步骤指南，介绍如何在Spring Boot项目中集成MQTT：

1. 添加依赖

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

2. 配置MQTT客户端

参数配置

@Data
@Component("mqttConfigProp")
@ConfigurationProperties(prefix = "mqtt")
public class MqttConfigProp {
    private String[] serverURIs;
    private String clientId;
    private String userName;
    private char[] password;
    private String topic;
    private int timeout;
    private int keepAlive;
    private boolean cleanSession;
}

接收配置

@Slf4j
@Configuration
@EnableIntegration
public class MqttConfigurationInbound {

    @Autowired
    private MqttConfigProp mqttConfigProp;

    @Bean
    public Mqt