当前位置: 首页 > 知识库问答 >
问题:

Netty 4使用不同于通道的键来维护事件顺序

宇文元明
2023-03-14

Netty 3中有一个OrderedMemoryAwareThreadPoolExecutor,文档中描述了如何更改排序键:http://docs.jboss.org/netty/3.2/api/org/jboss/netty/handler/execution/OrderedMemoryAwareThreadPoolExecutor.html

在Netty 4中,这是用EventExecutorGroup方法替换的类。据我所知,如果我使用DefaultEventExecutorGroup,它将按通道保持顺序(顺便说一句,正确吗?)。但如果我在一个通道上多路复用了多个会话,并且我想使用其他密钥并行执行,那么通道有没有办法在Netty 4中实现它?

共有1个答案

路奇
2023-03-14

不是Netty自己提供的任何东西。您可能可以使用自定义EventExecutorInvoker,它将是Netty 4.1的一部分。您可以在我们的问题跟踪程序中打开一个问题,解释您的用例,以便我们能够跟踪吗?

 类似资料:
  • 我有一个从各种文件加载时间序列数据的应用程序。应用程序为每个文件打开一个线程以并行加载数据。文件中的记录是有序的,但我需要向应用程序的其余部分提供一个提要,以维护事件的整体顺序。 这是否可以使用像多个生产者一样的破坏者——一种消费者类型的设计来实现,以维持事件的顺序? 我目前正在使用阻塞集合和排序列表对每个阻塞集合的头部进行排序,但这会消耗大量内存,我想看看是否有其他人使用不同的体系结构实现了类似

  • 我使用水槽代理通过水槽代理收集外部数据。外部数据批次几乎是每 10 秒 1MB。我按如下方式配置了水槽代理。 我按以下方式激活了代理。 可惜后来发现netcat source运行良好,channel或者sink出了问题。从Ubuntu的资源监视器,我可以看到以下性能。网络性能。蓝色曲线表示输入,而红色曲线表示在没有其他应用程序运行网络io的情况下的输出,我确信这个图展示了我的Flume代理发生了什

  • 我有一个异步执行的查询的输入流。我想确保当我使用时,这些要求的结果将按照输入查询流的顺序收集。 这是我的代码的样子: SQLQueryEngine。执行(查询);返回

  • 问题内容: 我想写一个查询 或诸如此类 你能帮我么? 问题答案: 这应该工作: 从 MSDN : 在使用UNION,EXCEPT或INTERSECT运算符的查询中,仅在语句末尾才允许使用ORDER BY。仅当您在顶级查询中 而不是子查询中 指定UNION,EXCEPT和INTERSECT时,此限制才适用。 编辑 :强制您需要将顺序应用于外部查询的顺序。我已经向两个查询添加了一个常量值列。

  • 问题内容: 我正在使用JSONObject来删除JSON字符串中不需要的certin属性: 它可以正常工作,但是问题是JSONObject是“名称/值对的无序集合”,我想保持String在通过JSONObject操作之前的原始顺序。 任何想法如何做到这一点? 问题答案: 你不能 这就是为什么我们称其 为名称/值对的无序集合 。 我不确定为什么需要这样做。但是,如果要订购,则必须使用json数组。

  • 我想为Netty处理程序使用不同于套接字的输入。这可能吗?如果是这样,什么是有效的输入格式?