我是netty的新手。我想开发一个服务器，旨在接收来自可能很少（比如 Max 是 2 个）客户端的请求。但是每个客户端都会不断地向服务器发送许多请求。服务器必须处理此类请求并响应客户端。所以，在这里我假设即使我配置了多个工作线程，它也可能没有用，因为只有 2 个活动连接。工作线程再次阻塞，直到它处理并响应客户端。所以，请让我知道如何处理这些类型的问题。 如果我在工作线程中使用 threadpoolexecutor 以多线程方式处理两个客户端请求，它会高效吗？或者如果它可以通过netty框架实现，请让我知道如何做到这一点？ 提前谢谢...
【问题讨论】：
标签： multithreading netty
如果我理解正确：您的客户端 (2) 将发送许多消息，每个消息都暗示服务器会尽快回复。
可以看到2个选项：
answear 过程很短（足够短，不会成为您想要达到的速率的问题，这意味着 1 个线程能够尽可能快地回答 1 个客户端的需求）：那么您可以继续使用在服务器引导程序中设置的来自 Netty 的标准线程（一次 1 个客户端的 1 个工作线程）。这是最短路径。
answear过程时间不够短（速度会很可怕，比如因为有一个“长时间”的过程，比如阻塞调用、数据库访问、文件写入……）：那么你可以在 Netty 管道中为你的 ChannelHandler 添加一个线程池（一个组）来做这样的阻塞/长进程。
以下是从 ChannelPipeline 中摘录的 API 文档： http://netty.io/4.0/api/io/netty/channel/ChannelPipeline.html
// Tell the pipeline to run MyBusinessLogicHandler's event handler methods
// in a different thread than an I/O thread so that the I/O thread is not blocked by
// a time-consuming task.
// If your business logic is fully asynchronous or finished very quickly, you don't
// need to specify a group.
pipeline.addLast(group, "handler", new MyBusinessLogicHandler());
【讨论】：
只需将带有特殊 EventExecutorGroup 的 ChannelHandler 添加到 ChannelPipeline。例如 UnorderedThreadPoolEventExecutor (src)。
类似的东西。
UnorderedThreadPoolEventExecutor executorGroup = ...;
pipeline.addLast(executorGroup, new MyChannelHandler());
【讨论】：