下载ZeroMq:
wget https://github.com/zeromq/zeromq4-1/releases/download/v4.1.5/zeromq-4.1.5.tar.gz
解压:
$ tar zvxf zeromq-4.1.5.tar.gz $ mv zeromq-4.1.5 zeromq $ cd zeromq
编译安装:
$sudo ./configure $sudo make $sudo make install
python学习zeromq的地址:https://learning-0mq-with-pyzmq.readthedocs.io/en/latest/pyzmq/basics.html
一个简单的例子:
# -*- coding: utf-8 -*- import zmq import random import sys import time port = "5556" context = zmq.Context() socket_server = context.socket(zmq.PAIR) socket_server.bind("tcp://*:%s" % port) socket = context.socket(zmq.PAIR) socket.connect("tcp://localhost:%s" % port) for i in range(10): socket.send("client message to server "+ str(i)) while True: msg = socket_server.recv() print msg time.sleep(10)
输出:
[deepai@q_1 test]$ python 3.py
client message to server 0
client message to server 1
client message to server 2
client message to server 3
client message to server 4
client message to server 5
client message to server 6
client message to server 7
client message to server 8
client message to server 9
完毕。