4

在我的 Erlang 开发中，我需要创建一个 C-Node（请参阅C-Node 文档的链接）。基本实现很简单，但是文档中有一个巨大的漏洞。

该代码实现了单线程客户端和服务器。暂时忽略客户端......实现服务器的'c'代码是单线程的，一次只能连接到一个erlang客户端。

  1. 启动 EPMD ('epmd -daemons')
  2. 启动服务器应用程序（'cserver 1234'）
  3. 启动 erlang 客户端应用程序 ('erl -sname e1 -setcookie secretcookie') [在与 #2 不同的窗口中]
  4. 从 #3 中的 erlang shell 执行服务器命令 ('complex3:foo(3).')

现在服务器正在运行并且当前的 erlang shell 已连接到服务器，从另一个窗口再次尝试。

  1. 打开一个新窗口。
  2. 启动一个 erlang 客户端（'erl -sname e2 -setcookie secretcookie'）。
  3. 执行一个新的服务器命令（'complex3:foo(3).'）。

请注意，系统似乎挂起......它应该已经执行了命令。它挂起的原因是因为另一个 erlang 节点已连接，并且没有其他线程在侦听连接。

注意：连接处理中似乎存在错误。我在接收块中添加了一个超时，我发现了一些错误的行为，但我没有得到它们。此外，如果我在执行指示的步骤后强制第一个 erlang 节点终止，我能够让 cserver 在没有警告或错误的情况下崩溃。

所以问题是......实现线程化 C 节点的最佳方式是什么？什么是合理的连接数？

4

1 回答 1

4

cnode 教程中的 cnode 实现示例并不意味着处理多个连接的节点，因此您遇到的第一个症状是正常的。

erl_accept呼叫是接受传入连接的内容。

if ((fd = erl_accept(listen, &conn)) == ERL_ERROR)
  erl_err_quit("erl_accept");
fprintf(stderr, "Connected to %s\n\r", conn.nodename);
while (loop) {
  got = erl_receive_msg(fd, buf, BUFSIZE, &emsg);

请注意，以这种方式编写，cnode 将只接受一个连接，然后将描述符传递给读/写循环。这就是为什么当 erlang 节点关闭时，cnode 以错误结束，因为erl_receive_msg会失败，因为fd将指向一个关闭的套接字。

如果要接受多个入站连接，则必须循环接受连接并实现一种处理多个文件描述符的方法。您不需要多线程程序来执行此操作，如果您的操作系统支持它们，使用pollor系统调用可能会更容易（并且可能更有效）。select

至于最佳连接数，我认为没有规则，如果您想在 cnode 中支持高并发，则需要对您的应用程序进行基准测试。但在这种情况下，重新设计系统可能会更好，以便 erlang 处理并发，从而减轻 cnode 的负担。

于 2011-01-17T22:04:20.417 回答