使用 gen_tcp:send 的消息在套接字关闭之前不会被发送

Question

我想编写一个简单的客户端，向服务器发送消息并接收响应。我有一个服务器，它向所有连接的客户端广播相同的消息，并且在我使用 telnet 测试它时它正在工作。当我尝试使用 Erlang shell 执行此操作时， gen_tcp:send 在我关闭套接字之前不会发送任何消息。

这就是我想要做的：

{ok, S} = gen_tcp:connect(IP, Port, []).
gen_tcp:send(S, "Test").
flush().

通过查看我的 telnet 客户端，我可以看到当我关闭套接字时消息已发送。

Erlang 版本：R14B01 (erts-5.8.2)

更新

hdima 评论说服务器从流中提取消息的方式可能有问题。这似乎是因为当我尝试编写自己的服务器时，客户端似乎按预期工作。我将尝试获取服务器的源代码。顺便说一句，服务器是用 Java 编写的。

Answer 1

你可以用 Erlang 服务器试试这个，看看是服务器端还是客户端有问题。

在外壳 A 中：

1> {ok, L} = gen_tcp:listen(12345, [{active, false}]).
{ok,#Port<0.601>}
2> {ok, S} = gen_tcp:accept(L), {ok, P} = gen_tcp:recv(S, 0), gen_tcp:send(S, P).
... % Server will block here until a message comes
ok

在外壳 B 中：

1> {ok, S} = gen_tcp:connect(localhost, 12345, []), gen_tcp:send(S, "hello").
ok
2> flush().
Shell got {tcp,#Port<0.607>,"hello"}

如果可行，则很可能是 Java 方面的问题。

Answer 2

主要问题是没有通用消息格式。因此，您的第一步是找到服务器使用的消息格式。您无法使用其他语言与服务器交谈。

一些消息格式可以是：

• 整个流就是一条消息。
• 固定大小的消息。
• 由标记分隔的消息。例如SMTP、POP、HTTP 和许多其他协议都使用这种类型的消息。
• 带有大小字段的消息。例如TLV (Type-Length-Value) 消息格式。 IP、UDP、Erlang 和许多其他协议都使用这种类型的消息。

例如，如果服务器理解由换行符分隔的消息，您可以使用以下代码发送两条不同的消息：

1> {ok, S} = gen_tcp:connect(IP, Port, []).
2> gen_tcp:send(S, "Test\n").
3> gen_tcp:send(S, "Test2\n").

Answer 3

当发送小块数据时，套接字会缓冲它们以尝试填充 TCP 数据包的最大负载。

这可能是正在发生的事情，因为当您关闭套接字时，它会在释放之前被刷新。

尝试设置

{nodelay, true}

您的套接字上的选项。

更多信息在这里： http://www.erlang.org/doc/man/inet.html#setopts-2