sender-->worker-->collector 形式，本例是 collector

ex_collector.py

#!/usr/bin/env python3
# -*- coding: utf-8 -*-

"""sender-->worker-->collector 形式，本例是 collector
"""

import zmq


class TaskCollector(object):

    def __init__(self):
        self.ctx = zmq.Context()

    def run(self):
        self.res_rcv = self.ctx.socket(zmq.PULL)
        self.res_rcv.bind('tcp://*:53001')

        while True:
            msg = self.res_rcv.recv()
            print('Result: {0}'.format(msg))


if __name__ == '__main__':
    task_collector = TaskCollector()
    task_collector.run()