为什么 Zeromq 不能在本地主机上工作？

Question

这段代码工作得很好：

import zmq, json, time

def main():
    context = zmq.Context()
    subscriber = context.socket(zmq.SUB)
    subscriber.bind("ipc://test")
    subscriber.setsockopt(zmq.SUBSCRIBE, '')
    while True:
        print subscriber.recv()

def main():
    context = zmq.Context()
    publisher = context.socket(zmq.PUB)
    publisher.connect("ipc://test")
    while True:
        publisher.send( "hello world" )
        time.sleep( 1 )

但是这段代码不*工作：

import zmq, json, time

def recv():
    context = zmq.Context()
    subscriber = context.socket(zmq.SUB)
    subscriber.bind("tcp://localhost:5555")
    subscriber.setsockopt(zmq.SUBSCRIBE, '')
    while True:
        print subscriber.recv()

def send():
    context = zmq.Context()
    publisher = context.socket(zmq.PUB)
    publisher.connect("tcp://localhost:5555")
    while True:
        publisher.send( "hello world" )
        time.sleep( 1 )

它引发了这个错误：

ZMQError：没有这样的设备

为什么，zeromq 不能使用 localhost 接口？

只能在同一台机器上的IPC上使用吗？

Answer 1

正如 @fdb 指出的：

问题出在 line:

subscriber.bind("tcp://localhost:5555")

try 更改为：

subscriber.bind("tcp://127.0.0.1:5555")

但是，这需要更多解释以理解原因。

zmq_bind 的文档解释了（粗体强调是我的）：

endpoint 参数是一个由两部分组成的字符串，如下所示：
运输://地址。 传输部分指定底层
要使用的传输协议。 地址部分的含义是特定的
到所选的底层传输协议。

由于您的示例使用 tcp 作为传输协议，我们在 zmq_tcp 文档来发现（再次强调我的）：

使用 zmq_bind() 为套接字分配本地地址时
tcp 传输，端点应解释为接口
后跟冒号和要使用的 TCP 端口号。

接口可以通过以下任一方式指定：

• 通配符 *，表示所有可用接口。
• 分配给接口的主 IPv4 地址，采用数字表示形式。
• 操作系统定义的接口名称。

因此，如果您不使用通配符或接口名称，则意味着您必须使用数字形式的 IPv4 地址（而不是 DNS 名称）。

注意，这只适用于使用zmq_bind！另一方面，使用 zmq_connect 的 DNS 名称是完全可以的，正如稍后在 zmq_tcp：

使用 zmq_connect() 将套接字连接到对等地址时
TCP 传输，端点应被解释为对等地址
后跟冒号和要使用的 TCP 端口号。

对等地址可以通过以下任一方式指定：

• 对等方的 DNS 名称。
• 对等方的 IPv4 地址（采用数字表示形式）。

Answer 2

问题出在行：

subscriber.bind("tcp://localhost:5555")

尝试更改为：

subscriber.bind("tcp://127.0.0.1:5555")