这篇文章将为大家详细讲解有关使用python3如何实现ZeroMQ的三种模式，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。
10年积累的成都网站设计、网站制作、
外贸营销网站建设经验，可以快速应对客户对网站的新想法和需求。提供各种问题对应的解决方案。让选择我们的客户得到更好、更有力的网络服务。我虽然不认识你，你也不认识我。但先
网站制作后付款的网站建设流程，更有
路北免费网站建设让你可以放心的选择与我们合作。python是什么意思
Python是一种跨平台的、具有解释性、编译性、互动性和面向对象的脚本语言，其最初的设计是用于编写自动化脚本，随着版本的不断更新和新功能的添加，常用于用于开发独立的项目和大型项目。
ZeroMQ是一个消息队列网络库，实现网络常用技术封装。在C/S中实现了三种模式，这段时间用python简单实现了一下，感觉python虽然灵活。但是数据处理不如C++自由灵活。
Request-Reply模式：
客户端在请求后，服务端必须回响应
server：
# -*-coding:utf-8 -*-
import zmq
context = zmq.Context()
socket = context.socket(zmq.REP)
socket.bind("tcp://*:5555")
while True:
message = socket.recv()
print (message)
socket.send("server response!".encode('utf-8'))clinet：
# -*-coding:utf-8 -*-
import zmq
import sys
context = zmq.Context()
socket = context.socket(zmq.REQ)
socket.connect("tcp://localhost:5555")
while(True):
data = input("input your data:")
if data == 'q':
sys.exit()
print(data)
socket.send(data.encode('utf-8'))
response = socket.recv();
print (response)Publish-Subscribe模式：
广播所有client，没有队列缓存，断开连接数据将永远丢失。client可以进行数据过滤。
server：
# -*-coding:utf-8 -*-
import zmq
context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind("tcp://127.0.0.1:5000")
while True:
data = input('input your data:')
socket.send(data.encode('utf-8'))clinet：
# -*-coding:utf-8 -*-
import time
import zmq
context = zmq.Context()
socket = context.socket(zmq.SUB)
socket.connect("tcp://127.0.0.1:5000")
socket.setsockopt(zmq.SUBSCRIBE, ''.encode('utf-8'))
while True:
print(socket.recv())Parallel Pipeline模式：
由三部分组成，push进行数据推送，work进行数据缓存，pull进行数据竞争获取处理。区别于Publish-Subscribe存在一个数据缓存和处理负载。
当连接被断开，数据不会丢失，重连后数据继续发送到对端
server：
# -*-coding:utf-8 -*-
import zmq
context = zmq.Context()
recive = context.socket(zmq.PULL)
recive.connect('tcp://127.0.0.1:5558')
while True:
data = recive.recv()
print(data)work：
# -*-coding:utf-8 -*-
import zmq
context = zmq.Context()
recive = context.socket(zmq.PULL)
recive.connect('tcp://127.0.0.1:5557')
sender = context.socket(zmq.PUSH)
sender.connect('tcp://127.0.0.1:5558')
while True:
data = recive.recv()
print(data)
sender.send(data)clinet：
# -*-coding:utf-8 -*-
import zmq
import time
context = zmq.Context()
socket = context.socket(zmq.PUSH)
socket.bind('tcp://*:5557')
while True:
data = input('input your data:')
print(data)
socket.send(data.encode('utf-8'))关于“使用python3如何实现ZeroMQ的三种模式”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，使各位可以学到更多知识，如果觉得文章不错，请把它分享出去让更多的人看到。
网站名称：使用python3如何实现ZeroMQ的三种模式-创新互联
标题链接：
http://cdkjz.cn/article/dgschi.html
