zmq使用

zqm的三中模式

1、请求回复

server端

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

while True:
    message=socket.recv_string()
    socket.send(b"word")
    print message
    time.sleep(10)

client端

import zmq
import time

context = zmq.Context()

#  Socket to talk to server
print("Connecting to hello world server…")
socket = context.socket(zmq.REQ)
socket.connect("tcp://localhost:5555")

#  Do 10 requests, waiting each time for a response
s_time = time.time()
for request in range(10):
    print("Sending request %s …" % request)
    socket.send(b"Hello")

    #  Get the reply.
    message = socket.recv()
    print("Received reply %s [ %s ]" % (request, message))
print time.time() - s_time

2、订阅模式 client端通过指定最前面的字符

server端

import zmq
from random import randrange

context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind("tcp://*:5556")

while True:
    zipcode = randrange(1, 100000)
    temperature = randrange(-80, 135)
    relhumidity = randrange(10, 60)
    print zipcode

    socket.send_string("%i %i %i" % (zipcode, temperature, relhumidity))

client端

import sys
import zmq

#  Socket to talk to server
context = zmq.Context()
socket = context.socket(zmq.SUB)

print("Collecting updates from weather server…")
socket.connect("tcp://localhost:5556")

# Subscribe to zipcode, default is NYC, 10001
zip_filter = sys.argv[1] if len(sys.argv) > 1 else "10001"

# Python 2 - ascii bytes to unicode str
if isinstance(zip_filter, bytes):
    zip_filter = zip_filter.decode('ascii')
socket.setsockopt_string(zmq.SUBSCRIBE, zip_filter)

# Process 5 updates
total_temp = 0
for update_nbr in range(5):
    string = socket.recv_string()
    zipcode, temperature, relhumidity = string.split()
    total_temp += int(temperature)
    print zipcode

print("Average temperature for zipcode '%s' was %dF" % (
    zip_filter, total_temp / (update_nbr + 1))
      )

3、并行模式，server发送，client端启动多个接收，并行处理

server

import zmq
import time

context = zmq.Context()
socket = context.socket(zmq.PUSH)
socket.bind("tcp://*:5557")
num = 0

while True:
    num += 1
    socket.send("测试消息" + str(num))
    print "测试消息" + str(num)
    # print "已发送"
    time.sleep(1)

clinet

import zmq, time

context = zmq.Context()

recive = context.socket(zmq.PULL)
recive.connect('tcp://127.0.0.1:5557')


def test1():
    while True:
        data = recive.recv()
        print "正在转发..."
        print data
        time.sleep(5)
test1()