3

我在 C 中创建了一个套接字服务器(使用 nanomsg),它将通过 TCP 与 Python 脚本(使用标准的“套接字”实现)进行通信:

C 代码(无错误处理):

#include <nanomsg/nn.h>
#include <nanomsg/pair.h>
...
char buf[23];
...
socket = nn_socket(AF_SP, NN_PAIR);
nn_bind(socket, "tcp://127.0.0.1:xxxxx");
...
nn_recv(socket, buf, sizeof(buf), 0); 
...
nn_shutdown(socket, endpoint_id);

Python代码:

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
s.connect(("127.0.0.1", xxxxx))
s.send('Hello C this is Python')
s.close()

连接到套接字时 Python 没有错误(如果 C 应用程序正在运行)。但是,C 脚本在方法 nn_recv 中处于空闲状态,根本没有得到任何数据。我究竟做错了什么?

首先,我在 shell 中启动 C 代码(它在方法 nn_recv 中空闲)。然后我在另一个 shell 中启动 Python 并期望 C 应用程序接收数据。两个脚本都执行没有错误。

4

1 回答 1

5

问题是 nanomsg 套接字类型不是普通的标准 TCP 类型。协议不匹配。您不能将 TCP 消息发送到 nanomsg 套接字并期望它nn_recv会起作用,因为该消息将不符合定义的 nanomsg SP 协议要求。

请参阅 nanomsg SP 协议头:

0                1               2                3
0 1 2 3 4 5 6 7  8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3  4 5 6 7 8 9 0 1
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|      0x00     |      0x53     |      0x50     |    version    |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|             type              |           reserved            |
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+

协议头的前四个字节用于确保对等方的协议与本地端点使用的协议兼容。

如果从对等方接收到的协议头不同,则必须立即关闭TCP 连接。

这意味着send到 nanomsg 套接字的任何原始 TCP 都会终止连接,因为它不确认 SP 协议。

有关更多信息,请参阅此处的 sp-tcp-mapping-01.txt 文档

于 2016-10-30T19:16:12.573 回答