0

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

  1. 我在 kubernetes 中有一个 RabbitMQ 设置。
  2. 我登录到 RabbitMQ pod 并为我的版本 3.8.14 获取 rabbitmqadmin
  3. 我运行这个：

./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 解决方案的选项。

4

1 回答 1

2

我知道了。我认为在某个时候 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()```
于 2021-04-23T14:41:10.553 回答