如何在Spring Boot中建立连接及测试

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>3.0.5</version>
</parent>
<dependencies>
    <!-- Spring Boot整合JUnit单元测试的起步依赖 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
    </dependency>
    <!-- MQTT Java客户端依赖 -->
    <dependency>
        <groupId>org.eclipse.paho</groupId>
        <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
        <version>1.2.5</version>
    </dependency>
</dependencies>

package com.takumilove.mqtt.test;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
import org.junit.jupiter.api.Test;
/**
 * @author: Takumilove
 * @description: 通过JUnit测试，验证MQTT客户端与服务器的连接是否成功。
 * @date: 2024/12/13
 **/
public class MqttPahoTest {
    // MQTT服务器地址
    String serverURI = "tcp://156.238.***.***:1883";
    // 客户端ID
    String clientId = "paho_test";
    @Test
    public void createConnection() throws MqttException {
        // 创建MqttClient对象，使用内存持久化
        MqttClient mqttClient = new MqttClient(serverURI, clientId, new MemoryPersistence());
        // 配置连接选项
        MqttConnectOptions options = new MqttConnectOptions();
        options.setUserName("admin"); // 设置用户名
        options.setPassword("123456".toCharArray()); // 设置密码
        options.setCleanSession(true); // 设置是否清除会话
        // 连接到MQTT服务器
        mqttClient.connect(options);
        System.out.println("连接成功");
        // 让当前线程阻塞，保持连接
        while (true) ;
    }
}