如何逐条读取RabbitMQ队列消息

文章/答案/技术大牛

发布

1回答

python、rabbitmq

我有一个需求，我需要阅读DLQ的消息，并基于此执行适当的操作。早些时候，在RabbitMQ/Erlang更新之前，下面的代码片段工作正常。现在它给出Bad Request错误。是不是因为最新版本的RabbitMQ不再接受这种REST调用？为了执行所需的操作，在Python中逐个读取所有消息的替代方案是什么？提前谢谢你，

浏览 27提问于2019-05-08得票数 0

回答已采纳

1回答

有人能解释一下RabbitMQ频道的确切行为吗？如果执行channel.basicAck会关闭通道呢？

java、spring-boot、rabbitmq

我正在尝试使用channel.basicConsume()方法在RabbitMQ队列上执行队列读取操作。队列包含多条消息，当我试图逐条确认每条消息时，在确认队列中的每条消息后，通道将被channel.basicAck()方法关闭。这是通道的预期行为吗？为了从队列中读取多个消息，我使用以下代码。

浏览 0提问于2016-10-23得票数 0

2回答

RabbitMQ队列消耗行为

java、spring-boot、rabbitmq、apache-camel

我们使用Apache (2.24)从RabbitMQ服务器使用Spring (2.1)应用程序(3.7.15)。应用程序似乎正在正确地消费(消息逐条消息，因为它们被放置在队列中)，但是在RabbitMQ监视器中，这些消息似乎是“批量地”被消耗的(请参见急剧下降，然后是平行线，尽管我们在日志中看到了应用程序正在处理的消息为什么队列数量不平稳地下降？

浏览 2提问于2019-08-23得票数 3

回答已采纳

2回答

在java中高效地向数据库中插入数据

java、database、multithreading

我正在构建一个应用程序，它有一个仅用于日志记录目的的数据库。我们记录传入的事务id及其开始和结束时间。这个数据库中的应用程序本身没有任何用处。因此，我希望在不影响应用程序本身的情况下尽可能高效地执行此插入查询。我的想法是在一个单独的线程中执行整个数据库插入代码。因此，通过这种方式，数据库插入将在不影响实际工作的情况下运行。我想知道是否有任何与这种情况相关的设计模式。或者我的思维模式对此是否正确。

浏览 0提问于2019-12-17得票数 1

2回答

Camel rabbitmq中重新启动时的camel路由丢失消息

rabbitmq、apache-camel、rabbitmq-exchange

我正在使用camel-rabbitmq。RouteBuilder() { public void configure() throws Exception { } } }); 当我将500条消息推送到此队列时，当停止和启动路由时，通道

浏览 63提问于2020-04-05得票数 0

回答已采纳

1回答

RabbitMQ实际上是如何物理存储消息的？

rabbitmq

我想知道RabbitMQ是如何在内存和磁盘中物理存储消息的？我想知道这些的内部结构。不幸的是，其主页上的官方文档并没有公开内部细节。

浏览 1提问于2016-07-19得票数 34

回答已采纳

1回答

是否支持从兔子队列中读取运行时未知的队列？

java、rabbitmq、spring-cloud-stream

我正在编写一个Java应用程序，它使用从输入RabbitMQ队列读取消息，处理消息，然后将新消息写入输出RabbitMQ交换。当在编译时知道输入队列名时，这是非常有效的。现在，我有了一个新的要求，即应用程序需要支持在运行时发现新的RabbitMQ队列，然后使用这些新队列进行输入(从新队列读取消息)。通过RabbitMQ中的RES

浏览 3提问于2021-02-04得票数 0

回答已采纳

2回答

如何查看RabbitMQ消息

rabbitmq、rmq

使用get messages命令后无法查看rabbitmq队列消息。rabbitmqadmin get queue='queue_name' -H localhost -P 15672 -u rmq -p rmq --vhost=/ count=100 队列计数显示100条消息，不能再次使用上面的命令查看消息。

浏览 15提问于2022-06-06得票数 0

1回答

