vertxmqtt +springboot 服务器代码

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

首先，确保你已经添加了 Spring Boot 和 Vert.x Mqtt 的依赖。在 pom.xml 文件中添加以下依赖：

<dependencies>
    <!-- Spring Boot -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter</artifactId>
    </dependency>
    
    <!-- Vert.x -->
    <dependency>
        <groupId>io.vertx</groupId>
        <artifactId>vertx-core</artifactId>
        <version>4.1.3</version>
    </dependency>
    <dependency>
        <groupId>io.vertx</groupId>
        <artifactId>vertx-mqtt</artifactId>
        <version>4.1.3</version>
    </dependency>
</dependencies>

然后，创建一个 Spring Boot 应用程序，并编写一个包含 Vert.x Mqtt 服务器的组件类：

import io.vertx.core.Vertx;
import io.vertx.mqtt.MqttServer;
import io.vertx.mqtt.MqttServerOptions;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class MqttServerApplication implements CommandLineRunner {

    @Value("${mqtt.server.port}")
    private int mqttServerPort;

    public static void main(String[] args) {
        SpringApplication.run(MqttServerApplication.class, args);
    }

    @Override
    public void run(String... args) {
        Vertx vertx = Vertx.vertx();

        MqttServerOptions options = new MqttServerOptions()
                .setPort(mqttServerPort);

        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());
            }
        });
    }
}

在上面的示例中，我们使用 `@Value` 注解从配置文件中获取 MQTT 服务器的端口号。你可以在 application.properties 或 application.yml 文件中定义该属性。

最后，运行 Spring Boot 应用程序，Vert.x Mqtt 服务器将在指定的端口上启动。当客户端连接到服务器并发布消息时，将显示相应的日志。

请根据你的实际需求进行适当的修改和扩展。记得在运行代码之前，确保已经正确配置了 MQTT 服务器的端口。