RabbitMQ调用API删除队列_rabbitmq 删除队列 java

项目中需要实现清空RabbitMQ里面的队列，就写了这篇文章
首先，管理端是能实现删除某个队列的功能的，所以我们通过F12看一下管理端调用的是什么接口，这里也可以使用fiddler来代理，监控待用的api，两种方式都是可以的

我们点击删除以后，可以捕捉到调用的api是http://192.168.1.123:15672/api/queues/%2F/worker_wh，而且用的Method请求方式是Delete

随后我们进到管理端api页面，在里面我们可以找到这个接口以及它的具体描述，描述主要包含下面信息

• 前面的X代表的是可以执行什么方式调用api，我们需要的这个api就可以delete，put，get
• 后面描述我们主要看delete的信息， 如果在api的参数中添加了if-empty=true 或者 if-unused=true，当队列里面如果有消息没有消费掉或者有人正在使用，则会阻碍我们删除这个队列，不过我们不加就没关系
• 还有就是我们url中的/%2F这边也给出了解释，许多 URI 需要虚拟主机的名称作为路径的一部分，因为名称仅唯一标识虚拟主机中的对象。由于默认虚拟主机称为“/”，因此需要将其编码为/%2F
  
  接下里我们开始用postman调用api，这里会发现返回401，这里意思是没有认证信息
  
  我们需要在Authorization里面选择Basic Auth，然后填入我们管理端的用户名和密码，调用如下，成功删除了队列
  
  点击右边的代码按钮，选择c#我们可以看到c#的代码如下
  
  把下面代码赋值粘贴到我们的程序里面，这里我们做了一些删减和增加

            string UserNameAndPassword = "admin:123456";
            var client = new RestClient("http://192.168.1.123:15672/api/queues/%2F/worker_wh");
            var request = new RestRequest("", Method.Delete);
            request.AddHeader("Authorization", "Basic "+ Convert.ToBase64String(Encoding.UTF8.GetBytes(UserNameAndPassword)));
            var body = @"";
            request.AddParameter("text/plain", body, ParameterType.RequestBody);
            RestResponse response = client.Execute(request);
            Console.WriteLine(response.Content);
1
2
3
4
5
6
7
8

主要将两个点

• 第一个需要引用RestSharp的Package，最新的类库里面可能构造函数或者属性有变化，自己判断修改
• 第二个如何获取Authorization，它其实是两个部分组成，一个是“Basic ”（此处有空格），一个是Base64编码的用户名和密码，字符串UserNameAndPassword里面的形式是“用户名:密码”，读者按照自己管理端的用户名密码来改变即可