如何从单个队列中删除所有消息

Question

如何从单个队列中删除所有消息？我有队列名称,我想清理它.

Answer 1

你可以直接运行这个命令

sudo rabbitmqctl purge_queue queue_name

Answer 2

rabbitmqadmin是完美的工具

rabbitmqadmin purge queue name=name_of_the_queue_to_be_purged

Answer 3

RabbitMQ实现了高级消息队列协议(AMQP),因此您可以使用通用工具来实现这样的功能.

在Debian/Ubuntu或类似系统上,执行:

sudo apt-get install amqp-tools
amqp-delete-queue -q celery  # where celery is the name of the queue to delete

Answer 4

要清除队列,您可以使用以下命令(API doc中的更多信息):

curl -i -u guest:guest -XDELETE http://localhost:15672/api/queues/vhost_name/queue_name/contents

Answer 5

RabbitMQ有2个项目在排队

1. 删除
2. 清除

删除-将删除队列

清除-这将清空队列（意味着从队列中删除消息，但队列仍然存在）

Answer 6

重要说明:这将删除所有用户和配置.

警告!!

警告!!

除非你想删除所有队列中的数据,包括用户和配置,否则我不会建议这个答案.只是重置它!

rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl start_app

Answer 7

我猜它已经晚了但是对于其他人的参考,这可以用鼠兔来完成

import pika
host_ip = #host ip
channel = pika.BlockingConnection(pika.ConnectionParameters(host_ip,
                                                        5672,
                                                        "/",
credentials=pika.PlainCredentials("username","pwd"))).channel()
print "deleting queue..", channel.queue_delete(queue=queue_name)

Answer 8

为了仅从队列中删除消息，请使用：

sudo rabbitmqctl --node <nodename> purge_queue <queue_name>

为了删除空队列（--if-empty）或没有消费者（--if-unused）的队列，请使用：

sudo rabbitmqctl --node <nodename> delete_queue <queue_name> --if-empty

或者

sudo rabbitmqctl --node <nodename> delete_queue <queue_name> --if-unused 

Answer 9

如果您将 RabbitMQ 与 Docker 一起使用，您的步骤应该是：

1. 连接到容器： docker exec -it your_container_id bash
2. rabbitmqctl purge_queue Queue-1 （其中 Queue-1 是队列名称）