Netty客户端的Java输入

Question

实际上，我正在使用Netty编写一个客户机-服务器程序，但我陷入了一个自上周以来无法解决的问题。

因为这是一个相当大的程序，我不能粘贴我所有的代码，但是，我开始使用这个例子从Netty的github（https://github.com/netty/netty/tree/4.1/example/src/main/java/io/netty/example/securechat）

在游戏的上下文中，我希望允许玩家键入他喜欢的每个命令（更改他的名字，或者查看发生了什么），但问题是，在输入过程中，我无法接收服务器的答案。

通过回调接收服务器回答：

public class ClientHandler extends SimpleChannelInboundHandler<String> {

    @Override
    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
        System.out.println(cause.getMessage());
        ctx.close();
        System.exit(84);
    }

    @Override
    public void channelRead0(ChannelHandlerContext arg0, String answer) throws Exception {
       // HERE
    }
}

在我的主循环中，我实际上正在这样做（我简化了它，因为它太长了）：

BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
String line;
line = in.readLine();
// Process and send to server
System.out.println(line);

当我等待用户输入并同时收到服务器应答时，输入阻塞了我的回调。我只在输入完成时收到它。

有人能告诉我吗？我如何继续进行非阻塞输入或其他操作，以便在服务器实际向我发送内容时，我可以停止输入过程并读取答案？

非常感谢。

Answer 1

您应该将输入循环与netty处理程序解耦。

如果您从netty处理程序启动游戏输入循环，这将意味着netty线程永远不会返回netty的核心，因此您的通道被标记为繁忙，这意味着新的输入将排队，并且只有当线程返回时才会被处理。

解决这个问题的一个好方法是在程序开始时创建一个新的线程实例，并使该线程调用netty的方法来执行游戏操作。