springboot集成mqtt完整代码

以下是一个完整的 Spring Boot 应用程序与 Eclipse Paho MQTT 客户端库整合的示例代码：

1. 添加依赖

在 pom.xml 文件中添加以下依赖：

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

<dependency>
    <groupId>org.eclipse.paho</groupId>
    <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
    <version>1.2.5</version>
</dependency>

2. 配置 MQTT 连接参数

在 application.properties 文件中添加以下 MQTT 连接参数：

mqtt.server.uri=tcp://localhost:1883
mqtt.client.id=my-mqtt-client

3. 编写 MQTT 客户端

编写一个 MQTT 客户端类，用于连接 MQTT 服务器并订阅主题：

@Component
public class MqttClient {

    @Value("${mqtt.server.uri}")
    private String serverUri;

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

    private MqttClient mqttClient;

    @PostConstruct
    public void connect() throws MqttException {
        mqttClient = new MqttClient(serverUri, clientId);
        mqttClient.setCallback(new MqttCallback() {
            @Override
            public void connectionLost(Throwable cause) {
                // 连接丢失的回调方法
            }

            @Override
            public void messageArrived(String topic, MqttMessage message) throws Exception {
                // 消息到达的回调方法
            }

            @Override
            public void deliveryComplete(IMqttDeliveryToken token) {
                // 消息发送完成的回调方法
            }
        });
        mqttClient.connect();
        mqttClient.subscribe("my/topic");
    }

    public void publish(String topic, String payload) throws MqttException {
        MqttMessage message = new MqttMessage(payload.getBytes());
        mqttClient.publish(topic, message);
    }

    @PreDestroy
    public void disconnect() throws MqttException {
        mqttClient.disconnect();
    }
}

4. 在控制器中使用 MQTT 客户端

在控制器中使用 MQTT 客户端发布消息：

@RestController
public class MyController {

    @Autowired
    private MqttClient mqttClient;

    @GetMapping("/publish")
    public String publish() throws MqttException {
        mqttClient.publish("my/topic", "Hello, MQTT!");
        return "OK";
    }
}

5. 启动应用程序

运行应用程序，并访问 /publish 路径来发布消息。您可以使用 MQTT 客户端订阅 "my/topic" 主题，以接收此消息。