前言

关于vertx介绍这里就不多说了，官网说的很详细，https://vertx.io/

服务端搭建

创建springboot项目，引入依赖

	<dependencies>
        <dependency>
            <groupId>io.vertx</groupId>
            <artifactId>vertx-core</artifactId>
            <version>4.2.7</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

创建Verticle，用Verticle创建更易于管理，

关于verticle介绍可以看这里https://vertx.io/docs/vertx-core/java/#_verticles

/**
 * @author resthx
 * @date 16:14 2022/6/30
 */

public class MyVerticle extends AbstractVerticle {

    NetServer server;

    @Override
    public void start() throws Exception {
    	//配置
        NetServerOptions netServerOptions = new NetServerOptions();
        //设置socket多长时间未收到消息超时（s）
        netServerOptions.setReadIdleTimeout(120);
        //创建server
        server = vertx.createNetServer(netServerOptions);
         //socket处理
        server.connectHandler(
                netSocket -> {
                	//socket收到消息处理
                    netSocket.handler(
                            buffer -> {
                                System.out.println(buffer.length());
                                this.handlerSocket(buffer,netSocket);
                            }
                    );
                    //socket关闭处理
                    netSocket.closeHandler(
                            close -> {
                                System.out.println("通道"+netSocket+"已关闭");
                            }
                    );
                }
        );
        //开启监听
        server.listen(6789,"0.0.0.0");
    }
	//处理逻辑
    private void handlerSocket(Buffer buffer, NetSocket netSocket) {
        System.out.println(buffer.toString());
    }
}

配置vertx，并部署Verticle

/**
 * @author resthx
 * @date 15:42 2022/6/30
 */
@Configuration
public class VertxConfig {

/*    private final MyVerticle myVerticle;

    public VertxTest(MyVerticle myVerticle) {
        this.myVerticle = myVerticle;
    }*/

    @Bean
    public Vertx myVertx() {
        Vertx vertx = Vertx.vertx();
        //部署Verticle,并使用event线程组
        Future<String> future = vertx.deployVerticle(MyVerticle.class, new DeploymentOptions());
        future.onSuccess(
                handler -> {
                	//部署成功获取Verticle Id，这里只打印，后续通过id可以停止服务
                    System.out.println(future);
                }
        );
        Set<VerticleFactory> verticleFactories = vertx.verticleFactories();

        return vertx;
    }

}