通过 http 方式获取 RabbitMQ 队列消息数量(python3)

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了通过 http 方式获取 RabbitMQ 队列消息数量(python3)相关的知识,希望对你有一定的参考价值。

技术分享图片  

  在使用 pika 连接 RabbitMQ 的过程中,发现只能获取 ready 状态的消息数量,只要用 http 请求来实现目的。

#encoding: utf-8
#author: walker
#date: 2018-03-06
#summary: 获取 RabbitMQ 中3种状态消息的数量

import os, sys, time
import requests
import json

class RabbitMQTool(object):
	def __init__(self, host, vhost, queue, user, passwd):
		self.host = host
		self.vhost = vhost
		self.queue = queue
		self.user = user
		self.passwd = passwd

	# 返回3种消息数量:ready, unacked, total
	def getMessageCount(self):
		url = 'http://%s:15672/api/queues/%s/%s' % (self.host, self.vhost, self.queue)
		r = requests.get(url, auth=(self.user, self.passwd))
		print(r)
		if r.status_code != 200:
			return -1

		dic = json.loads(r.text)
		
		return dic['messages_ready'], dic['messages_unacknowledged'], dic['messages']

if __name__ == '__main__':    
	mqTool = RabbitMQTool(host = '192.168.0.xx',
							vhost = 'vhost_walker',
							queue = 'queue_walker',
							user = 'walker',
							passwd = 'walker')

	ready, unacked, total = mqTool.getMessageCount()
	
	print('ready: %d' % ready)
	print('unacked: %d' % unacked)    
	print('total: %d' % total)


*** walker ***


以上是关于通过 http 方式获取 RabbitMQ 队列消息数量(python3)的主要内容,如果未能解决你的问题,请参考以下文章

C#怎么从RabbitMQ中获取当前所有队列

rabbitMQ 学习

rabbitMQ学习

面试官:RabbitMQ过期时间设置死信队列延时队列怎么设计?

rabbitmq--路由模式

20rabbitmq介绍