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

Redis作为消息队列的应用场景之二是解耦系统组件。例如，当一个系统由多个组件组成时，每个组件都可以将消息推送到Redis队列中，而其他组件可以订阅这些队列以获取消息。这样，系统组件之间的通信变得简单而高效。

代码语言：javascript复制

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)

在此示例中，组件1向名为queue1的主题中发布消息，而组件2订阅queue1主题以获取消息。当组件1推送消息时，组件2将获取并处理消息。

redis

0 人点赞