程序问答   发布时间:2022-06-02  发布网站:大佬教程  code.js-code.com
大佬教程收集整理的这篇文章主要介绍了获取RabbitMQ队列中的消息数大佬教程大佬觉得挺不错的,现在分享给大家,也给大家做个参考。

如何解决获取RabbitMQ队列中的消息数?

开发过程中遇到获取RabbitMQ队列中的消息数的问题如何解决?下面主要结合日常开发的经验,给出你关于获取RabbitMQ队列中的消息数的解决方法建议,希望对你解决获取RabbitMQ队列中的消息数有所启发或帮助;

import pika

pika_conn_params = pika.ConnectionParameters(
    host='localhost', port=5672,
    credentials=pika.credentials.PlainCredentials('guest', 'guest'),
)
connection = pika.blockingConnection(pika_conn_params)
chAnnel = connection.chAnnel()
queue = chAnnel.queue_declare(
    queue="your_queue", durable=True,
    exclusive=false, auto_delete=false
)

print(queue.method.message_count)

from pyrabbit.API import ClIEnt
cl = ClIEnt('localhost:55672', 'guest', 'guest')
cl.get_messages('example_vhost', 'example_queue')[0]['message_count']

句法:

curl -i -u user:password http://localhost:15672/API/queues/vhost/queue

例:

curl -i -u guest:guest http://localhost:15672/API/queues/%2f/celery

注意:默认虚拟主机是/需要转义为%2f

$ sudo rabbitmqctl List_queues | grep 'my_queue'

解决方法

我们正在使用amqplib来发布/使用消息。我希望能够读取队列中的消息数(理想情况下是已确认和未确认)。这将使我能够向管理员用户显示良好的状态图,并检测某个组件是否无法满足负载需求。

我在amqplib文档中找不到有关读取队列状态的任何信息。

有人可以指出我正确的方向吗?

大佬总结

以上是大佬教程为你收集整理的获取RabbitMQ队列中的消息数全部内容,希望文章能够帮你解决获取RabbitMQ队列中的消息数所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错,欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。