企业开发中Springboot集成MQTT

在企业级应用开发中，Spring Boot 是一种流行的轻量级框架，常用于简化初始项目设置和快速构建。将 Spring Boot 集成 MQTT（Message Queuing Telemetry Transport）则可以让你的应用程序能够与其他系统或设备进行实时通信。

集成步骤大致如下：

1. 添加依赖：首先，在项目的 `pom.xml` 或 `build.gradle` 文件中添加 Spring Cloud Stream 和相关的 MQTT 客户端库依赖，如 `spring-cloud-stream-starter-mqtt`。

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

2. 创建配置：在 `application.yml` 或 `application.properties` 中配置 MQTT 的连接信息，如服务器地址、端口、用户名和密码等。

spring:
  cloud:
    stream:
      bindings:
        input-outlet:
          destination: your-topic
          contentType: application/json
        output-outlet:
          sendTo: direct://output
        mqtt:
          brokers: "tcp://localhost:1883"

3. 消息生产者或消费者：创建消息生产者的组件，通过 `@Input` 注解从 `input-outlet` 接收数据并发送到 MQTT，或创建消息消费者的组件，通过 `@StreamListener` 注解监听指定主题的数据。

@Component
public class MqttProducer {

    @Autowired
    private MqttTemplate mqtt;

    @StreamListener("input-outlet")
    public void sendMessage(String message) {
        mqtt.send("your-topic", message);
    }
}

@Component
public class MqttConsumer {

    @StreamListener("output-outlet")
    public void consumeMessage(Message<?> message) {
        String payload = new String(message.getPayload(), StandardCharsets.UTF_8);
        // 处理接收到的消息
    }
}