极简发布/订阅模式：同步通信的基石

2023-11-12 01:57:25

在软件架构中，发布/订阅模式是一种消息范式，用于建立发布者和订阅者之间的同步通信。与传统的请求/响应模型不同，发布/订阅模式允许发布者向订阅者发送消息，而无需了解谁在监听。

发布/订阅模式的基础

发布/订阅模式包含以下关键元素：

发布者： 产生消息并将其发布到特定主题的组件。
订阅者： 对特定主题感兴趣并接收与该主题相关消息的组件。
主题： 用于对消息进行分类并将其路由到适当订阅者的逻辑通道。
消息队列： 存储发布消息的临时存储区，直到订阅者可以处理它们。

实现一个极简发布/订阅模式

让我们通过一个简单的 Python 实现来了解发布/订阅模式的基本原理：

import asyncio
import time

# 定义主题
TOPIC = "my_topic"

# 定义消息队列
message_queue = asyncio.Queue()

# 定义发布者
async def publisher():
    while True:
        message = input("Enter message to publish: ")
        await message_queue.put(message)
        print(f"Published message: {message}")
        time.sleep(1)

# 定义订阅者
async def subscriber():
    while True:
        message = await message_queue.get()
        print(f"Received message: {message}")

# 创建任务
publisher_task = asyncio.create_task(publisher())
subscriber_task = asyncio.create_task(subscriber())

# 运行事件循环
asyncio.run(publisher_task)
asyncio.run(subscriber_task)