多个Netty客户端向一个Netty服务器发送数据

Question

我使用的是Netty 3.9.5，我有一个简单的客户机-服务器设置，我从http://en.wikipedia.org/wiki/Netty_（软件）#Netty\u TCP\u示例。我扩展了这个示例，将Java search plan对象从客户端发送到服务器。在这个网站上跟踪用户的帮助下，我已经能够让这个程序按预期运行。

现在，我想让我的读卡器/服务器程序同时接受多个客户端。我想我会使用下面列出的原始管道工厂代码：

channelFactory = new NioServerSocketChannelFactory(bossThreadPool,
            workerThreadPool);
    this.bootstrap = new ServerBootstrap(channelFactory);
    this.bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
        @Override
        public ChannelPipeline getPipeline() throws Exception {
            return Channels.pipeline(
                    new ObjectEncoder(),
                    new ObjectDecoder(ClassResolvers
                            .cacheDisabled(getClass().getClassLoader())),
                    new ServerMessageHandler());
        }
    });

并进行此更改：

channelFactory = new NioServerSocketChannelFactory(bossThreadPool,workerThreadPool, 3);

我认为这将在workerThreadPool中创建3个工作线程，从而能够处理3个客户端连接。这不起作用。第一个客户端连接按预期工作，但第二个连接最终引发连接超时异常。

问题：

>

我对workerThreadPool的假设正确吗？如果是，我忘记了什么

现在，我的代码仍然只使用一个端口进行连接。是否需要为每个可能的连接提供唯一的端口？我没有看到这样的例子。我需要调整bind方法还是acceptor。isBound方法是否适用于可能的多个连接？

public boolean connect() {
boolean status = false; // assume failure

final int LISTEN_PORT = 53233;

/*
 * We use a channel when attempting to bind the ServerBootstrap to
 * ensure if the operation was successful
 */
acceptor = this.bootstrap.bind(new InetSocketAddress(LISTEN_PORT));

/*
 * We make sure the Server could bind to the port by calling the
 * isBound() method in the Channel class.
 */
if (!acceptor.isBound()) {
    logger.error(ErrorMessage.SERVER_UNABLE_TO_BIND + LISTEN_PORT);

    status = false;
} else {
    status = true;
    logger.info(Message.SERVER_CONNECTION_SUCCESSFUL + LISTEN_PORT
            + "!" + Message.SERVER_AWAITING_CONNECTIONS);
}

return status;
}

任何帮助都将不胜感激。谢谢

Answer 1

你说得对，工作池与并发连接数相关联。你以工人身份通过了什么样的遗嘱执行人？我建议使用执行器。newCachedThreadPool（）。在这种情况下，In建议不要在NioServerSocketChannelFactory中设置任何第三个值，因为默认情况下，它将使用NumberOfCore*2，所以就像之前一样。

另外，我假设您的ServerMessageHandler不会永远阻塞（或者很长时间），因为如果阻塞了，那么您必须在管道中的它之前添加类似于OrderedMemoryAwareThreadPoolExecutor的内容，以释放工作线程。