如何使用Vert.x 3在websocket上管理连接用户？

Question

为了说服一些人从旧学校技术转换,我需要构建一个聊天演示应用程序,使用Java管理超过10K的并发连接(如Node.Js的东西).

我测试了Netty 5.0,这很棒,但需要做很多工作; 另一方面,Jetty 9.3非常棒,但与其他竞争对手相比速度较慢.

经过一番搜索后,我找到了基于Netty的Vert.x 3工具包,有很多很棒的工具(不需要重新发明轮子),我在git中看到了这些例子,我能够构建一个websocket服务器等等.

public void start() throws Exception {
    vertx.createHttpServer().websocketHandler(new Handler<ServerWebSocket>() {
        @Override
        public void handle(ServerWebSocket e) {
           // business stuff in the old style not yet lambda 
        }
    }).listen(port);
}

作为Vert.x世界的新手,我无法弄清楚如何管理使用它的连接用户,通常旧的时尚方式是使用类似的东西:

HashMap<UUID,ServerWebSocket> connectedUsers;

建立连接后,检查它是否存在; 如果不是我将它添加为新条目并执行一些功能来发送,广播,通过集合检索等等.

我的问题是Vert.x 3有什么东西可以处理连接以跟踪它们并删除那些离开(乒乓),广播等等,或者我应该从头开始使用cookie,session,....)

我找不到使用Vert.x 3的任何真实例子.

Answer 1

基本上，websocketHandler 的范围代表一个连接。在您的示例中，这是您的匿名类。我创建了一个小型 websocket 聊天示例，其中使用 Vert.x 事件总线将消息分发给所有客户端。

在服务器的 start 方法中，我们处理 websocket 连接。您可以实现 closeHandler 来监控客户端断开连接。还有异常处理程序、乒乓处理程序等。您可以使用 textHandlerID 来识别特定连接，但您也可以访问远程地址。

 public void start() throws Exception {
        vertx.createHttpServer().websocketHandler(handler -> {
            System.out.println("client connected: "+handler.textHandlerID());

            vertx.eventBus().consumer(CHAT_CHANNEL, message -> {
                handler.writeTextMessage((String)message.body());
            });

            handler.textMessageHandler(message -> {
               vertx.eventBus().publish(CHAT_CHANNEL,message);
            });

            handler.closeHandler(message ->{
                System.out.println("client disconnected "+handler.textHandlerID());
            });

        }).listen(8080);
    }

客户端示例也是用 Java 编写的。它只是将 websocket 连接上收到的所有消息打印到控制台。连接后，它会发送一条消息。

public void start() throws Exception {
        HttpClient client = vertx.createHttpClient();

        client.websocket(8080, "localhost", "", websocket -> {
            websocket.handler(data -> System.out.println(data.toString("ISO-8859-1")));
            websocket.writeTextMessage(NAME+ ":hello from client");
        });

    }