我通过flink收听mysql的binlog，然后将它放到rabbitmq队列中，在flink中使用rabbitmq消息，将并行性设置为1以便连续地消耗消息，但是这会导致flink任务oom，有什么方法可以支持多并行性并按顺序消费吗
浏览 11提问于2022-08-25得票数 0
1回答
在要求后保持交货顺序
、、、、
我正在开发一个使用兔子MQ进行消息传递的应用程序。我使用显式ACK：并在处理消息后执行ACK： throw; };
问题是，当处理消息时出现错误，而兔子没有接收到ACK时，它会以不同顺序的将消息</
浏览 2提问于2017-02-15得票数 3
假设我有m条消息在队列中，我有n条消息需要发布。如何以随机顺序插入队列中的n条消息，而不是附加到队列末尾？换句话说，我如何使用rabbitMQ进行混洗？
浏览 0提问于2016-04-19得票数 3
我正在为.NET RabbitMQ库编写一个包装器，在我所能看到的文档中有一个问题没有得到回答，而且我也想不出一种实验验证它的方法。声明如下：
在大多数情况下，RabbitMQ将以相同的发布顺序向发布者确认消息(这适用于在单个通道上发布的消息)。但是，发布服务器确认是异步发出的，可以确认单个消息或一组消息。发出确认消息的确切时刻取决于消息的传递模式(持久性还是暂时性的)，以及消息
浏览 0提问于2019-01-16得票数 1
回答已采纳
我用皮卡为蟒蛇与RabbitMQ沟通。我有6个线程，它们使用和确认来自同一个队列的消息。对于每个线程，我使用不同的连接(和通道)。在重新连接之后，我将以相同的顺序接收相同的未确认消息，或者它将开始在所有线程之间重新分发它们，还是从重新连接点开始？这在我的应用程序中很重要，因为在消息接收和确认之间存在延迟，我希望在接下来的过程中避免重复。
浏览 3提问于2015-09-16得票数 3
回答已采纳
我正在尝试获取具有特定关联id的消息，就像rabbitmq文档中所解释的那样。但是，我发现不相关的消息被出队了。我不希望它发生。在收到消息并知道这不是我要找的消息后，我如何告诉rabbitmq不要出队。请帮帮我。
浏览 2提问于2016-02-11得票数 4
只要在本地机器上进行一些测试，就可以在某个地方检查由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回答
我期待从RabbitMQ队列中检索一条特定的消息。有人能指点我一下吗。但上面是fr。我想使用C# .net从队列中检索一条特定的消息。
编辑：附票解决不了我的问题。
浏览 6提问于2016-02-20得票数 0
回答已采纳
我目前正在为一个跟踪系统实现rabbitMQ，该系统有多个前端生产者在同一队列上写入。基本上，我在队列中发送了两种类型的消息，因为跟踪工作流有两个步骤: impression/click => lead/sale。这很简单:用户点击一个横幅，然后在他被重定向到的网站上执行一个操作。问题是我需要按时间顺序使用消息。虽然如果所有生产者都以相同的速度发送队列中的消息(即消息应该以FIFO的方式正确排序)，那么当其中一个生产者在队列中写入(由于某种原因)较慢时，我会遇到
浏览 0提问于2013-03-19得票数 3
回答已采纳
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
我们在我们的应用程序中使用websockets和组合RabbitMQ，我需要解决以下用例：
用户登录JS应用，应用开始订阅websocket topic以获取新消息。用户尚未订阅这些消息，因此消息仅存储在数据库中。在某些时刻(时间T)，用户登录应用程序并开始订阅，并且经由websockets接收消息m4、m5、m6。用户需要知道从何时开始，或上次存储但未接收到的消息的ID，在本例中为m3。或者只是简单地在开始订阅时发送初始批消息。你知道在春天解决这个问题的好方法是什么吗
浏览 0提问于2020-07-27得票数 0
2回答
我有一个应用程序，可以同时从多个用户接收三种类型的消息，并且我使用3个队列/消费者和3个交换来处理它。我的问题是，当队列中有来自一个用户的数千条消息时，其他用户正在等待。
浏览 0提问于2018-10-26得票数 6
4回答
这一次，我需要一个支持发布/订阅的可伸缩队列，并且必须保持消息排序。我读到亚历克西斯的评论:他写道：
“消息可以使用具有请求参数(basic.recover、basic.reject和basic.nack)的AMQP方法返回到队列，或者由于通道关闭，同时保存未确认的2.7.0版本和更高版本，如果队列有多个订阅者，单个使用者仍然可以观察消息的无序。这是由于其他可能
浏览 10提问于2014-01-26得票数 84
回答已采纳
1回答
我正在用rabbitmq开发Laravel 5.1.46 (LTS)，用于使用的消息队列QUEUE_DRIVER=rabbitmq'rabbitmq' => [
'host' => env('RABBITMQ_HOST', '
浏览 3提问于2019-08-16得票数 0
2回答
我正在研究一个能够处理来自RabbitMQ的消息的工作人员。如果我收到一条消息，并且在处理错误时发生错误，我如何将消息放到队列的末尾？我试图使用nack或拒绝，但消息总是重新放在第一个位置，其他消息保持冻结！
我不明白为什么要把这条信息放在第一个位置，我试图“播放”其他选项，如requeue或AllupTo，但它们似乎都不起作用。
浏览 4提问于2016-12-29得票数 1
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号