vert.x mqtt 服务器 代码

下面是一个使用 Vert.x Mqtt 服务器的简单示例代码：

import io.vertx.core.Vertx;
import io.vertx.mqtt.MqttServer;
import io.vertx.mqtt.MqttServerOptions;

public class MqttServerExample {
    public static void main(String[] args) {
        Vertx vertx = Vertx.vertx();
        
        MqttServerOptions options = new MqttServerOptions()
                .setPort(1883) // 设置服务器端口
                .setHost("localhost"); // 设置服务器主机
                
        MqttServer mqttServer = MqttServer.create(vertx, options);
        
        mqttServer.endpointHandler(endpoint -> {
            System.out.println("Client connected: " + endpoint.clientIdentifier());
            
            endpoint.publishHandler(message -> {
                System.out.println("Received message from client: " + message.payload().toString());
            });
            
            endpoint.accept(false);
        });
        
        mqttServer.listen(ar -> {
            if (ar.succeeded()) {
                System.out.println("Mqtt server started on port " + ar.result().actualPort());
            } else {
                System.err.println("Mqtt server failed to start: " + ar.cause().getMessage());
            }
        });
    }
}

这个示例代码创建了一个基本的 MQTT 服务器，并监听本地主机的 1883 端口。当客户端连接到服务器时，打印出客户端标识符。当客户端向服务器发布消息时，打印出接收到的消息内容。

你可以根据自己的需求修改代码中的参数和逻辑，来构建符合你业务需求的 Vert.x Mqtt 服务器应用程序。记得在运行代码之前，确保已经添加了 Vert.x 和 MQTT 服务器的依赖。