详解Python实现ZeroMQ的三种基本工作模式-创新互联

简介

引用官方说法：ZMQ（以下 ZeroMQ 简称 ZMQ）是一个简单好用的传输层，像框架一样的一个 socket library，他使得 Socket 编程更加简单、简洁和性能更高。

是一个消息处理队列库，可在多个线程、内核和主机盒之间弹性伸缩。

ZMQ 的明确目标是“成为标准网络协议栈的一部分，之后进入 Linux 内核”。现在还未看到它们的成功。但是，它无疑是极具前景的、并且是人们更加需要的“传统” BSD 套接字之上的一 层封装。ZMQ 让编写高性能网络应用程序极为简单和有趣。

它跟 RabbitMQ，ActiveMQ 之类有着相当本质的区别，ZeroMQ 根本就不是一个消息队列服务器，更像是一组底层网络通讯库，对原有的 Socket API 加上一层封装，使我们操作更简便。

三种工作模式

Request-Reply 模式：

说到“请求-应答”模式，不得不说的就是它的消息流动模型。消息流动模型指的是该模式下，必须严格遵守“一问一答”的方式。

发出消息后，若没有收到回复，再发出第二条消息时就会抛出异常。同样的，对于 Rep 也是，在没有接收到消息前，不允许发出消息。

基于此构成“一问一答”的响应模式。

server:

# -*- coding=utf-8 -*-

import zmq

context = zmq.Context()
socket = context.socket(zmq.REP)
socket.bind("tcp://*:5555")

while True:
 message = socket.recv()
 print("Received: %s" % message)
 socket.send("I am OK!")