vertx内的多线程

Question

我是vert的新手。x、 我在尝试垂直。x“NetServer”功能。http://vertx.io/core_manual_java.html#writing-tcp服务器和客户端，它的工作方式很有魅力。

然而，我也读到“verticle实例严格来说是单线程的。

如果您创建一个简单的TCP服务器并部署它的单个实例，那么该服务器的所有处理程序始终在同一个事件循环（线程）上执行。”

目前，对于我的实现，我希望接收TCP字节流，然后触发另一个组件。但这不应该是Verticle的“start”方法中的阻塞调用。那么，在start方法中编写执行器是一种好的做法吗？或者vertx是否自动处理此类情况。

这里有一个片段

public class TCPListener extends Verticle {

    public void start(){

        NetServer server = vertx.createNetServer();

        server.connectHandler(new Handler<NetSocket>() {
            public void handle(NetSocket sock) {
                container.logger().info("A client has connected");
                sock.dataHandler(new Handler<Buffer>() {
                    public void handle(Buffer buffer) {
                        container.logger().info("I received " + buffer.length() + " bytes of data");

                        container.logger().info("I received " + new String(buffer.getBytes()));
                        //Trigger another component here. SHould be done in a sperate thread. 
                        //The previous call should be returned . No need to wait for component response.
                    }
                });
            }
        }).listen(1234, "host");
    }
}

应该有什么机制使其成为非阻塞调用。

Answer 1

正如duffymo提到的那样，创建线程违背了使用vertx的目的。最好的方法是将消息写入eventbus并创建一个新的处理程序来监听来自eventbus的消息。更新代码以展示这一点。将消息写入“next.topic”主题，并注册一个处理程序来读取来自“next.topic”主题的消息。

public class TCPListener extends Verticle {

public void start(){

    NetServer server = vertx.createNetServer();

    server.connectHandler(new Handler<NetSocket>() {
        public void handle(NetSocket sock) {
            container.logger().info("A client has connected");
            sock.dataHandler(new Handler<Buffer>() {
                public void handle(Buffer buffer) {
                    String recvMesg = new String(buffer.getBytes());
                    container.logger().info("I received " + buffer.length() + " bytes of data");

                    container.logger().info("I received " + recvMesg);
                    //Writing received message to event bus
                    vertx.eventBus().send("next.topic", recvMesg);
                }
            });
        }
    }).listen(1234, "host");

    //Registering new handler listening to "next.topic" topic on event bus
    vertx.eventBus().registerHandler("next.topic", new Handler<Message<String>() {
       public void handle(Message<String> mesg) {
           container.logger.info("Received message: "+mesg.body());
       }
    };

}
}

Answer 2

最灵活的方法是创建ExecutorService并使用它处理请求。这带来了对工作线程模型的细粒度控制（固定或可变的线程数，应该在单个线程上串行执行哪些工作，等等）。

修改后的示例可能如下所示：

public class TCPListener extends Verticle {

    private final ExecutorService executor = Executors.newFixedThreadPool(10);

    public void start(){

        NetServer server = vertx.createNetServer();

        server.connectHandler(new Handler<NetSocket>() {
            public void handle(final NetSocket sock) { // <-- Note 'final' here
                container.logger().info("A client has connected");
                sock.dataHandler(new Handler<Buffer>() {
                    public void handle(final Buffer buffer) { // <-- Note 'final' here

                        //Trigger another component here. SHould be done in a sperate thread. 
                        //The previous call should be returned . No need to wait for component response.
                        executor.submit(new Runnable() {

                            public void run() {
                                //It's okay to read buffer data here
                                //and use sock.write() if necessary
                                container.logger().info("I received " + buffer.length() + " bytes of data");
                                container.logger().info("I received " + new String(buffer.getBytes()));
                            }
                        }
                    }
                });
            }
        }).listen(1234, "host");
    }
}

Answer 3

我认为这不是vert的发展方向。十、

更好的方法是正确使用事件总线而不是执行器。让工作人员在总线上响应事件，进行处理，并在总线完成时向总线发出信号。

创建线程违背了使用vert的目的。十、