目录
一.引言
二.安装ZeroMQ
三.模式一（发布-订阅模式）
发布-订阅模式详解
适用场景：
示例代码：
四.模式二（请求-响应模式）
请求-响应模式详解
适用场景：
示例代码：
五.模式二（请求-响应模式）
推送-拉取模式详解
适用场景：
示例代码：
一.引言
ZeroMQ（ZMQ）是一个高效、轻量级的消息传递库，广泛用于构建分布式系统和网络通信。本教程将介绍如何使用Python和ZeroMQ创建简单的消息传递系统，包括发布-订阅，请求-响应，推送-拉取三种模式
二.安装ZeroMQ
pip install pyzmq三.模式一（发布-订阅模式）
发布-订阅模式详解
在发布-订阅模式中，适用于一对多的通信场景。一个发布者发送消息，多个订阅者接收消息。
适用场景：
- 新闻订阅系统： 一个新闻发布者定期发布新闻，多个用户作为订阅者接收新闻通知。
示例代码：
# 发布者
import zmq
import time
context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind("tcp://127.0.0.1:5555")
while True:
news = "Breaking News! Time: {}".format(time.time())
socket.send_string(news)
time.sleep(1)# 订阅者
import zmq
context = zmq.Context()
socket = context.socket(zmq.SUB)
socket.connect("tcp://127.0.0.1:5555")
socket.setsockopt_string(zmq.SUBSCRIBE, "")
while True:
news = socket.recv_string()
print("Received News: {}".format(news))四.模式二（请求-响应模式）
请求-响应模式详解
在请求-响应模式中，适用于客户端向服务器发送请求，服务器返回响应的场景。
适用场景：
- 客户端-服务器通信： 客户端发送请求，服务器处理请求并返回相应结果。
示例代码：
# 请求者
import zmq
context = zmq.Context()
socket = context.socket(zmq.REQ)
socket.connect("tcp://127.0.0.1:5556")
while True:
request = input("Enter your request: ")
socket.send_string(request)
response = socket.recv_string()
print("Response: {}".format(response))# 响应者
import zmq
context = zmq.Context()
socket = context.socket(zmq.REP)
socket.bind("tcp://127.0.0.1:5556")
while True:
request = socket.recv_string()
print("Received request: {}".format(request))
response = input("Enter your response: ")
socket.send_string(response)五.模式二（请求-响应模式）
推送-拉取模式详解
在推送-拉取模式中，适用于单个生产者向多个消费者广播消息的场景。
适用场景：
- 任务分发系统： 一个任务分发者将任务推送给多个工作者，工作者通过拉取方式获取任务进行处理。
示例代码：
# 推送者
import zmq
import time
context = zmq.Context()
socket = context.socket(zmq.PUSH)
socket.bind("tcp://127.0.0.1:5557")
while True:
task = "New task! Time: {}".format(time.time())
socket.send_string(task)
time.sleep(1)# 拉取者
import zmq
context = zmq.Context()
socket = context.socket(zmq.PULL)
socket.connect("tcp://127.0.0.1:5557")
while True:
task = socket.recv_string()
print("Received Task: {}".format(task))这些例子提供了使用发布-订阅、请求-响应和推送-拉取模式的基本场景和代码。实际应用中，你可以根据需求组合这些模式，创建更复杂、更灵活的通信系统。
