回答情况：
提问时间：
问题标签：
我已经安装了RabbitMQ，能够立即发布和使用来自rails应用程序的兔子创业板消息。在发布到RabbitMQ交换时，如何实现每条消息预定义延迟时间的延迟排队？
浏览 5提问于2017-02-01得票数 2
我们使用rabbitmq消息延迟插件(rabbitmq_delayed_message_exchange)来延迟消息。为了调试和监视目的，是否可以在rabbitmq管理web界面中显示保留的/延迟的消息？再见，本
浏览 1提问于2018-06-08得票数 0
回答已采纳
我面临着这样一种场景:队列中的每条消息都应该在延迟一段时间后被消费，这可以使用RabbitMQ中的TTL和死信交换来实现，但当最大TTL将位于头部时，其他消息将不会被消费。我希望实现队列中的每个消息在延迟后被消费，而不管它在队列中的位置。
浏览 18修改于2020-06-02得票数 0
我已经做了一些研究，但找不到任何解决方案来删除或修改队列中已经存在的消息。(RabbitMQ)。用例:我正在尝试使用RabbitMQ中的延迟消息功能(headers.put("x-delay"，5000))发送通知(比方说30分钟后)。我想发送一个可以删除/修改消息内容的事件。在RabbitMQ中有什么方法可以做到这一点吗？
另一种方法是使用数据库和调度程序，如果这是不可能的，我将实现。
浏览 29修改于2020-06-04得票数 0
我已经安装了'RabbitMQ延迟消息插件‘。并且可以在RabbitMq的插件列表上看到。
var services = new ServiceCollection();
services.AddMassTransit但是我得到了一个错误：未知交换类型‘x-延迟消息’RabbitMq和MassTransit。
浏览 0提问于2021-05-02得票数 0
回答已采纳
我希望扇出交换在将消息添加到exchange A之前添加消息头"x-delay: 30000“。有什么方法可以做到这一点吗？我使用的是RabbitMQ 3.8.19和管理控制台插件。 说明: Exchange A是RabbitMQ延迟的消息交换。本质上，我希望A上的消息被延迟。显而易见的答案是在扇出交换上提交初始消息的延迟。然而，我真正想要是A有30秒的延迟，B有10秒的
浏览 9修改于2021-07-09得票数 2
我有几个使用RabbitMQ作为消息代理的.Net 5.0微服务。现在我正在切换到AWS SQS。很少有服务正在侦听相同的消息(这是在RabbitMQ中使用Exchange完成的)。在AWS中，这可以通过向SNS主题订阅SQS队列来实现。我创建了SNS fifo主题和SQS fifo队列，将这些队列订阅到主题。当我直接将消息发布到队列时，一切都会立即生效，但当我将消息发布到SNS主题时，从队列订阅到主题需要7分钟以上的时间。有没有人注
浏览 34提问于2021-10-05得票数 1
我使用rabbitmq工具在spring引导时提供支持。现在我应该将消息发送到队列中，延迟时间过后，队列将传递消息。Rabbitmq支持rabbitmq-延迟消息交换插件来调度消息.但我没有付诸实施。(我启用了插件延迟)DirectExchange directExchange() {
Map<String, Object> args = new HashMap&l
浏览 3修改于2016-03-16得票数 7
我有一个要求，在一定的持续时间后发送消息到MessageListener，所以有任何方法来实现使用Spring。
例如。生产者产生消息并将消息发送到RabbitMQ q，消息接收侦听器立即收听该q，我想延迟在客户端接收该消息，比如在某些配置参数(例如1000 to )之后。
浏览 4提问于2016-11-16得票数 3
回答已采纳
我们的初创企业目前正在使用RabbitMQ (与Python/Django一起)作为消息队列，现在我们计划转移到Amazon SQS，因为它的高可用性&它们的延迟队列功能。但我在互联网上到处读到，SQS执行缓慢&而且成本效益很高，所以选择Amazon还是应该坚持使用RabbitMQ是明智的决定吗？如果我们坚持使用RabbitMQ，那么“延迟队列”的替代解决方案是什么呢？
浏览 2提问于2014-12-05得票数 0
回答已采纳
我需要在rabbitmq (延迟消息插件)上安装一个插件，但我不喜欢“手动”方式，所以如果删除了这个插件，我必须再次安装插件。rabbitmq-plugins enable rabbitmq_delayed_message_exchange
浏览 0提问于2018-06-29得票数 2
回答已采纳
我正在寻找一种解决方案来使用RabbitMQ来安排消息，这样不仅可以像几个来源中描述的那样延迟消息，而且可以计划它有一条消息，例如每天。如果不是RabbitMQ，那么对于使用消息总线的微服务环境，您还能想到什么其他的解决方案吗？因此，它实际上是关于将任务调度器和消息总线的概念结合起来……
或者，使用作业调度程序只是为了将消息推送到消息队列，例如结合使用</
浏览 2修改于2018-06-10得票数 8
回答已采纳
我有一个系统，它使用mongoDB作为持久性，使用RabbitMQ作为消息代理。我面临一个挑战，我只想为发布失败场景实现RabbitMQ。我不确定这是否可能，因为我也有使用相同mongoDB持久性的使用者，所以当我编写一个代码，涵盖RabbitMQ发布失败场景的事务性发件箱时，发布的消息会在mongoDB commitTransaction之前到达消费者，因此由于延迟，我的使用者无
浏览 28提问于2021-08-30得票数 1
回答已采纳
为了与(一个特定的RabbitMQ messages实现)兼容，喷射使用并尽可能快地确认广播消息是关键。Message实例的规范坚持这样一个事实，即使用者必须实现内存中的队列，以便在处理时间较慢的情况下不延迟确认。
在喷口和螺栓之间有这样一个隐含的队列吗？是否必须在螺栓中实现内存中的队列？
浏览 4提问于2017-01-04得票数 0
回答已采纳
我们正在使用rabbitmq (3.6.6)将分析(百万)发送到不同的分析器。这些非常快，我们计划使用兔子消息插件来安排对分析元素的监视。我们正在考虑兔子延迟交换插件，我们已经做了一些测试，我们需要一些澄清。
RabbitMQ被内核杀死了，因为像这样工作一周后内存使用量很高(4GB硬件)。延迟交换的Mnesia文件
浏览 3提问于2017-01-10得票数 0
回答已采纳
0回答
我很难找到一种方法来延迟SpringAMQP中的消息级别。如果服务不可用或抛出异常，我会调用keep服务，我会将所有请求存储到RabbitMQ队列中，并不断重试服务调用，直到它成功执行。如果服务持续抛出错误或不可用，rabbitMQ侦听器将继续循环。(这意味着侦听器检索消息并进行服务调用，如果出现任何错误，则将消息重新排队)
我使用MessagePostProcessor限制循环到X小时，但是我想在消息级别上启用延迟，并在每次尝试访问
浏览 4修改于2016-07-09得票数 1
回答已采纳
对于此功能，应用程序使用第三方服务作为和。以下是应用程序的数据流。Web应用
由于Amazon端可能存在网络延迟、操作延迟和故障等问题，web应用程序使用作为调度器应用程序来实现异步、重试等行为，并将SNS发送任务存储在队列中并进行异步处理。芹菜作为调度器使用RabbitMQ作为它的代理应用程序。以下是数据流。我们可以看到当芹菜向RabbitMQ发送任务时，特定的RabbitMQ队列数会增加，这意味着芹菜成功地创建了一个任务对象
浏览 0提问于2018-04-11得票数 0
我试图了解如何设置basic.nacked消息的重发时间。一些重要的信息是，我使用的仲裁队列的重发量为5次。考虑以下情况：
消息是对原始队列的不满。我之所以想这样做，是因为我使用的是OCC &在某些情况下，延迟消息重新传递可以解决一致性问题。(对于那些想知道为什么
浏览 6修改于2022-08-13得票数 0
回答已采纳
服务A连续地(但不是以周期性的方式)向服务B发送消息。该消息采用简单的键/值格式。键是整数，值是当前本地日期和时间。既然我们已经将RabbitMQ引入到我们的解决方案中，我们也需要修改这个通信模型。我正在考虑对10分钟时间窗口使用延迟消息交换，然后重写和重置从服务A传入的重复消息的时间(重排10分钟)。
浏览 0修改于2019-06-05得票数 1
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号