我正在编写Python脚本cron-job，它定期从RabbitMQ获取更新并处理它们。每次我处理它们时，我只需要获取RMQ队列的最新快照。我使用queue_declare来获取其中的消息数量。我知道如何使用basic_get逐条获取消息。此外，我还可以使用basic_consume/start_consuming在后台获取消息，将它们存储在某个列表中，并定期从该列表中获取消息，但如果脚本因某些错误而失败怎么办？而且，我可以使用很少的使用者(

浏览 14提问于2017-12-21得票数 0

回答已采纳

1回答

RabbitMQ用户授权读取队列但防止清除访问

rabbitmq、rabbitmqctl

我在RabbitMQ中添加了一个用户，并编辑了在RabbitMQ管理控制台中读取".*“的权限。但是，当以"readman“登录时，我仍然可以从队列中清除消息。这是意料之中吗？如何使用户能够查看队列和消息，但不能清除队列的消息？

浏览 5提问于2019-11-13得票数 1

回答已采纳

1回答

具有每个使用者的多个实例的pubsub

pubsub

我目前正在考虑为我们的基于微服务的平台建立一个发布、订阅、消息传递的底层结构。新的设置是为了取代我们目前基于卡夫卡的一个，用一些更容易维护的东西。我们最初选择卡夫卡的原因之一是拥有消费者群体的能力。我们有每个消费服务的多个实例正在运行，通过将相同服务的所有实例放入同一个使用者组，我们确保它们分布在分区之间，因此，只有一个实例会接收消息(据我理解)。因此，基本上，如果我们有服务a，实例a1和a2，服务b与b1和b2，都在收听相同的主题，是否有办法，使用类似于rabbitmq或redis之类的东西，来拒绝只有一个服务实例a和一个服务实例接收<e

浏览 0提问于2017-07-25得票数 5

回答已采纳

1回答

使用Spring从RabbitMq读取消息

rabbitmq、spring-amqp、apache-storm、spring-rabbit

我想使用来自rabbitMq队列的Storm中的消息。问题是，我可以让一个侦听器从队列中读取消息。但是，我如何将这条信息发送给我的Storm Spout，它正在运行在风暴集群上？拓扑将启动一个集群，但是在我的next

浏览 2提问于2015-09-29得票数 2

回答已采纳

3回答

使用Celery (RabbitMQ，Django)检索队列长度

django、queue、rabbitmq、celery、django-celery

我在django项目中使用芹菜，我的代理是RabbitMQ，我想检索队列的长度。我看了一下芹菜的代码，但没有找到这样做的工具。

浏览 1提问于2013-07-26得票数 10

1回答

何时应该使用单个队列，何时使用多个队列？

rabbitmq、activemq、stomp

我想知道，在RabbitMQ中何时创建单个队列以及何时创建多个队列是否有规则？还是由生产者来决定是否将消息发送到单个队列或多个队列，技术上没有区别？它应该依赖于db的模式吗?也就是说，一个表应该对应于单个队列吗？

浏览 2提问于2016-02-01得票数 1

回答已采纳

3回答

RabbitMQ中的基本消耗调度

c#、rabbitmq

我从上个月开始使用RabbitMQ，successfully.Messages是从队列中读取的，使用BasicConsume特性发布的RabbitMQ.The消息立即被相应的使用者使用。现在我创建了一个新的队列DelayedMsg，发布到这个队列的消息只能在5分钟delay.What之后读取，我应该这样做吗？

浏览 4提问于2016-10-14得票数 3

回答已采纳

3回答

RabbitMQ订阅者通知在.NET中

rabbitmq

我们现在使用的是带有WCF激活功能的MSMQ，它使我们能够不拉队列来读取消息。它喜欢将消息推送到应用程序。 RabbitMQ中有什么.net可以推送通知给订阅者的东西，比如MSMQ? 或者我们需要不断检查消息的服务运

浏览 3提问于2010-10-14得票数 8

2回答

如何在java中用MDB和activemq制作串行进程

ejb、jboss-mdb

我正在使用activemq在ejb mdb上工作，你能帮我吗，iam从队列中读取消息并将数据保存到数据库中，我可以将数据保存到数据库中，但它mdb从队列中提取消息，一个消息部分保存到数据库中，然后另一个消息被处理我想把这些信息逐条存入数据库，有谁能帮我吗

浏览 5提问于2017-09-07得票数 0

1回答

确定RabbitMQ中最新邮件的优先级

rabbitmq

我正在开发一个应用程序，在该应用程序中，实时传感器读数通过RabbitMQ队列传递给上传器，后者将读数推送到中央服务器。在这个特殊的应用程序中，最新的读数是最有价值的。这意味着我更希望上传器首先处理最近的读取，通过积累的任何积压时间向后移动。我想出的一个解决方案是创建一个“实时”队列和一个“积压”队列。实时<em

浏览 0提问于2015-05-07得票数 0

1回答