【开源视频联动物联网平台】vertx写一个mqtt客户端

<dependency>
    <groupId>io.vertx</groupId>
    <artifactId>vertx-mqtt-client</artifactId>
    <version>4.2.2</version> <!-- 请根据实际情况调整版本号 -->
</dependency>

import io.vertx.core.AbstractVerticle;
import io.vertx.core.Vertx;
import io.vertx.core.buffer.Buffer;
import io.vertx.mqtt.MqttClient;
import io.vertx.mqtt.MqttClientOptions;
 
public class MqttClientVerticle extends AbstractVerticle {
 
    @Override
    public void start() {
        MqttClientOptions options = new MqttClientOptions()
            .setAutoKeepAlive(true)
            .setKeepAliveTimeSeconds(10);
 
        MqttClient mqttClient = MqttClient.create(vertx, options);
 
        mqttClient.connect(1883, "mqtt.eclipse.org", ar -> {
            if (ar.succeeded()) {
                System.out.println("Connected to the MQTT broker");
 
                // 订阅主题
                mqttClient.subscribe("your_topic", 0, subAck -> {
                    if (subAck.succeeded()) {
                        System.out.println("Subscribed to topic");
                    } else {
                        System.err.println("Failed to subscribe to topic");
                    }
                });
 
                // 发布消息
                mqttClient.publish("your_topic", Buffer.buffer("Hello, MQTT!"), 0, false, false, pubAck -> {
                    if (pubAck.succeeded()) {
                        System.out.println("Message published");
                    } else {
                        System.err.println("Failed to publish message");
                    }
                });
            } else {
                System.err.println("Failed to connect to the MQTT broker");
            }
        });
    }
 
    public static void main(String[] args) {
        Vertx vertx = Vertx.vertx();
        vertx.deployVerticle(new MqttClientVerticle());
    }
}