将这段代码整合到springboot中

要在 Spring Boot 中整合 Java MQTT 客户端，你可以按照以下步骤进行操作：

1. 在你的 Spring Boot 项目中添加 Eclipse Paho MQTT 客户端依赖。你可以在 Maven 或 Gradle 构建工具中添加以下依赖项：

Maven:

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

Gradle:

implementation 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.2.5'

2. 创建一个 Spring Boot 的组件（Component）类，用于处理 MQTT 客户端的连接、订阅、发布等操作。

import org.eclipse.paho.client.mqttv3.*;
import org.springframework.stereotype.Component;

@Component
public class MqttClientComponent {

    private MqttClient client;

    public MqttClientComponent() {
        String broker = "tcp://mqtt.example.com:1883";
        String clientId = "JavaMqttClient";
        MemoryPersistence persistence = new MemoryPersistence();

        try {
            client = new MqttClient(broker, clientId, persistence);

            MqttConnectOptions connOpts = new MqttConnectOptions();
            connOpts.setCleanSession(true);

            client.connect(connOpts);

            client.setCallback(new MqttCallback() {
                public void messageArrived(String topic, MqttMessage message) throws Exception {
                    System.out.println("Received message: " + new String(message.getPayload()));
                }

                public void connectionLost(Throwable cause) {
                    System.out.println("Connection lost");
                }

                public void deliveryComplete(IMqttDeliveryToken token) {
                }
            });

            String topic = "myTopic";
            int qos = 1;

            client.subscribe(topic, qos);

        } catch (MqttException e) {
            e.printStackTrace();
        }
    }

    public void publishMessage(String topic, String message) throws MqttException {
        int qos = 1;
        client.publish(topic, message.getBytes(), qos, false);
    }

    public void disconnect() throws MqttException {
        client.disconnect();
    }
}

3. 创建一个 Spring Boot 控制器（Controller）类，用于接收 HTTP 请求并调用 MQTT 客户端发布消息的方法。

import org.eclipse.paho.client.mqttv3.MqttException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class MqttController {

    @Autowired
    private MqttClientComponent mqttClientComponent;

    @PostMapping("/publish")
    public void publishMessage(@RequestBody String message) {
        String topic = "myTopic";

        try {
            mqttClientComponent.publishMessage(topic, message);
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }
}

4. 运行你的 Spring Boot 应用程序，并发送 POST 请求到 `/publish` 路径，传递消息内容作为请求体。例如，你可以使用 cURL 命令或 Postman 工具发送请求。

这样，当你发送 POST 请求时，消息将被发布到 MQTT 代理，并通过 MQTT 客户端接收。

请注意，这只是一个简单的示例代码，你可以根据实际需求进行修改和扩展。例如，你可以添加认证、错误处理等功能来提高代码的健壮性和安全性。

希望这能帮助到你在 Spring Boot 中整合 Java MQTT 客户端！如果还有其他问题，请随时提问。