linux安装RabbitMQ详细教程

下面是关于“Linux安装RabbitMQ详细教程”的完整攻略：

1.安装Erlang

RabbitMQ是使用Erlang编写的，因此需要首先安装Erlang。

在Ubuntu系统中，可以使用以下命令安装Erlang：

sudo apt-get update
sudo apt-get install erlang

如果你使用其他的Linux发行版，可以参考官方文档进行安装：https://www.erlang.org/downloads

2.安装RabbitMQ

有多种方式可以安装RabbitMQ，这里介绍通过包管理器进行安装。在Ubuntu系统中，可以使用以下命令安装RabbitMQ：

sudo apt-get update
sudo apt-get install rabbitmq-server

安装完成后，可以使用以下命令启动RabbitMQ服务：

sudo systemctl start rabbitmq-server

如果需要在系统启动时自动启动RabbitMQ服务，可以使用以下命令：

sudo systemctl enable rabbitmq-server

3.设置管理员用户

默认情况下，RabbitMQ服务器只允许本地主机访问，因此需要设置管理员用户以便从远程主机访问。

首先需要启用RabbitMQ的管理插件，使用以下命令：

sudo rabbitmq-plugins enable rabbitmq_management

然后创建管理员账户，例如：

sudo rabbitmqctl add_user admin password
sudo rabbitmqctl set_user_tags admin administrator
sudo rabbitmqctl set_permissions -p / admin ".*" ".*" ".*"

这里创建了一个名为“admin”的管理员账户，并设置了密码为“password”。

4.访问管理界面

通过浏览器访问RabbitMQ的管理界面，例如：

http://your_server_ip:15672/

输入之前设置的管理员账户的用户名和密码，即可进入管理界面。

示例

示例1：创建一个队列和一个消费者

使用Python的pika库创建一个队列和一个消费者。首先安装pika库：

pip install pika

然后编写以下Python代码：

import pika

# 连接到RabbitMQ服务器
connection = pika.BlockingConnection(
    pika.ConnectionParameters('localhost')
)
channel = connection.channel()

# 创建一个名为q_test的队列
channel.queue_declare(queue='q_test')

# 定义一个回调函数，用于处理接收到的消息
def callback(ch, method, properties, body):
    print("Received:", body)

# 创建一个消费者，绑定到队列q_test上，并开始消费消息
channel.basic_consume(queue='q_test', on_message_callback=callback, auto_ack=True)

print("Waiting for messages...")
channel.start_consuming()

运行代码后，您会看到“Waiting for messages...”的信息。现在可以在RabbitMQ的管理界面中发送一条消息到队列“q_test”，并在终端中查看到打印出了这条消息。

示例2：使用REST API创建一个交换机和一个绑定

使用curl命令通过REST API创建一个交换机和一个绑定。命令如下：

curl -i -u admin:password -H "content-type:application/json" \
    -XPUT http://your_server_ip:15672/api/exchanges/%2f/test_exchange \
    -d'{"type":"fanout","durable":true}'

curl -i -u admin:password -H "content-type:application/json" \
    -XPOST http://your_server_ip:15672/api/bindings/%2f/e/test_exchange/q_test \
    -d'{"routing_key":"", "arguments":{}}'

这里创建了一个名为“test_exchange”的fanout类型的交换机，并将其绑定到之前创建的队列“q_test”上。

好了，以上就是安装配置RabbitMQ的完整攻略。