Redis 应用实践-消息队列-解耦系统组件
Redis作为消息队列的应用场景之二是解耦系统组件。例如，当一个系统由多个组件组成时，每个组件都可以将消息推送到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)在此示例中，组件1向名为queue1的主题中发布消息，而组件2订阅queue1主题以获取消息。当组件1推送消息时，组件2将获取并处理消息。
举报
腾讯云开发者
