Netty Nio 用 Ja​​va 读取 ChannelFuture 即将发布的消息

Question

我正在尝试使用the following code，它是 Netty Nio 中 Web 套接字的一种实现。我已经实现了一个 JavaFx Gui，我想从 Gui 中读取从服务器或其他客户端接收到的消息。 NettyClient 代码如下：

public static ChannelFuture callBack () throws Exception{

    String host = "localhost";
    int port = 8080;
    try {
        Bootstrap b = new Bootstrap();
        b.group(workerGroup);
        b.channel(NioSocketChannel.class);
        b.option(ChannelOption.SO_KEEPALIVE, true);
        b.handler(new ChannelInitializer<SocketChannel>() {
            @Override
            public void initChannel(SocketChannel ch) throws Exception {
                ch.pipeline().addLast(new RequestDataEncoder(), new ResponseDataDecoder(),
                        new ClientHandler(i -> {
                            synchronized (lock) {
                                connectedClients = i;
                                lock.notifyAll();
                            }
                        }));
            }
        });
        ChannelFuture f = b.connect(host, port).sync();
        //f.channel().closeFuture().sync();

        return f;
    }
    finally {
        //workerGroup.shutdownGracefully();
    }
}

public static void main(String[] args) throws Exception {

    ChannelFuture ret;
    ClientHandler obj = new ClientHandler(i -> {
        synchronized (lock) {
            connectedClients = i;
            lock.notifyAll();
        }
    });
   ret = callBack();
        int connected = connectedClients;
    if (connected != 2) {
        System.out.println("The number if the connected clients is not two before locking");
        synchronized (lock) {
            while (true) {
                connected = connectedClients;
                if (connected == 2)
                    break;
                System.out.println("The number if the connected clients is not two");
                lock.wait();
            }
        }
    }
    System.out.println("The number if the connected clients is two: " + connected );
    ret.channel().read(); // can I use that from other parts of the code in order to read the incoming messages?
}

如何使用从我的代码的其他部分的回调返回的 channelFuture 来读取传入的消息？是否需要再次调用callBack，或者如何才能收到频道的更新消息？我可以从我的代码（在按钮事件中）使用ret.channel().read() 之类的东西（以便获取最后一条消息）吗？

Answer 1

通过阅读该代码，NettyClient用于创建连接（ClientHandler），一旦连接完成，Netty调用ClientHandler.channelActive，如果你想向服务器发送数据，你应该在这里放一些代码。如果这个连接获取消息表单服务器，ClientHandler.channelRead被Netty调用，把你的代码来处理消息。

您还需要阅读文档以了解 netty 编码器/解码器的工作原理。

• 如何使用我的代码其他部分的回调返回的 channelFuture 来读取传入的消息？

  分享那些由NettyClient创建的ClientHandler(NettyClient.java line 29)

• 是否需要再次调用callBack，或者如何才能收到频道的更新消息？

  如果服务器消息来了，ClientHandler.channelRead 被调用。

• 我可以从我的代码（在按钮事件中）使用 ret.channel().read() 之类的东西（以便获取最后一条消息）吗？

  是的，你可以，但不是一种网络方式，玩网络，你写回调（当消息到来时，当消息发送时......），等待网络调用你的代码，即：驱动程序是网络，不是你.

最后，你真的需要这么重的库来做网络吗？如果没有，试试This code，简单易懂