springboot对接Mosquitto

Spring Boot 是一个流行的轻量级 Java 框架，它简化了构建生产级别的 web 应用程序的初始设置。而 Mosquitto 是一个开源的 MQTT (Message Queuing Telemetry Transport) 服务器，用于设备间的消息发布/订阅通信，常用于 IoT 和实时数据传输。

要在 Spring Boot 中集成 Mosquitto，你可以按照以下步骤操作：

1. **添加依赖**：在你的 `pom.xml` 或者 `build.gradle` 文件中，添加 Spring Cloud Stream 的 mqtt 支持依赖，例如使用 Maven:

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

或者 Gradle:

implementation 'org.springframework.cloud:spring-cloud-stream-sink-mqtt'
implementation 'org.springframework.cloud:spring-cloud-stream-source-mqtt'

2. **配置连接信息**：在 `application.yml` 或 `application.properties` 中配置 Mosquitto 的地址、端口和认证信息，如：

spring.cloud.stream.bindings.input.destination=your-topic
spring.cloud.stream.binder.mqtt.broker-uri=mosquitto://localhost:1883
spring.cloud.stream.binder.mqtt.username=your-username
spring.cloud.stream.binder.mqtt.password=your-password

3. **创建消息处理组件**：定义一个接收消息并进行处理的处理器，比如使用 `@MessagingGateway` 注解：

import org.springframework.messaging.Message;
import org.springframework.messaging.handler.annotation.SendTo;

@SpringBootApplication
@EnableBinding(MyMqttApplication binder)
public class MyMqttApplication {

    @SendTo("output")
    public String processMessage(Message<String> message) {
        // 处理接收到的 MQTT 消息
        return "Received and processed: " + message.getPayload();
    }

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

4. **消息发送**：如果你的应用还需要向 Mosquitto 发送消息，可以使用 `@StreamListener` 注解创建一个监听器方法，比如：

import org.springframework.cloud.stream.messaging.SendAction;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.stereotype.Component;

@Component
public class MessagePublisher {

    private final Sink output;

    public MessagePublisher(Sink output) {
        this.output = output;
    }

    public void send(String message) {
        SendAction.send(output, message);
    }
}