FilesExpand file tree

 master

/

request_reply_broker.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

38 lines (29 loc) · 1017 Bytes

 master

/

request_reply_broker.py

Top

File metadata and controls

• Code
• Blame

38 lines (29 loc) · 1017 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

#!/usr/bin/env python

# -*- coding: utf-8 -*-

# Simple request-reply broker

#

# Author: Lev Givon <lev(at)columbia(dot)edu>

# 参考: http://zguide.zeromq.org/py:rrbroker

import zmq

# Prepare our context and sockets

context = zmq.Context()

frontend = context.socket(zmq.ROUTER)

backend = context.socket(zmq.DEALER)

frontend.bind("tcp://*:5559")

backend.bind("tcp://*:5560")

# Initialize poll set

poller = zmq.Poller()

poller.register(frontend, zmq.POLLIN)

poller.register(backend, zmq.POLLIN)

# Switch messages between sockets

while True:

socks = dict(poller.poll())

if socks.get(frontend) == zmq.POLLIN:

# 如果有来来自: frontend的message, 则转发给后端?

message = frontend.recv_multipart()

backend.send_multipart(message)

if socks.get(backend) == zmq.POLLIN:

# 如果有来自后端的消息，则转发给前端

message = backend.recv_multipart()

frontend.send_multipart(message)

# zerohub通过zmq自带的函数来实现了? zerohub