Python 全栈系列239 使用消息队列完成分布式任务

import time
import random
from redis import Redis
 
# 连接到Redis
redis_client = Redis(host='localhost', port=6379, db=0)
 
# 生产者：将任务推送到Redis列表中
def produce_tasks():
    for i in range(10):
        task = f"task_{i}"
        # 使用LPUSH将任务推入列表的左端
        redis_client.lpush("tasks_list", task)
        print(f"Produced: {task}")
        time.sleep(random.random())
 
# 消费者：从Redis列表中取出任务并执行
def consume_tasks():
    while True:
        # 使用BRPOP从列表的右端取出一个任务，超时设置为5秒
        task = redis_client.brpop("tasks_list", 5)
        if task:
            task_name = task[1]
            print(f"Consumed: {task_name}")
            # 这里可以添加任务处理的代码
            # handle_task(task_name)
        else:
            print("No tasks available")
 
# 启动生产者和消费者
produce_tasks()
consume_tasks()

这段代码演示了如何使用Redis的列表数据结构作为消息队列，来实现生产者和消费者模型。生产者函数produce_tasks将任务推入列表，消费者函数consume_tasks从列表中取出任务并处理。代码中使用了lpush和brpop命令，分别用于向列表左端添加元素和从列表右端取出元素并进行阻塞，从而实现了一个简单的分布式任务队列。