35.10. 重新使用 Netty boss 和 worker 线程池


Netty 有两个线程池:WE 和 worker。默认情况下,每个 Netty 使用者和制作者都有自己的私有线程池。如果要在多个消费者或制作者之间重复使用这些线程池,则必须在 Registry 中创建并列出线程池。

例如,使用 Spring XML,我们可使用 NettyWorkerPoolBuilder 和 2 worker 线程创建共享 worker 线程池,如下所示:

<!-- use the worker pool builder to help create the shared thread pool -->
<bean id="poolBuilder" class="org.apache.camel.component.netty.NettyWorkerPoolBuilder">
  <property name="workerCount" value="2"/>
</bean>

<!-- the shared worker thread pool -->
<bean id="sharedPool" class="org.jboss.netty.channel.socket.nio.WorkerPool"
      factory-bean="poolBuilder" factory-method="build" destroy-method="shutdown">
</bean>
注意

对于 boss 线程池,存在用于 Netty producers 的 org.apache.camel.component.nettyServerBossPoolBuilder 构建器,以及 org.apache.camel.component.nettyClientBossPoolBuilder,用于 Netty producers。

然后,在 Camel 路由中,您可以通过在 URI 中配置 workerPool 选项来引用这个 worker 池,如下所示:

<route>
  <from uri="netty:tcp://0.0.0.0:5021?textline=true&amp;sync=true&amp;workerPool=#sharedPool&amp;usingExecutorService=false"/>
  <to uri="log:result"/>
  ...
</route>

另外,如果我们有另一个路由,我们可以参考共享 worker 池:

<route>
  <from uri="netty:tcp://0.0.0.0:5022?textline=true&amp;sync=true&amp;workerPool=#sharedPool&amp;usingExecutorService=false"/>
  <to uri="log:result"/>
  ...
</route>

以此类推。

Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

© 2024 Red Hat, Inc.