springboot 连接mosquitto的代码

要在Spring Boot应用程序中连接到Mosquitto服务器，你可以使用Eclipse Paho MQTT客户端库。以下是一个简单的示例代码：

首先，添加以下依赖项到您的pom.xml文件中：

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

然后，您可以编写如下代码来连接到Mosquitto服务器：

import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;

public class MqttClientExample {

    private static final String BROKER_URL = "tcp://localhost:1883";
    private static final String CLIENT_ID = "clientId";

    public static void main(String[] args) {
        try {
            MqttClient mqttClient = new MqttClient(BROKER_URL, CLIENT_ID);
            MqttConnectOptions options = new MqttConnectOptions();
            options.setCleanSession(true);
            mqttClient.connect(options);
            System.out.println("Connected to Mosquitto broker!");
            mqttClient.disconnect();
            System.out.println("Disconnected from Mosquitto broker!");
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }
}

在上面的代码中，我们使用MqttClient类创建一个MQTT客户端，并使用MqttConnectOptions类设置连接选项。然后，我们使用mqttClient.connect(options)方法连接到Mosquitto服务器，并使用mqttClient.disconnect()方法断开连接。请注意，这只是一个简单的示例代码，您可以根据您的需求进行更改和扩展。