Vert.x系列：
Vert.x介绍：https://blog.csdn.net/haoranhaoshi/article/details/89279096
Vert.x实战一：Vert.x通过Http发布数据：https://blog.csdn.net/haoranhaoshi/article/details/89284847
Vert.x实战二：TCP通信：https://blog.csdn.net/haoranhaoshi/article/details/89296522
Vert.x实战三：TCP客户端之间以角色通过服务端转接通信：https://mp.csdn.net/postedit/89296606
Vert.x实战四：TCP客户端之间以角色和同一角色连接顺序通过服务端转接通信：https://blog.csdn.net/haoranhaoshi/article/details/89296665
Vert.x实战五：TCP客户端之间以ID通过服务端转接通信：https://blog.csdn.net/haoranhaoshi/article/details/89296754
Vert.x实战六：TCP客户端之间以功能名通过服务端转接通信：https://blog.csdn.net/haoranhaoshi/article/details/89296841
Vert.x实战七：TCP设置超时断开：https://blog.csdn.net/haoranhaoshi/article/details/89296986
Vert.x的TCP服务端和客户端配置：https://blog.csdn.net/haoranhaoshi/article/details/89297022
Vert.x的Http和TCP实战代码下载：https://download.csdn.net/download/haoranhaoshi/11114611

本篇：TCP客户端和服务端通信

package VertxTCPBaseTest;

import io.vertx.core.AbstractVerticle;
import io.vertx.core.Vertx;
import io.vertx.core.buffer.Buffer;
import io.vertx.core.net.NetServer;

public class VertxTCPServer extends AbstractVerticle {

    @Override
    public void start() {
        // 创建TCP服务器
        NetServer server = vertx.createNetServer();

        // 处理连接请求
        server.connectHandler(socket -> {
            socket.handler(buffer -> {
                // 在这里应该解析报文，封装为协议对象，并找到响应的处理类，得到处理结果，并响应
                System.out.println("接收到的数据为：" + buffer.toString());

                // 按照协议响应给客户端
                socket.write(Buffer.buffer("Hello Vertx from Server!"));
            });

            // 监听客户端的退出连接
            socket.closeHandler(close -> {
                System.out.println("客户端退出连接");
            });

        });

        // 监听端口
        server.listen(33323, res -> {
            if (res.succeeded()) {
                System.out.println("服务器启动成功");
            }
        });
    }

    public static void main(String[] args) {
        Vertx.vertx().deployVerticle(new VertxTCPServer());
    }
}

package VertxTCPBaseTest;

import io.vertx.core.AbstractVerticle;
import io.vertx.core.Vertx;
import io.vertx.core.buffer.Buffer;
import io.vertx.core.net.NetClient;
import io.vertx.core.net.NetSocket;

public class VertxTCPClient extends AbstractVerticle {
    private static NetSocket netSocket;

    @Override
    public void start() {
        // 创建一个TCP客户端
        NetClient client = vertx.createNetClient();

        // 连接服务器
        client.connect(33323, "localhost", conn -> {
            if (conn.succeeded()) {
                System.out.println("客户端连接服务端成功");
                netSocket = conn.result();
                // 向服务器写数据
                netSocket.write(Buffer.buffer("Hello Vertx from Client!"));

                // 读取服务器的响应数据
                netSocket.handler(buffer -> {
                    System.out.println("接收到的数据为：" + buffer.toString());
                });
            } else {
                System.out.println("连接服务器异常");
            }
        });
    }

    public static void main(String[] args) {
        Vertx.vertx().deployVerticle(new VertxTCPClient());
    }
}