zeromq和bind_to_random_port - 如何选择端口

Tam*_*mpa 8 zeromq pyzmq

在python中,我使用以下内容:

    context = zmq.Context()
    socket = context.socket(zmq.PUSH)
    socket.bind_to_random_port('tcp://*', min_port=6001, max_port=6004, max_tries=100)
    port_selected = socket.???????
Run Code Online (Sandbox Code Playgroud)

我怎么知道选择了什么端口?我将在redis中查找工作表以供工人阅读.

我正在使用推拉模型.我需要让工人知道要连接的端口.

我必须这样做,因为我在uwsgi中使用gevent循环并指定一个普通的盲目的thows和错误,因为一个分叉.如果使用bind_to_random_port然后选择一个端口,我只是不知道哪个.

Traceback (most recent call last):
  File "/usr/local/lib/python2.7/dist-packages/gevent-1.0b2-py2.7-linux-x86_64.egg/gevent/greenlet.py",
line 328, in run
    result = self._run(*self.args, **self.kwargs)
  File "/home/ubuntu/workspace/rtbopsConfig/rtbServers/rtbUwsgiPixelServer/uwsgiPixelServer.py",
line 43, in sendthis
    socket.send(push)
  File "/usr/local/lib/python2.7/dist-packages/zmq/green/core.py",
line 173, in send
    self._wait_write()
  File "/usr/local/lib/python2.7/dist-packages/zmq/green/core.py",
line 108, in _wait_write
    assert self.__writable.ready(), "Only one greenlet can be waiting
on this event"
AssertionError: Only one greenlet can be waiting on this event
<Greenlet at 0x2d41370: sendthis('2012-07-02 04:05:15')> failed with
AssertionError
Run Code Online (Sandbox Code Playgroud)

Sch*_*jer 15

port_selected = socket.bind_to_random_port('tcp://*', min_port=6001, max_port=6004, max_tries=100)
Run Code Online (Sandbox Code Playgroud)

  • 参考:http://zeromq.github.com/pyzmq/api/zmq.html#zmq.Socket.bind_to_random_port (2认同)