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

棘手的消息优先级

郗福
2023-03-14

Netty中是否有任何嵌入式优先级机制可以帮助我决定哪些消息比其他消息发送得更频繁?

共有2个答案

林博厚
2023-03-14

消息按写入通道的顺序发送。你到底想做什么?

米裕
2023-03-14

您可以使用需要使用未绑定优先级队列实现的BufferedWriteHandler对写入进行优先级排序。引用JavaDocs:

您可以通过在此处理程序的构造函数中指定一个无界优先级队列来实现优先级写入。需要设计适当的策略来确定调用flush()的频率。例如,您可以定期调用flush(),每秒使用HashedWheelTimer。

 类似资料:
  • RabbitMQ有消息优先级的概念吗?我有一个问题,一些更重要的消息由于队列中不太重要的消息而被拖慢。我希望高优先级的优先,并移动到队列的前面。 我知道我可以用两个队列来近似计算,一个是“快”队列,另一个是“慢”队列,但这看起来像是一个黑客。 有人知道使用RabbitMQ的更好的解决方案吗?

  • TLDR:通过FCM发送到Android设备的消息需要10秒到5分钟才能送达。可能是因为优先权。我将其设置为“高”,但它似乎没有保持在该值上。 我为iOS和Android开发了一个应用程序。我的后端运行在Django上。对于我们的实时通信,我们最近开始使用Firebase云消息传递(FCM)。 我成功地连接了Django服务器,并且能够向这两种设备发送消息。 这是我构造消息的python代码。请注

  • 我正在研究Kafka是否支持任何要处理的队列或消息的优先级。 看来它不支持任何这样的事情。我在谷歌上找到了这个也支持这一点的邮件存档:http://mail-archives.apache.org/mod_mbox/incubator-kafka-users/201206.mbox/%3CCAOEJIJHVHSR=d6astihpsqwvg6vk5xylam6ymdcd6uauoxf-dq@mai

  • 什么是最方便的方法来影响消息转换器的优先级Spring应用时发布与? 用例:我想确保给定的实体被发布为JSON,而不是例如。XML当我做。 违约 选项1 您可以显式地为给定的实例配置消息转换器,如。如果实例是共享的(例如作为Spring bean),这是不方便的,因为您可能需要在一个情况下使用转换器X,在不同的情况下使用转换器Y。 选择2 您可以显式地设置和HTTP头,在这种情况下,Spring将

  • 我正在使用for。对于这个我正在使用,https://github.com/vyuldashev/laravel-queue-rabbitmq. 对于正常队列和消费者,一切都很好。为了区分消息的优先级,我定义了多个队列,在队列名中使用0-3作为后缀。我通过手动计算作业总数,将作业路由到不同的队列。 使用这种方法,对于不同的任务,我需要创建更多具有名称优先级的队列。创建队列名称中包含 0-3 的队列

  • 本文向大家介绍新手学习css优先级,包括了新手学习css优先级的使用技巧和注意事项,需要的朋友参考一下 css不是一种程序语言,而是一种描述语言。因此,可以说,css理解起来是非常容易的,大部分人通过简单的学习就可以懂得如何写css代码来定义网页的样式。但是,大部分人同样也会在写css的过程中产生很多困惑,比如为什么自己写的某段css没有生效,或者呈现出的样式和预计的不同,但又不知道要如何解决。