假设我有m条消息在队列中，我有n条消息需要发布。如何以随机顺序插入队列中的n条消息，而不是附加到队列末尾？换句话说，我如何使用rabbitMQ进行混洗？
浏览 0提问于2016-04-19得票数 3
我用皮卡为蟒蛇与RabbitMQ沟通。我有6个线程，它们使用和确认来自同一个队列的消息。对于每个线程，我使用不同的连接(和通道)。在重新连接之后，我将以相同的顺序接收相同的未确认消息，或者它将开始在所有线程之间重新分发它们，还是从重新连接点开始？这在我的应用程序中很重要，因为在消息接收和确认之间存在延迟，我希望在接下来的过程中避免重复。
浏览 3提问于2015-09-16得票数 3
回答已采纳
只要在本地机器上进行一些测试，就可以在某个地方检查由RabbitMQ (deliveryMode = 2)发布和保存的消息。或者至少有一段时间消息实际上是持久化的。第一次尝试是RabbitMQ管理，我发现所有选项和最接近的内容如下：
Database directory: /usr/local/var/lib/rabbitmq/mnesia/rabbit@localhost
浏览 6提问于2017-11-30得票数 0
回答已采纳
我使用RabbitMQ铲子插件(动态铲子，见下文)在两个RabbitMQ代理之间通过一个不可靠的广域网链接提供单向消息。我在RabbitMQ服务器日志中看到了正常的连接丢失。消费应用程序要求在发送端以相同的顺序接收消息。
浏览 7提问于2015-08-11得票数 1
回答已采纳
1回答
在每次插入数据库A1 (提交后)时，我们都会向RabbitMQ发布消息，以使应用程序B了解全新的实体。每个实体都有一个事件- X1和Y1。一切都很好，如果RabbitMQ保持消息的顺序，那么应用程序B的工作人员可以先处理X1，然后再处理Y1，以便在数据库B1中的新A和B记录之间建立正确的关联。但据我所知，RabbitMQ并不打算保持消息的顺序，而是在非常特殊的情况下执行，比如在一个通道内发布、发送到一个交换、推送到一个队列、在一个通道内使用。所以我的问
浏览 3提问于2017-09-12得票数 0
回答已采纳
1回答
我有一个用例，在这个用例中，我必须使用一种队列机制，以确保消息由消费者(“工作者”)按顺序逐一处理。
我过去使用过RabbitMQ，它保证了接收消息的顺序。但是如果这个顺序不正确呢？假设我提交消息4、5、3、2、1，RabbitMQ消费者将按此顺序处理消息。如果我希望以1、2、3、4、5的顺序处理它们，因为这些消息相互依赖，该怎么办？此外，我不想让消费者在确认消息
浏览 10提问于2017-10-27得票数 0
2回答
作为一个简单的例子，我正在向一个新的RabbitMQ(v2.6.1)队列中添加5个项目：connection = pika.BlockingConnection(pika.ConnectionParameters我希望消息#1 (再次)是队列中的第一条消息，并将Redelivered属性设置为True。相反，收到消息#2：<Basic.GetOk(['message_count=9
浏览 0提问于2012-05-14得票数 0
回答已采纳
我的想法是将新订单同步存储到某个数据库中，然后将消息发送到某种队列中。sns，sqs，redis，rabbitmq或其他什么适合这个吗？系统应该是可靠的，并且顺序很重要。
我假设轮询数据库中的消息，将是一种方法，但我不确定这是否有效？
浏览 31提问于2017-06-29得票数 0
4回答
这一次，我需要一个支持发布/订阅的可伸缩队列，并且必须保持消息排序。我读到亚历克西斯的评论:他写道：
“消息可以使用具有请求参数(basic.recover、basic.reject和basic.nack)的AMQP方法返回到队列，或者由于通道关闭，同时保存未确认的2.7.0版本和更高版本，如果队列有多个订阅者，单个使用者仍然可以观察消息的无序。这是由于其他可能
浏览 10提问于2014-01-26得票数 84
回答已采纳
2回答
我正在研究一个能够处理来自RabbitMQ的消息的工作人员。如果我收到一条消息，并且在处理错误时发生错误，我如何将消息放到队列的末尾？我试图使用nack或拒绝，但消息总是重新放在第一个位置，其他消息保持冻结！
我不明白为什么要把这条信息放在第一个位置，我试图“播放”其他选项，如requeue或AllupTo，但它们似乎都不起作用。
浏览 4提问于2016-12-29得票数 1
回答已采纳
我计划在java中使用RabbitMQ，并希望以Ack的顺序了解rabbitMQ行为。考虑3条消息x，y，z由3个不同的消费者按相同的顺序选择。Y和z首先得到完整的ack，此时是否可以将负ack发送到消息x？我从他们的文档中得到的信息是，这是不可能的--这是rabbitMQ不可能做到的事情吗？
对于多个消费者，我认为这是一个常见的场景。
浏览 3提问于2016-02-13得票数 2
回答已采纳
1回答
我有一个消息队列，对于从rabbitmq队列中弹出的给定消息，我想知道这是来自队列的第N条消息。如果在某个地方有一个计数器能够告诉我这个消息在给定队列中的位置号，那就太好了。这样，如果多个工作人员从队列中提取消息，他们将得到每条消息的位置。员工1抓取第29条信息，员工2抓取第31条信息，员工3抓取第30条信息等。
浏览 3提问于2014-11-25得票数 0
回答已采纳
我通过flink收听mysql的binlog，然后将它放到rabbitmq队列中，在flink中使用rabbitmq消息，将并行性设置为1以便连续地消耗消息，但是这会导致flink任务oom，有什么方法可以支持多并行性并按顺序消费吗
浏览 11提问于2022-08-25得票数 0
2回答
无法获得优先级序列的消息
、、、
我是一个使用spring camel rabbitmq的初学者。我可以通过在生产者端设置消息头来设置消息优先级，如下所示：但是，在使用信息的同时，它们并不是按优先级顺序排列的我可以在rabbitmq的web接口中看到适当设置的优先级头。
浏览 2提问于2017-06-16得票数 0
回答已采纳
这是，我的测试类，它是，创建了线程的2000，，而这些线程正在发送消息。这是我的主要消息发送类。}") String port = ""; String userName= ""; String passwor
浏览 2提问于2015-08-14得票数 0
回答已采纳
如果我需要确保另一条消息(具有相同的产品Id)不会同时被另一个消费者处理，我想知道处理来自队列的消息的最佳实践是什么。我的问题是，如果有人使用产品in下单和订购，而另一条消息带有相同的产品，我希望逐个处理它们，但不是并行处理。我正在考虑使用redis，我将保存正在处理的ids，并在处理结束后清除它们。
浏览 2提问于2018-09-27得票数 1
对于发送了confirm.select方法的发布者，RabbitMQ broker 的文字读数表明，客户端接收消息确认响应的顺序可能与发布原始消息的顺序不同。
有没有人能证实这是真的呢？或者消息总是按照接收到的相同顺序进行确认？如果可以以不同的顺序接收消息确认，则需要哪些条件才能出现这种情况？
浏览 3提问于2017-03-09得票数 2
1回答
在要求后保持交货顺序
、、、、
我正在开发一个使用兔子MQ进行消息传递的应用程序。我使用显式ACK：并在处理消息后执行ACK： throw; };
问题是，当处理消息时出现错误，而兔子没有接收到ACK时，它会以不同顺序的将消息</
浏览 2提问于2017-02-15得票数 3
我有两个Rabbitmq节点作为一个集群连接(没有队列复制)，并且有4个工作人员，它们都绑定到同一个队列"myqueue"，现在，我手动将消息发布到该队列(发布者可以连接到任意一个兔子节点)。现在，这种情况发生了:每次我向队列发布消息时，我都会发现以Robin的方式传递给工人/消费者的消息，无论消费者或发布者连接到哪个节点，我总是得到相同的结果。我被告知这是Rabbitmq的"prefetch_count“的效果，但我不明白这是怎么回事，甚至我也不知道这是否是正确的
浏览 0提问于2013-12-05得票数 2
回答已采纳
在我的MuleESB应用配置中，我有一个RabbitMQ队列，我希望使用多线程来使用消息，而顺序并不重要。我有以下配置：
<amqp:connector name="RabbitMQMultiThread" validateConnections="true" host="${rabbitmq_host}" port="${rabbitmq_port}" fallbackAddresses="${ra
浏览 4提问于2018-11-02得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
