删除RabbitMQ中的队列

作者: 求赞有赞必回
发布时间: 2025-02-07 03:31:57 (16天前)
转自：

10 条回复

0#
回复此人
℘ 宋唐 ℒº ѵ ℯ楚厦 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 您断言存在队列（如果不存在则创建它），方法是使用的<strong> queue.declare </强> 。如果您最初将auto-delete设置为false，则使用autodelete true再次调用queue.declare将导致软错误，并且代理将关闭该通道。 </p> <P> 你需要使用的<strong> queue.delete </强> 现在为了删除它。 </p> <P> 有关详细信息，请参阅API文档： </p> <UL> <LI> <a href =“http://www.rabbitmq.com/releases/rabbitmq-java-client/v2.5.1/rabbitmq-java-client-javadoc-2.5.1/com/rabbitmq/client/Channel.html#queueDelete ％28java.lang.String％29" > Java客户端queueDelete </A> </LI> <LI> <a href =“http://www.rabbitmq.com/releases/rabbitmq-dotnet-client/v2.5.1/rabbitmq-dotnet-client-2.5.1-client-htmldoc/html/type-RabbitMQ.Client.IModel html的＃方法-M％3aRabbitMQ.Client.IModel.QueueDelete％28System.String％29" > .NET客户端queueDelete </A> </LI> </UL> <P> 如果您使用其他客户端，则需要找到等效方法。由于它是协议的一部分，它应该存在，它可能是Channel或等效的一部分。 </p> <P> 您可能还想查看其余文档，特别是 <a href="http://www.rabbitmq.com/getstarted.html"> 入门 </A> 涵盖了很多常见用例的部分。 </p> <P> 最后，如果您有问题但在其他地方找不到答案，您应该尝试发帖 <a href="https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss"> RabbitMQ讨论 </A> 邮件列表。开发人员尽力回答那里提出的所有问题。 </p> </DIV>

