1

源文件:

-module(biu_server).
-export([start_server/0]).

start_server() -> 
  {ok, Listen} = gen_tcp:listen(1332,
         [binary, {packet, 4},{reuseaddr, true}, {active, true}]),
  spawn(fun() -> par_connect(Listen) end).

par_connect(Listen) ->
     {ok,Socket} = gen_tcp:accept(Listen),
     spawn(fun() -> par_connect(Listen) end),
     loop(Socket).

loop(Socket) ->
    receive
      {tcp, Socket, Request} ->
         gen_tcp:send(Socket, term_to_binary(Request)), 
         loop(Socket);
      {tcp_closed, Socket} ->
         io:format("Server socket closed~n")
    end.

内壳:

  1> c(biu_server).
  {ok,biu_server}
  2> biu_server:start_server().
  <0.40.0>
  3> q().
  ok
  4> {error_logger,{{2016,1,9},{18,40,28}},"Error in process ~p with exit value:~n~p~n",[<0.40.0>,{{badmatch,{error,closed}},[{biu_server,par_connect,1,[{file,"biu_server.erl"},{line,11}]}]}]}

我想写一个echo服务器,但是当我退出erlang shell时,error_logger警告badmatch,但客户端进程已经关闭。

为什么我的服务器关闭失败?怎么了?

4

3 回答 3

1

里面有一些不靠谱的东西。与它们交谈的最简单方法可能是只显示不同的版本:

-module(biu_server).
-export([start_server/0,start/0]).

start() ->
    spawn(fun() -> start_server() end).

start_server() ->
    Options = [list, {reuseaddr, true}],
    {ok, Listen} = gen_tcp:listen(1337, Options),
    par_connect(Listen).

par_connect(Listen) ->
    {ok, Socket} = gen_tcp:accept(Listen),
%     The line below is a whole different universe of confusion for now.
%     Get sequential stuff figured out first.
%   spawn(fun() -> par_connect(Listen) end),
    loop(Socket).

loop(Socket) ->
    ok = inet:setopts(Socket, [{active, once}]),
    receive
        {tcp, Socket, Request} ->
            ok = io:format("Received TCP message: ~tp~n", [Request]),
            Response = io_lib:format("You said: ~tp\r\n", [Request]),
            gen_tcp:send(Socket, Response),
            loop(Socket);
        {tcp_closed, Socket} ->
            io:format("Server socket closed~n");
        quit ->
            ok = io:format("Fine! I QUIT!~n");
        Unexpected ->
            ok = io:format("Unexpected message: ~tp~n", [Unexpected]),
            loop(Socket)
    end.

请注意,上面我注释掉了生成一个新进程来处理连接的调用。原始版本存在的问题之一是剩余的侦听器无法终止,因为它总是阻塞TCP 接受 - 永远。

