python - 使用传统的 TCP 向 ZeroMQ 服务器发送消息，可能吗？

Question

我不确定我这样做是否正确，但我希望能够从正常的 TCP 连接向我运行 ZMQ 的服务器发送消息。服务器使用 TCP 传输 在端口 5555 上运行 Python ZMQ。我希望能够使用使用传统 TCP 的不同客户端(Python、Java、PHP)向它发送消息。这是我目前所拥有的:

服务器

context = zmq.Context()
socket = context.socket(zmq.REP)
socket.bind("tcp://*:5555")

while True:
    message = socket.recv()
    print message
    socket.send('{"name":"someone"}')

客户

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect(('127.0.0.1', 5555))
s.send('Hello, World!')
data = s.recv(1024)
print data

在客户端上打印 data 没有给我预期的消息。我明白了:�。我尝试做 bytes(data).decode('utf8') 以为我得到的是字节数组，但我收到以下错误:

UnicodeDecodeError: 'ascii' codec can't decode byte 0xff in position 0: ordinal not in range(128)

我只是想知道:这可能吗？还是我做错了什么？还有，推荐吗？

我不在客户端上使用 ZMQ 的原因是我想减少依赖项的数量(ZeroMQ 是一个)。

感谢您的帮助。

Answer 1

ZeroMQ 是一个位于 TCP 之上的协议(protocol)(嗯，从技术上讲，ZMTP 是一个协议(protocol)；0MQ 是实现 ZMTP 协议(protocol)的库，而 ZeroMQ 是 0MQ 的 Python 实现……)。它所做的所有信号，以及所有的帧(将字节流分成单独的消息)，都是通过在套接字上发送字节来完成的。不知道如何执行 ZeroMQ 信号和框架的客户端只会看到一堆垃圾。

您正在尝试做的事情就像尝试编写一个只读取套接字而不知道任何 HTTP 的 Web 客户端。你会得到一堆你不知道如何处理的框架 Material 。唯一的区别是，在 HTTP 的情况下，框架有时(但不总是——你可以有 MIME 信封、gzip 传输编码、分 block 传输……)只是在数据之前的一堆人类可读的 ASCII，而对于 ZMTP，它从不是人类可读的……

如果你想通过普通 TCP 套接字发送数据，你必须通过在服务器端创建普通 TCP 套接字并调用它的send(或sendall 等)方法。如果您想通过 ZMTP channel 发送数据，您必须通过在客户端解析 ZMTP 或使用为您解析的库(如 ZeroMQ)来实现。

还有一点要记住，与 ZMTP 不同，TCP 不是面向消息的协议(protocol)；所有 TCP 发送的都是字节流。从接收端，无法知道一个发送何时结束，下一个发送何时开始。因此，对于除了“发送请求、获得响应、挂断”协议(protocol)之外的几乎任何事情，您都需要编写自己的某种框架。这可以像“消息是其中没有换行符的字符串，并且每条消息都由换行符分隔”一样简单(在这种情况下，您可以只使用 socket.makefile)，但通常消息格式必须更复杂，或者你必须发送“命令”而不仅仅是数据等。

自 tdelaney's答案已被删除(我认为这意味着它对 10K 代表以下的任何人都是不可见的)，并且有一个有用的建议，我将在这里重复它，并注明应有的信用:您可以(使用 ZeroMQ 库)编写一个中间件ZMTP 与服务器对话，但您自己的基于 TCP 的简单协议(protocol)与客户端对话。 ZeroMQ 是专门为使这相当容易而设计的；正如 tdelaney 所说，“有点像乐高积木，你通过构建不同的通信部分来构建强大的通信基础设施。并非所有部分都需要是 zeromq。”