java - 在不同的 ChannelPipeline 中共享 ExecutionHandler

Question

我的服务器有两个不同类型的客户端，它们具有不同的消息格式，因此服务器中有两个 NioServerSocketChannelFactory 分别处理两种类型的客户端请求。这两种类型的客户端需要在两个NioServerSocketChannelFactory的处理程序中访问同一个对象。我可以在两个 ChannelPipelines 中共享相同的 OrderedMemoryAwareThreadPoolExecutor 对象吗？

例如:

Channels.pipeline(
    concurrencyHandler,
    new Handler1());
}

Channels.pipeline(
    concurrencyHandler,
    new Handler2());
}

当 handler1 和 2 访问同一个对象时，OrderedMemoryAwareThreadPoolExecutor 会处理线程并发吗？

Answer 1

您应该为每个 ChannelFactory 使用一个 ExecutionHandler，因为 OrderedMemoryAwareThreadPoolExecutor 使用 Channel id 来查找给定 Channel 的正确 Executor。 Channel id 仅对每个 ChannelFactory 是唯一的，因此如果您在不同的 ChannelFactory 之间共享它，可能会产生严重的副作用。