相关疑难解决方法(0)

我发现了一个类似的问题,ZeroMQ:PUSH上的HWM不起作用,但它无法解决我的问题.

我想控制推送套接字队列的消息数,但它不起作用,仍然排队1000条消息.
所以我想知道如何设置推插座的hwm.提前致谢.

我的环境是:libzmq 4.0.4,pyzmq 14.1.0,python 3.3

这是我的代码:

server.py

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

import random

import zmq


class TestPush(object):

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

        random.seed()

    def run(self):
        task_snd = self.ctx.socket(zmq.PUSH)
        task_snd.setsockopt(zmq.SNDHWM, 10)
        task_snd.bind('tcp://*:53000')        

        while True:
            workload = str(random.randint(1, 100))
            task_snd.send(workload.encode('utf-8'))
            print('Send {0}'.format(workload))


if __name__ == '__main__':
    test_push = TestPush()
    test_push.run()

client.py

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

import time
import random

import zmq


class TestPull(object):

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

    def run(self):
        task_rcv = …