Redis 应用实践-消息队列-异步处理

import redis
import time
import threading

r = redis.Redis(host='localhost', port=6379, db=0)

# Web应用程序
def handle_request(request):
    r.lpush('request_queue', request)

# 处理请求的工作者进程
def worker():
    while True:
        request = r.rpop('request_queue')
        if request:
            # 处理请求
            print('processing request:', request)
        else:
            # 队列为空，等待新请求
            time.sleep(1)

# 创建工作者进程
for i in range(5):
    t = threading.Thread(target=worker)
    t.daemon = True
    t.start()

# 发送请求
for i in range(10):
    handle_request('request{}'.format(i))

# 等待所有请求处理完毕
while r.llen('request_queue') > 0:
    time.sleep(1)