那里还有一些套接字控制问题——最简单的解决方法是让每个侦听器产生下一个侦听器并继续处理其新获取的连接。另一种方法是做你已经做过的事情,但是需要管理一些细节才能使其顺利运行。(示例(不用担心,仍然很容易):https ://github.com/zxq9/erlmud/blob/master/erlmud-0.1/tcplistener.erl )。

我还在主循环中的接收中添加了两个新子句:一个让我们告诉进程从 Erlang 中杀死自己,另一个处理来自系统内部的意外消息。“Unexpected”子句之所以重要有两个原因:它告诉我们发生了什么(您通常应该收到神秘消息,但它可能会发生并且并不总是您的错),它可以防止进程邮箱堆积无法匹配但无法管理的消息。

只是坚持上面的版本,这是我第一次会议期间发生的事情......

在 Erlang 外壳中:

1> c(biu_server).
{ok,biu_server}
2> {Pid, Ref} = spawn_monitor(biu_server, start_server, []).
{<0.40.0>,#Ref<0.0.2.89>}
Received TCP message: "foo\r\n"
Received TCP message: "bar\r\n"
Received TCP message: "Yay! It works!\r\n"
Server socket closed
3> flush().
Shell got {'DOWN',#Ref<0.0.2.89>,process,<0.40.0>,normal}
ok
4> f().                                                     
ok

在 telnet 会话中:

ceverett@changa:~/Code/erlang$ telnet localhost 1337
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
foo
You said: "foo\r\n"
bar
You said: "bar\r\n"
Yay! It works!
You said: "Yay! It works!\r\n"
^]
telnet> quit
Connection closed.

正如我们所见,来自客户端的关闭连接按预期终止。shell 的进程正在监视 TCP 服务器进程,所以当我flush()最后看到'DOWN'监​​视器消息时,正如预期的那样——正常退出。

现在让我们做一个类似的会话,但我们将使用 Erlang 端的quit消息:

5> {Pid, Ref} = spawn_monitor(biu_server, start_server, []).
{<0.43.0>,#Ref<0.0.2.103>}
Received TCP message: "Still works.\r\n"
6> Pid ! "Launch the missiles!".
Unexpected message: "Launch the missiles!"
"Launch the missiles!"
7> Pid ! quit.
Fine! I QUIT!
quit
8> flush().
Shell got {'DOWN',#Ref<0.0.2.103>,process,<0.43.0>,normal}
ok

在远程登录方面:

ceverett@changa:~/Code/erlang$ telnet localhost 1337
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
Still works. 
You said: "Still works.\r\n"
Connection closed by foreign host.

您注意到那里的“\r\n”。这来自客户端的原始消息——所有 telnet 消息都以“\r\n”结尾(所以这就是你通常拆分流的方式——这是我们尚未解决的主题;这段代码实际上是假装 TCP 像 UDP 数据报一样工作,但事实并非如此......)。服务器返回消息中的“\r\n”被 telnet 客户端正确解释并中断到下一行。

顺便说一句,编写 telnet(或数据报)游戏是探索Erlang 网络模块的一种非常愉快的方式。

于 2016-01-09T13:26:57.963 回答
0

我解决了这个问题,但我不知道为什么......

http://erlang.2086793.n4.nabble.com/parallel-tcp-server-closed-once-spawned-td2099538.html

代码:

-module(biu_server).
-export([start_server/0,start/0]).

start() ->
    spawn(fun() -> start_server() end).

start_server() -> 
    {ok, Listen} = gen_tcp:listen(1332,
         [binary, {packet, 4},{reuseaddr, true}, {active, true}]),
    par_connect(Listen).

par_connect(Listen) ->
    {ok,Socket} = gen_tcp:accept(Listen),
    spawn(fun() -> par_connect(Listen) end),
    loop(Socket).

loop(Socket) ->
    receive
    {tcp, Socket, Request} ->
       gen_tcp:send(Socket, term_to_binary(Request)), 
       loop(Socket);
    {tcp_closed, Socket} ->
       io:format("Server socket closed~n")
    end.
于 2016-01-09T12:07:22.283 回答
0

当您q()从 shell 调用时,它会调用init:stop/0. 它基于文档所做的是:

所有应用程序都被顺利关闭,所有代码被卸载,所有端口在系统终止前关闭。

当您调用 时start_server/0,它会生成一个进程并process打开一个port用于 TCP 连接。因为你从 shell 内部启动你的服务器,所以它是链接到 shell 的,所以当 shell 收到退出信号时,它会再次将它发送给所有链接的进程,然后模块将产生以下错误报告error_logger

1> biu:start_server().
<0.35.0>
2> exit(normal).

=ERROR REPORT==== 9-Jan-2016::16:40:29 ===
Error in process <0.35.0> with exit value: {{badmatch,{error,closed}},[{biu,par_connect,1,[{file,"biu.erl"},{line,12}]}]}

** exception exit: normal
3> 

知道了这一点,当你q()在关闭端口之前调用时,所有模块都被卸载并且端口被一一关闭,因此会导致不需要的行为。

于 2016-01-09T13:21:08.497 回答