How to connect to Mqtt3AsyncClient using HiveMq-mqtt library?

使用 HiveMQ MQTT 库连接到 Mqtt3AsyncClient 的步骤

步骤1：添加 Maven 依赖

首先，确保您的项目中引入了 HiveMQ 的 MQTT 客户端库。如果您是使用 Maven 构建项目，可以在 pom.xml 文件中添加以下依赖：

xml
<dependency>
    <groupId>com.hivemq</groupId>
    <artifactId>hivemq-mqtt-client</artifactId>
    <version>1.2.1</version>
</dependency>

请检查最新版本以确保使用的是最新库。

步骤2：创建 Mqtt3AsyncClient 实例

使用 HiveMQ MQTT 客户端库创建 Mqtt3AsyncClient 实例。这可以通过 MqttClient.builder() 方法实现：

java
import com.hivemq.client.mqtt.mqtt3.Mqtt3AsyncClient;
import com.hivemq.client.mqtt.MqttClient;
import com.hivemq.client.mqtt.mqtt3.Mqtt3ClientBuilder;

public class MqttExample {
    public static void main(String[] args) {
        Mqtt3AsyncClient client = MqttClient.builder()
            .useMqttVersion3()
            .identifier(UUID.randomUUID().toString()) // 客户端标识符
            .serverHost("broker.hivemq.com") // MQTT 服务器地址
            .serverPort(1883) // MQTT 服务器端口
            .buildAsync();
    }
}

步骤3：连接到 MQTT 服务器

使用 connect 方法异步连接到 MQTT 服务器。您还可以通过 Mqtt3Connect 添加额外的连接选项，例如清理会话（clean session）和心跳间隔回（keep alive interval）。

java
import com.hivemq.client.mqtt.mqtt3.message.connect.connack.Mqtt3ConnAck;

public class MqttExample {
    public static void main(String[] args) {
        // 创建 Mqtt3AsyncClient 实例
        Mqtt3AsyncClient client = MqttClient.builder()
            .useMqttVersion3()
            .identifier(UUID.randomUUID().toString())
            .serverHost("broker.hivemq.com")
            .serverPort(1883)
            .buildAsync();

        // 异步连接到 MQTT 服务器
        client.connectWith()
            .cleanSession(true)
            .keepAlive(10)
            .send()
            .whenComplete((connAck, throwable) -> {
                if (throwable != null) {
                    System.out.println("连接失败: " + throwable.getMessage());
                } else {
                    System.out.println("成功连接: " + connAck);
                    // 连接成功后的处理
                }
            });
    }
}

步骤4：处理连接后的业务逻辑

在成功连接到服务器后，您可以开始订阅主题或发布消息。例如，订阅一个主题：

java
client.subscribeWith()
    .topicFilter("test/topic")
    .callback(publish -> {
        System.out.println("收到消息: " + new String(publish.getPayloadAsBytes()));
    })
    .send()
    .whenComplete((subAck, throwable) -> {
        if (throwable != null) {
            System.out.println("订阅失败: " + throwable.getMessage());
        } else {
            System.out.println("成功订阅");
        }
    });

以上就是使用 HiveMQ MQTT 库与 Mqtt3AsyncClient 连接和交互的基本步骤。通过这个客户端库，您可以灵活地处理各种 MQTT 相关的业务需求，如设备通信、物联网数据交换等。