Python+ZeroMQ快速实现消息发布与订阅

ZeroMQ (也称ØMQ、0MQ或zmq)是一个开源的通用消息队列库，是一个并发网络框架，支持tcp（适用于在单机或多机的进程间通信）、ipc（适用于在单机环境的多进程间通信）和inproc（适用于在单个进程中的多个线程之间通信）等多种连接类型，支持PUSH/PULL（推/拉）、PUB/SUB（发布/订阅）、REQ/REP（同步请求/同步应答）以及DEALER（异步请求）、ROUTER（异步应答）等多种模式，运行速度能够满足集群应用开发的需要，支持支持C/C++/C#、Erlang、F#、Go、Haskell、Java、Node.js、Perl、Python、Ruby、Rust等多种编程语言，支持多种操作系统，使得网络应用程序开发更加简单、安全和高效，可以自动保证接收完整消息、自动重新连接、对方不在线时自动缓存数据，可以快速开发多服务端/多客户端的N:M通信系统且自动保证负载均衡。

ZeroMQ库的官方网站为https://zeromq.org，名字中的Zero意思是zero broker、zero latency、zero cost、zero administration，M表示消息Message，Q表示队列Queue。

扩展库pyzmq使得可以在Python中使用ZeroMQ库。

1、安装扩展库pyzmq

2、编写发布端程序

3、编写订阅端程序

运行结果：