CentOS中Python消息队列怎么搭建

centos

小樊

2025-07-29 02:11:14

栏目: 编程语言

在CentOS系统中搭建Python消息队列，你可以选择多种消息队列系统，如RabbitMQ、Redis、Kafka等。以下是使用RabbitMQ作为消息队列系统的搭建步骤：

1. 安装Erlang

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

sudo yum install -y erlang

2. 安装RabbitMQ服务器

接下来安装RabbitMQ服务器。

sudo yum install -y rabbitmq-server

3. 启动RabbitMQ服务

安装完成后，启动RabbitMQ服务并设置开机自启。

sudo systemctl start rabbitmq-server
sudo systemctl enable rabbitmq-server

4. 启用管理插件

为了方便管理RabbitMQ，可以启用管理插件。

sudo rabbitmq-plugins enable rabbitmq_management

5. 验证安装

打开浏览器，访问 http://<your_server_ip>:15672/，默认用户名和密码都是 guest。你应该能看到RabbitMQ的管理界面。

6. 安装Python客户端库

使用pip安装RabbitMQ的Python客户端库pika。

pip install pika

7. 编写生产者和消费者代码

生产者代码示例

import pika

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

# 声明一个队列
channel.queue_declare(queue='hello')

# 发送消息
channel.basic_publish(exchange='', routing_key='hello', body='Hello World!')
print(" [x] Sent 'Hello World!'")

# 关闭连接
connection.close()

消费者代码示例

import pika

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

# 声明一个队列
channel.queue_declare(queue='hello')

# 定义回调函数
def callback(ch, method, properties, body):
    print(f" [x] Received {body}")

# 消费消息
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)

print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

8. 运行生产者和消费者

分别运行生产者和消费者脚本，观察消息的发送和接收情况。

python producer.py
python consumer.py

通过以上步骤，你就可以在CentOS系统中成功搭建一个基于RabbitMQ的Python消息队列系统。如果你选择其他消息队列系统，如Redis或Kafka，步骤会有所不同，但基本思路类似：安装相应的服务器软件，配置环境，编写生产者和消费者代码。