Redis 应用实践-消息队列-解耦系统组件

import redis
import time
import threading

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

# 组件1
def component1():
    while True:
        # 执行任务1
        print('component1 task1')
        time.sleep(1)
        # 推送消息到队列
        r.publish('queue1', 'message from component1')

# 组件2
def component2():
    p = r.pubsub()
    p.subscribe('queue1')
    while True:
        message = p.get_message()
        if message and message['type'] == 'message':
            # 执行任务2
            print('component2 task2:', message['data'])

# 创建组件线程
t1 = threading.Thread(target=component1)
t2 = threading.Thread(target=component2)
t1.daemon = True
t2.daemon = True
t1.start()
t2.start()

# 等待程序结束
while True:
    time.sleep(1)