编辑
1#
回复此人
ikun | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 我已经将Piotr Stapp的JavaScript / jQuery方法进一步推广，将其封装到一个函数中并进行了一些推广。 </p> <P> 此函数使用RabbitMQ HTTP API查询给定的可用队列 <code> vhost </code> ，然后根据可选项删除它们 <code> queuePrefix </code> ： </p> <pre> <code> function deleteQueues(vhost, queuePrefix) { if (vhost === '/') vhost = '%2F'; // html encode forward slashes $.ajax({ url: '/api/queues/'+vhost, success: function(result) { $.each(result, function(i, queue) { if (queuePrefix && !queue.name.startsWith(queuePrefix)) return true; $.ajax({ url: '/api/queues/'+vhost+'/'+queue.name, type: 'DELETE', success: function(result) { console.log('deleted '+ queue.name)} }); }); } }); }; </code> </pre> <P> 在RabbitMQ管理页面上将此功能粘贴到浏览器的JavaScript控制台中后，您可以像这样使用它： </p> <P> 删除'/'vhost中的所有队列 </p> <pre> <code> deleteQueues('/'); </code> </pre> <P> 删除以'test'开头的'/'vhost中的所有队列 </p> <pre> <code> deleteQueues('/', 'test'); </code> </pre> <P> 删除'dev'vhost中以'foo'开头的所有队列 </p> <pre> <code> deleteQueues('dev', 'foo'); </code> </pre> <P> 的<strong> 请使用此风险，风险自负！ </强> </p> </DIV>

编辑
2#
回复此人
枫 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <pre> <code> import pika connection = pika.BlockingConnection(pika.ConnectionParameters( 'localhost')) channel = connection.channel() channel.queue_delete(queue='queue-name') connection.close() </code> </pre> <P> 安装pika包如下 </p> <pre> <code> $ sudo pip install pika==0.9.8 </code> </pre> <P> 安装依赖于pip和git-core软件包，您可能需要先安装它们。 </p> <P> 在Ubuntu上： </p> <pre> <code> $ sudo apt-get install python-pip git-core </code> </pre> <P> 关于Debian： </p> <pre> <code> $ sudo apt-get install python-setuptools git-core $ sudo easy_install pip </code> </pre> <P> 在Windows上：要安装easy_install，请运行用于setuptools的MS Windows Installer </p> <pre> <code> > easy_install pip > pip install pika==0.9.8 </code> </pre> </DIV>

编辑
3#
回复此人
浮华丶 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 我做了不同的方式，因为我只能访问管理网页。我创建了简单的“片段”，用于删除Javascript中的队列。这里是： </p> <pre> <code> function zeroPad(num, places) { var zero = places - num.toString().length + 1; return Array(+(zero > 0 && zero)).join("0") + num; } var queuePrefix = "PREFIX" for(var i=0; i<255; i++){ var queueid = zeroPad(i, 4); $.ajax({url: '/api/queues/vhost/'+queuePrefix+queueid, type: 'DELETE', success: function(result) {console.log('deleted '+queuePrefix+queueid)}}); } </code> </pre> <P> 我的所有队列都是格式：PREFIX_0001到PREFIX_0XXX </p> </DIV>

编辑
4#
回复此人
哦豁 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 在RabbitMQ版本中＆gt; 3.0，如果启用了rabbitmq_management插件，您还可以使用HTTP API。只需确保将content-type设置为'application / json'并提供vhost和队列名称： </p> <P> I.E.使用curl和vhost'test'以及队列名称'testqueue'： </p> <pre> <code> $ curl -i -u guest:guest -H "content-type:application/json" -XDELETE http://localhost:15672/api/queues/test/testqueue HTTP/1.1 204 No Content Server: MochiWeb/1.1 WebMachine/1.9.0 (someone had painted it blue) Date: Tue, 16 Apr 2013 10:37:48 GMT Content-Type: application/json Content-Length: 0 </code> </pre> </DIV>

编辑
5#
回复此人
坚挺的阿袁 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 安装 </p> <pre> <code> $ sudo rabbitmq-plugins enable rabbitmq_management </code> </pre> <P> 然后去 <a href="http://localhost:15672/#/queues" rel="nofollow noreferrer"> HTTP：//本地主机：15672 /＃/队列 </A> 如果您使用的是localhost。默认密码是 <code> username: guest </code> ， <code> password: guest </code> 并转到队列选项卡并删除队列。 </p> </DIV>

编辑
6#
回复此人
一生流水 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 如果您不关心其他队列，可以通过命令行按顺序运行以下命令来删除所有队列： </p> <P> 的<strong> 警告： </强> 这也将的<strong> 删除 </强> 任何的<strong> 用户 </强> 和的<strong> 虚拟主机 </强> 你已经在兔子服务器上配置了 </p> <pre> <code> rabbitmqctl stop_app rabbitmqctl reset rabbitmqctl start_app </code> </pre> <P> rabbitmq文档说明了 <code> reset </code> 命令： </p> <BLOCKQUOTE> <P> 从其所属的任何群集中删除该节点，从中删除所有数据管理数据库，例如配置的用户和虚拟主机，以及删除所有持久性消息。 </p> </BLOCKQUOTE> <P> 所以，小心使用它。 </p> </DIV>

编辑
7#
回复此人
苞米地里的蒙面妖 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 另一种选择是启用management_plugin并通过浏览器连接到它。您可以查看所有队列和有关它们的信息。从此界面删除队列是可能的，也很简单。 </p> </DIV>

编辑
8#
回复此人
雨儿 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 管理插件（Web界面）为您提供了python脚本的链接。您可以使用它来删除队列。我使用这种模式删除了很多队列： </p> <pre> <code> python tmp/rabbitmqadmin --vhost=... --username=... --password=... list queues > tmp/q vi tmp/q # remove all queues which you want to keep cut -d' ' -f4 tmp/q| while read q; do python tmp/rabbitmqadmin --vhost=... --username=... --password=... delete queue name=$q; done </code> </pre> </DIV>

编辑

登录后才能参与评论