117笔记问答在Ubuntu上配置Python消息队列，你可以选择多种消息队列系统，如RabbitMQ、Redis、ZeroMQ等。以下是使用RabbitMQ和Redis作为消息队列系统的基本步骤：
使用RabbitMQ
-
安装RabbitMQ
打开终端并运行以下命令来安装RabbitMQ服务器：
sudo apt update sudo apt install rabbitmq-server
安装完成后，启动RabbitMQ服务：
sudo systemctl start rabbitmq-server
设置RabbitMQ开机自启：
sudo systemctl enable rabbitmq-server
-
安装Pika库
Pika是一个Python库，用于与RabbitMQ通信。在你的Python项目中安装Pika：
pip install pika
-
编写生产者和消费者代码
-
生产者：发送消息到队列。
import pika 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 def callback(ch, method, properties, body): print(f" [x] Received {body}") connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = connection.channel() channel.queue_declare(queue='hello') channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True) print(' [*] Waiting for messages. To exit press CTRL+C') channel.start_consuming()
-
使用Redis
-
安装Redis
打开终端并运行以下命令来安装Redis服务器：
sudo apt update sudo apt install redis-server
安装完成后，启动Redis服务：
sudo systemctl start redis-server
设置Redis开机自启：
sudo systemctl enable redis-server
-
安装redis-py库
在你的Python项目中安装redis-py库：
pip install redis
-
编写生产者和消费者代码
-
生产者：发送消息到Redis队列。
import redis r = redis.Redis(host='localhost', port=6379, db=0) r.lpush('messages', 'Hello World!') -
消费者：从Redis队列接收消息。
import redis r = redis.Redis(host='localhost', port=6379, db=0) while True: message = r.brpop('messages') print(f"Received: {message[1]}")
-
这些步骤为你提供了一个基本的消息队列配置示例。根据你的具体需求，你可能需要进一步配置消息队列系统，例如设置持久化、消息确认机制等。