使用 rabbitmqadmin 创建 RabbitMQ 队列时返回“未找到”

问题描述

我需要从命令行创建一个 RabbitMQ 队列。

我在 kubernetes 中设置了 RabbitMQ。
我登录到 RabbitMQ pod 并获取了我的版本 3.8.14 的 rabbitmqadmin
我运行这个：

./rabbitmqadmin -u user1 -p password1 -N rabbit@rabbitmq-0.rabbitmq.default.svc.cluster.local declare queue name=CompName.Player1

但我没有添加队列：

**未找到：/api/queues/%2F/CompName.Player1

我尝试了这些但没有成功，运行这些rabbitmqadmin命令时rabbitmq日志也没有显示任何事件：

./rabbitmqadmin declare queue name=Test1

./rabbitmqadmin -u user1 -p password1 declare queue name=CompName.Player1

curl -i -u user1:password1 -H "content-type:application/json" -XPUT -d'{"durable":true}' http://localhost:15672/api/queues/%2f/CompName.Player1

通过管理 Web UI 手动添加队列有效，但它不是 kubernetes 解决方案的选项。

解决方法

我明白了。我认为 API 端点在某个时候会更新，因此所有调用都必须转到 http://localhost:15672/rabbitmq/api。这是添加的导致问题的配置行：

management.path_prefix = /rabbitmq

以下是工作示例：

./rabbitmqadmin -u user1 -p password1 --path-prefix=http://localhost:15672/rabbitmq declare queue name=CompName.Player1

curl -i -u user1:password1 -H "content-type:application/json" -XPUT -d'{"durable":true}' http://localhost:15672/rabbitmq/api/queues/%2f/CompName.Player1

这也有效：

import pika
import sys
connection = pika.BlockingConnection(
    pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='CompName.Player1',durable=True)
connection.close()```

kubernetes rabbitmqadmin