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

ex_worker.py

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

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

import zmq


class TaskWorker(object):

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

    def run(self):
        self.task_rcv = self.ctx.socket(zmq.PULL)
        self.task_rcv.connect('tcp://localhost:53000')

        self.res_snd = self.ctx.socket(zmq.PUSH)
        self.res_snd.connect('tcp://localhost:53001')

        while True:
            task = self.task_rcv.recv()
            print('Worker has got task: {0}'.format(task))

            res = 'Res-{0}'.format(task)
            self.res_snd.send(res.encode('utf-8'))
            print('Has sent res: {0}'.format(res))


if __name__ == '__main__':
    task_worker = TaskWorker()
    task_worker.run()