回答情况：
提问时间：
问题标签：
我面临着这样一种场景:队列中的每条消息都应该在延迟一段时间后被消费，这可以使用RabbitMQ中的TTL和死信交换来实现，但当最大TTL将位于头部时，其他消息将不会被消费。我希望实现队列中的每个消息在延迟后被消费，而不管它在队列中的位置。
浏览 18修改于2020-06-02得票数 0
我有一个系统，它使用mongoDB作为持久性，使用RabbitMQ作为消息代理。我面临一个挑战，我只想为发布失败场景实现RabbitMQ。我不确定这是否可能，因为我也有使用相同mongoDB持久性的使用者，所以当我编写一个代码，涵盖RabbitMQ发布失败场景的事务性发件箱时，发布的消息会在mongoDB commitTransaction之前到达消费者，因此由于延迟，我的使用者无法在mongoDB中找到消息。6-如果mongoDB abortTran
浏览 28提问于2021-08-30得票数 1
回答已采纳
我正在实现一个日常作业，它从MongoDB (大约300 K文档)获取数据，并为每个文档在RabbitMQ队列上发布一条消息。另一方面，我在同一个队列中有一些消费者，理想情况下，这些用户应该并行工作。
一切都很正常，但没有我想的那么多，特别是关于消费者的表现。据我所了解，从我非常短的RabbitMQ经验，这应该可以保证所有的消费者被调用。顺便说一下，消费者需要0.5到1.2秒来完成他们的任务。我刚刚发现了很短的3秒。我并不期望交付/消
浏览 2修改于2018-04-16得票数 2
回答已采纳
我有一个关于RabbitMq消费者确认的查询，我阅读了RabbitMq上的文档，声明确认消息应该在消费者接收到的同一个通道上。但是，由于某种原因，在收到消息之后，由于某种原因消费者进程被停止，并且没有确认Rabbitmq，当消费者进程重新启动时，消费者开始从RabbitMq获得未被确认的消息，但是在这里，使用者不能向这些消息发送应答因此，我的<e
浏览 3提问于2018-11-22得票数 0
当消息被路由到队列时，我们的应用程序必须处理尽可能接近的消息，到目前为止，我们还没有遇到问题。然而，最近我们已经看到，当我们正在处理的一条消息需要很长时间才能完成时，当另一条消息被处理时，它会延迟，尽管有许多可用的用户(6)并不忙。注意，当应用程序只订阅单个队列时，这个问题不会发生，当涉及多个队列时，它就会成为一个问题。
我们有一个简单的消费应用程序，它订阅两个队列，一个用于命令，另一
浏览 1提问于2019-05-30得票数 1
回答已采纳
大量的Task.Delay会导致性能问题吗?或者当我想使用它来延迟将消息传递到rabbitmq时，是否有更好的方法来替换它呢？谢谢。
浏览 3提问于2020-02-10得票数 0
回答已采纳
我有一个问题，生产者消费狂犬病春季应用。我想从生产者向消费者发送一系列消息，但是消费者部分没有收到它们，生产者就会发送它们。当我试着只发送一条信息的时候，它起了作用。routingkey, company); } } @RabbitListener(queues="${js
浏览 2修改于2020-11-12得票数 1
回答已采纳
上下文：
当返回该basic.ack时，RabbitMQ是否保证将该消息发送到使用者的远程套接字？我知道它不能保证消息已经到达了消费者的本地套接字缓冲区，但是我感兴趣的是代理是否发送了它。每条消息的过期时间是否会以任何方式影响
浏览 1提问于2016-09-17得票数 1
回答已采纳
我有以下问题需要解决:我正在尝试使用RabbitMQ消息实现一个简单的延迟重试机制。我有一个基础设施，它为我提供了传递消息的延迟。我可以有许多感兴趣的参与者，他们希望在运行时利用这种延迟重试机制。参与者只想向我提供两个详细信息和消息: 1.他们希望在延迟T秒后将消息传递到的队列名称。2.队列的消费者(比如消息的消费者)。这是在运行时向队列的消息使
浏览 16提问于2017-12-18得票数 1
我有一个使用RabbitMQ的PHP项目(Symfony2)。我使用它的简单消息队列来延迟一些作业(发送邮件、来自API的重要数据)。消费者在web服务器上运行，他们的代码是web服务器存储库的一部分-它们与web部署在相同的位置。如果很重要的话，我会使用Capifony进行部署。
谢谢!
浏览 0提问于2011-12-20得票数 4
回答已采纳
我对使用RabbitMQ作为消息队列协议非常陌生，我已经编写了RabbitMQ教程中给出的发送者和消费者工作队列的代码。当我们在发送者之前启动消费者时，上面的事情运行得很好。但是，如果我们在运行发送器之后启动消费者，就会出现问题。这些消息都不会被那些在运行发送器之后启动的消费者使用。在研究了RabbitMQ的架构和AMQP相关的东西之后，它似乎相当困难。1]有没有可能在发送者之后启动
浏览 0提问于2013-08-29得票数 1
我对RabbitMQ非常陌生，所以这可能是我所缺少的东西。我的“问题”是，我的应用程序将使用发布/订阅和交换通过RabbitMQ发送“事件”。但是，这些事件可能有消费者，也可能没有消费者，但一旦有了消费者，我希望该消费者获得在连接之前发生的任何事件/消息。因此，基本上我希望交换“缓冲”所有消息，一旦有一个队列绑定到交换(由消费者创建和绑定的队列)，交换就应该将所有缓冲的消
浏览 16提问于2021-06-30得票数 0
回答已采纳
我希望在一个messageId队列中读取未确认消息的有效负载或RabbitMQ。这个是可能的吗？
一个消费者接收到消息，并对其进行处理。如果处理成功，使用者需要确认工作队列，然后将消息写回延迟队列；如果处理失败(例如，线程崩溃)，则
浏览 2修改于2014-11-11得票数 3
回答已采纳
我正在尝试为RabbitMQ提供两个数据中心之间的灾难恢复。在主DC出现故障之前，辅助数据中心处于被动状态。将队列镜像
浏览 3修改于2019-04-01得票数 4
我这样启动RabbitMQ服务器：docker run -d --hostname my-rabbit-host --name my-rabbit -p 5672:5672 rabbitmq:3使用此代码我们可以确保，即使您在处理消息时使用CTRL+C杀死一个工作人员，也不会有任何损失。工作进程死后不久，所有未确认的消息都将被重新传递。
我产生了两个消费者，当我对其中一个消费者执行CTRL+C操作时，另一个正
浏览 173修改于2017-10-10得票数 0
我已经创建了项目，其中只包含rabbitmq的路由设置。 <from uri="rabbitmq:localhost/test_out_ex?queue=test_out&autoDelete=false&username=admin&password=admin"/>
<to uri="rabbitmq:localhost因为"to“还没有消费<
浏览 4修改于2014-03-17得票数 0
我了解到，默认情况下，带有ack的RabbitMQ将在检测到使用者/工作人员已经死亡的情况下重新排队。
消费者/工人还活着的情况如何，但它的过程已经停顿了太长时间，而且没有被破坏？我想设置一个明确的时间，说明如果消息已经被发送给一个消费者，但是该使用者在没有ack的情况下保存消息的时间太长，消息就会重新排队。我认识到，这可能导致消息被一式两次处理，但有时结果并不像延迟消息传递那样
浏览 1提问于2016-04-21得票数 3
回答已采纳
我敢肯定我错过了MassTranist和/或RabbitMQ的细微差别，但是持久(永久的)能持续多久？消息是否留在队列中？我考虑的情况是，某一类型事件的所有消费者都不可用-显然，当他们重新启动时，您希望他们能够根据他们在离线时“错过”的事件采取适当的操作。然而，当一个新的消费者在几天/几个月/几年后开始从同一队列中读出时会发生什么情况呢？该消费者现在是否将从一开始就拉入所有事件？我几乎可以肯定情况并非如此，但是耐久性和及时性是如何平衡的呢？
浏览 1提问于2015-06-12得票数 0
我对RabbitMQ非常陌生。exchange_type => 'topic'auto_delete => 0使用此参数发布消息：消费者使用get()从交换中
浏览 0修改于2021-06-02得票数 72
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号