RabbitMQ 从命令行创建队列和绑定

Question

如果我的机器上安装了 RabbitMQ，有没有办法从命令行创建消息队列并将其绑定到某个交换而不使用客户端？

我认为这是不可能的，但我想确定一下。

Answer 1

摘要：

其他答案是所要求答案的很好替代方案。以下是您可以从命令行使用的命令。

首先，做好所有必要的准备工作，例如安装rabbit、rabbitmqadmin 和rabbitctl。这个想法是使用来自rabbitmqctl和rabbitmqadmin的命令。您可以看到一些命令示例： https://www.rabbitmq.com/management-cli.html< /a>

示例命令/设置：

以下命令应该为您提供大部分（如果不是全部）所需的内容：

# Get the cli and make it available to use.
wget http://127.0.0.1:15672/cli/rabbitmqadmin
chmod +x rabbitmqadmin
mv rabbitmqadmin /etc/rabbitmq

添加用户和权限

rabbitmqctl add_user testuser testpassword
rabbitmqctl set_user_tags testuser administrator
rabbitmqctl set_permissions -p / testuser ".*" ".*" ".*"

创建虚拟主机并设置权限

rabbitmqctl add_vhost Some_Virtual_Host
rabbitmqctl set_permissions -p Some_Virtual_Host guest ".*" ".*" ".*"

进行交换

./rabbitmqadmin declare exchange --vhost=Some_Virtual_Host name=some_exchange type=direct

创建队列

./rabbitmqadmin declare queue --vhost=Some_Virtual_Host name=some_outgoing_queue durable=true

进行绑定

./rabbitmqadmin --vhost="Some_Virtual_Host" declare binding source="some_exchange" destination_type="queue" destination="some_incoming_queue" routing_key="some_routing_key"

使用 Python 进行绑定的替代方法

以下是命令行绑定的替代方案，因为我有时会遇到问题，并发现以下 python 代码更可靠。

#!/usr/bin/env python
import pika

rabbitmq_host = "127.0.0.1"
rabbitmq_port = 5672
rabbitmq_virtual_host = "Some_Virtual_Host"
rabbitmq_send_exchange = "some_exchange" 
rabbitmq_rcv_exchange = "some_exchange"
rabbitmq_rcv_queue = "some_incoming_queue"
rabbitmq_rcv_key = "some_routing_key"

outgoingRoutingKeys = ["outgoing_routing_key"]
outgoingQueues = ["some_outgoing_queue "]

# The binding area
credentials = pika.PlainCredentials(rabbitmq_user, rabbitmq_password)
connection = pika.BlockingConnection(pika.ConnectionParameters(rabbitmq_host, rabbitmq_port, rabbitmq_virtual_host, credentials))
channel = connection.channel()
channel.queue_bind(exchange=rabbitmq_rcv_exchange, queue=rabbitmq_rcv_queue, routing_key=rabbitmq_rcv_key)

for index in range(len(outgoingRoutingKeys)):
    channel.queue_bind(exchange=rabbitmq_send_exchange, queue=outgoingQueues[index], routing_key=outgoingRoutingKeys[index])

上面的代码可以作为使用 python 的脚本的一部分运行。请注意，我将传出的内容放入数组中，这将允许您迭代它们。这应该会使部署变得容易。

最后的想法

我认为上述内容应该让您朝着正确的方向前进，如果任何特定命令没有意义，请使用谷歌或使用rabbitmqadmin help subcommands阅读更多内容。我尝试使用能够解释自身的变量。

Answer 2

安装RabbitMQ 管理插件。它附带了一个命令行工具，您可以使用它来配置所有队列/交换器等。

Answer 3

创建Exchange：

rabbitmqadmin -u {user} -p {password} -V {vhost} declare exchange name={name} type={type}

创建队列：

rabbitmqadmin -u {user} -p {password} -V {vhost} declare queue name={name}

将队列绑定到Exchange：

rabbitmqadmin -u {user} -p {password} -V {vhost} declare binding source={Exchange} destination={queue}

Answer 4

也许有点晚了，但我已经使用 CURL 做到了。

对于队列：

curl -i -u RABBITUSER:RABBITPASSWORD -H "content-type:application/json" \
-XPUT -d'{"durable":true}' \
http://192.168.99.100:15672/api/queues/%2f/QUEUENAME

对于绑定

curl -i -u RABBITUSER:RABBITPASSWORD -H "content-type:application/json" \
-XPOST -d"{\"routing_key\":\"QUEUENAME\"}" \
http://192.168.99.100:15672/api/bindings/%2f/e/EXCHANGENAME/q/QUEUENAME

注意 192.168.99.100:15672 指向我的 RMQ 管理

Answer 5

如果您使用的是 Linux Debian，则有一个名为 amqp-tools 的软件包。安装它

apt-get install amqp-tools

然后您可以使用命令行（例如 amqp-publish）将消息发送到您的队列

amqp-publish -e exchange_name -b "your message"

从队列中收集消息

amqp-get -q queue_name

然后您可以使用或

amqp-consume -q queue_name

还有来自 rabbitmq-c 包/库。构建后，您可以通过命令行发送消息，例如

amqp_sendstring localhost 5672 amq.direct test "hello world"

Have fun ...

Answer 6

提供的命令行界面rabbitmqctl 不公开创建队列并绑定它的功能。

