Vert.x TCP服务器
Vert.x随附有一个TCP服务器，可轻松在应用程序中创建TCP服务器。我们可以根据需要创建一个或者多个TCP服务器。在本教程中，我将研究如何从垂直内部创建TCP服务器以及如何处理传入的连接和数据。
创建一个TCP服务器
通过调用" Vertx"对象上的" createNetServer()"方法来创建Vert.x TCP服务器。看起来是这样的：
NetServer server = vertx.createNetServer();
我们通常会在一个垂直内部创建一个TCP服务器。这是从垂直内部创建Vert.x TCP服务器的方法：
import io.vertx.core.AbstractVerticle;
import io.vertx.core.net.NetServer;
public class VertxTcpServerVerticle extends AbstractVerticle {
@Override
public void start() throws Exception {
NetServer server = vertx.createNetServer();
}
}
启动TCP服务器
一旦创建了TCP服务器，就可以使用它的listen()方法启动它。这是启动TCP服务器的外观：
public class VertxTcpServerVerticle extends AbstractVerticle {
@Override
public void start() throws Exception {
NetServer server = vertx.createNetServer();
server.listen(10000);
}
}
本示例将启动服务器，并指示其在TCP端口10.000上进行侦听。
NetServer类包含listen()方法的更多版本，为我们提供启动TCP服务器的不同选项。
在TCP服务器上设置连接处理程序
为了处理传入的TCP连接，我们需要在TCP服务器上设置连接处理程序。通常，这是在启动TCP服务器之前完成的。这是一个Vert.x TCP服务器连接处理程序示例：
public class VertxTcpServerVerticle extends AbstractVerticle {
@Override
public void start() throws Exception {
NetServer server = vertx.createNetServer();
server.connectHandler(new Handler<NetSocket>() {
@Override
public void handle(NetSocket netSocket) {
System.out.println("Incoming connection!");
}
});
server.listen(10000);
}
}
每当TCP服务器的客户端创建新的TCP连接时，都会调用connect处理程序的handle()方法。作为参数传递给handle()方法的NetSocket对象可以访问传入的连接(套接字等)。
从套接字读取数据
为了从传入的连接中读取数据，我们需要在NetSocket对象上为连接设置一个处理程序。这是完成的方式：
public class VertxTcpServerVerticle extends AbstractVerticle {
@Override
public void start() throws Exception {
NetServer server = vertx.createNetServer();
server.connectHandler(new Handler<NetSocket>() {
@Override
public void handle(NetSocket netSocket) {
System.out.println("Incoming connection!");
netSocket.handler(new Handler<Buffer>() {
@Override
public void handle(Buffer buffer) {
System.out.println("incoming data: "+buffer.length());
buffer.getString(0,buffer.length());
}
});
}
});
server.listen(10000);
}
}
将数据写入套接字
处理完传入的数据后，我们可能需要将响应写回到客户端。我们可以通过传递给连接处理程序的handle()方法的NetSocket实例来实现。这是一个通过NetSocket将数据写回到客户端的例子：
public class VertxTcpServerVerticle extends AbstractVerticle {
@Override
public void start() throws Exception {
NetServer server = vertx.createNetServer();
server.connectHandler(new Handler<NetSocket>() {
@Override
public void handle(NetSocket netSocket) {
System.out.println("Incoming connection!");
netSocket.handler(new Handler<Buffer>() {
@Override
public void handle(Buffer inBuffer) {
System.out.println("incoming data: " + inBuffer.length());
String data =
inBuffer.getString(0, inBuffer.length());
Buffer outBuffer = Buffer.buffer();
outBuffer.appendString("response...");
netSocket.write(outBuffer);
}
});
}
});
server.listen(10000);
}
}
NetSocket方法的write方法是异步的。因此，它立即返回。数据将在以后写入底层套接字。
NetSocket类包含更多版本的write()方法，使我们可以编写例如直接将一个String插入套接字，而不使用Buffer。有关更多详细信息，请参见Vert.x JavaDoc。
关闭TCP服务器
完成TCP服务器后，可以使用它的close()方法关闭它。这是关闭Vert.x TCP服务器的样子：
server.close();
关闭TCP服务器是异步操作，因此close()方法可能在TCP服务器实际关闭之前退出。如果需要在TCP服务器关闭时收到通知，则可以将Handler传递给close()方法。 TCP服务器完全关闭时，将调用此处理程序。看起来是这样的：
server.close(new Handler<AsyncResult<Void>>() {
@Override
public void handle(AsyncResult result) {
if(result.succeeded()){
//TCP server fully closed
}
}
});
