0

我正在运行一个 Flask 应用程序并在内部使用一个用 Node.js 编写的库，我通过 ZeroRPC 访问它（实际的节点进程由 Circus 管理）。这本身就可以正常工作；我可以毫无问题地进行单元测试。但是，当启动 Flask 应用程序作为侦听进程并调用调用此库的 REST api 时，程序在尝试启动进程时会引发异常。启动服务的代码如下：

from circus.watcher import Watcher
from circus.arbiter import ThreadedArbiter
from circus.util import (DEFAULT_ENDPOINT_DEALER, DEFAULT_ENDPOINT_SUB,
     DEFAULT_ENDPOINT_MULTICAST)
class Node(object):
    {... omitted code that initializes self._arbiter and self._client ...}
    def start(self):
        if self._arbiter and self._client:
            return
        port = 'ipc:///tmp/inlinejs_%s' % os.getpid()
        args = 'lib/server.js --port %s' % port
        watcher = Watcher('node', '/usr/local/bin/node', args,
            working_dir=INLINEJS_DIR)
        self._arbiter = ThreadedArbiter([watcher], DEFAULT_ENDPOINT_DEALER,
            DEFAULT_ENDPOINT_SUB, multicast_endpoint=DEFAULT_ENDPOINT_MULTICAST)
        self._arbiter.start()
        self._client = zerorpc.Client()
        self._client.connect(port)

此函数返回，但不久之后在一个单独的线程中，我收到此错误：

Exception in thread Thread-1:
Traceback (most recent call last):
  File "/python/lib/python2.7/site-packages/circus/_patch.py", line 21, in _bootstrap_inner
    self.run()
  File "/python/lib/python2.7/site-packages/circus/arbiter.py", line 647, in run
    return Arbiter.start(self)
  File "/python/lib/python2.7/site-packages/circus/util.py", line 319, in _log
    return func(self, *args, **kw)
  File "/python/lib/python2.7/site-packages/circus/arbiter.py", line 456, in start
    self.initialize()
  File "/python/lib/python2.7/site-packages/circus/util.py", line 319, in _log
    return func(self, *args, **kw)
  File "/python/lib/python2.7/site-packages/circus/arbiter.py", line 427, in initialize
    self.evpub_socket.bind(self.pubsub_endpoint)
  File "socket.pyx", line 432, in zmq.core.socket.Socket.bind (zmq/core/socket.c:4022)
  File "checkrc.pxd", line 21, in zmq.core.checkrc._check_rc (zmq/core/socket.c:5838)
ZMQError: Address already in use

我不知道为什么会发生这种情况，特别是因为它不会发生在单元测试中。任何人都可以解释一下吗？

4

1 回答 1

1

一般来说，当您收到这种类型的“正在使用的地址”错误时，这意味着您的程序正在尝试绑定 IP 端口号，但其他东西首先到达那里。

我不熟悉这个库，但由于错误是由“evpub_socket.bind”引起的，我猜你与常量 DEFAULT_ENDPOINT_SUB 指定的端口号有冲突。从马戏团源代码中，我看到了这些常量：

DEFAULT_ENDPOINT_DEALER = "tcp://127.0.0.1:5555" DEFAULT_ENDPOINT_SUB = "tcp://127.0.0.1:5556" DEFAULT_ENDPOINT_STATS = "tcp://127.0.0.1:5557"

检查您的系统 (netstat) 并查看是否有任何进程正在侦听端口 5555、5556、5557。或者您可能正在运行该程序两次而您忘记了第一个。

于 2013-11-03T01:34:05.803 回答