然而，使用快速脚本来完成此操作非常简单，RabbitMQ 入门指南在发布者和消费者方面都显示了几个示例。

#do some work to connect
#do some work to open a channel
channel.queue_declare(queue='helloworld')

我掩盖了连接，但它实际上是创建队列的一个衬垫。该操作也是幂等的，这意味着您可以将该语句包含在脚本中并且安全，因为知道它不会不断重新创建队列或清除现有的同名队列。

Answer 7

从 Windows 上的 CLI 动态创建 RabbitMq 交换、队列和绑定

我已经安装了 RabbitMQ 服务器并运行多个队列和交换，现在想从命令行动态创建它。我知道这是一个老问题，但我认为提供这些信息会有所帮助。

以下是我所做的：

安装

1. 下载并安装了Python 2.6.6-201008-24 Windows x86-64 MSI安装程序，任何版本的python，
2. 下载RabbitMqAdmin：RabbitMq Web用户界面有一个链接命令行，可以导航到http://server -name:15672/cli/ (server-name: 安装rabbitmq的服务器)或者，使用上面的url并在python中将文件保存为rabbitmqadmin.exe exe位置

例如：C:\Python26
C:\Python26\python
C:\Python26\rabbitmqadmin.exe

代码：在批处理文件中使用以下命令

1. 创建交换：

c:\python26\python.exe rabbitmqadmin.exe declare exchange name=*ExchangeName1* type=topic durable=true

2. 创建队列：

c:\python26\python.exe rabbitmqadmin.exe declare queue name=*NameofQueue1* durable=true

3. 创建绑定：

c:\python26\python.exe rabbitmqadmin.exe declare binding source=ExchangeName1 destination_type=queue destination=*NameofQueue1* routing_key=*RoutingKey1*

通过执行rabbitmqadmin.exe -help -subcommands 它列出了所有可用的命令，

例如：c:\python26\python .exerabbitmqadmin.exe-help-子命令

Answer 8

对我来说，我的 RabbitMQ 管理交易一直试图重定向到 https 版本...我的设置中的所有内容都是普通的，我什至没有配置文件...无论如何，我的解决方法是手动创建rabbitmqadmin .py 在 sbin 文件夹中，然后填充 https://raw.githubusercontent.com/rabbitmq/rabbitmq-management/v3.8.1/bin/rabbitmqadmin

然后，确保 python 位于例如，您的 PATH 并运行它来添加交换：

python rabbitmqadmin.py declare exchange --vhost=/ name=CompletedMessageExchange type=direct

Answer 9

这是一个更简单的 Python 示例，取自 RabbitMQ Python 教程 。

首先，安装 pika：

sudo easy_install pika
# (or use pip)

这就是向本地主机发送消息所需的全部内容：

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()

channel.queue_declare(queue='test-queue')
channel.basic_publish(exchange='', routing_key='test-queue', body='Hello World!')

Answer 10

如果任何 Windows 用户正在寻找基于 powershell 的解决方案，那么这里有我编写的函数。

Function createQueue([string]$QueueName){
$headers = New-Object "System.Collections.Generic.Dictionary[[String],[String]]"
$headers.Add("content-type", "application/json")
$headers.Add("Authorization", "Basic Z3Vlc3Q6Z3Vlc3Q=")

$body = "{
`n  `"vhost`": `"/`",
`n  `"name`": `"$QueueName`",
`n  `"durable`": `"true`",
`n  `"arguments`": {}
`n}"

# Write-Host $body

$url='http://localhost:15672/api/queues/%2f/'+$QueueName

# Write-Host  $url

$response = Invoke-RestMethod $url -Method 'PUT' -Headers $headers -Body $body
$response | ConvertTo-Json
}

将其保存到 helper.ps1 文件中并将其包含到您的脚本中，如下所示

$queueNames = 'my-queue-name'

. .\helper.ps1

createQueue($queueName)

Answer 11

在 RabbitMQ 中创建和删除队列的演练：

我找不到执行此操作的命令行命令。这是我用 java 代码实现的方法。

Ubuntu 上的 Rabbitmq-server 版本 3.3.5。

列出队列，还没有队列：

sudo rabbitmqctl list_queues
[sudo] password for eric:
Listing queues ...
...done.

将其放入 CreateQueue.java

import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;
import java.util.*;
public class CreateQueue {
  public static void main(String[] argv) throws Exception {
    ConnectionFactory factory = new ConnectionFactory();
    factory.setHost("localhost");
    Connection connection = factory.newConnection();
    Channel channel = connection.createChannel();
    Map<String, Object> args = new HashMap<String, Object>();
    args.put("x-message-ttl", 60000);
    channel.queueDeclare("kowalski", false, false, false, args);
    channel.close();
    connection.close();
  }
}

提供您的rabbitmq安装附带的jar文件：

我正在使用rabbitmq-client.jar版本0.9.1，使用您的rabbitmq版本附带的版本。

编译并运行：

javac -cp .:rabbitmq-client.jar CreateQueue.java
java -cp .:rabbitmq-client.jar CreateQueue

它应该顺利完成，现在检查您的队列：

sudo rabbitmqctl list_queues
Listing queues ...
kowalski        0
...done.

kowalski 队列存在。

Answer 12

有助于在您进行交换时绑定交换：

channel.queue_bind(queueName, exchange)

C-；