问题 gen_tcp:接受

Question

我已经创建了一个 TCP 服务器，它生成一个进程来侦听传入的连接。这是示例代码（从原始代码中删除了一些内容）：

module a:

main([]) ->
    { ok, Pid } = b:start(),
    receive
            _ ->
                    ok
    end.

module b:

-define(TCP_OPTIONS, [binary, { active, false}, { packet, 0 } , {reuseaddr, true}]).

...

start_link(Port) ->
    Pid = spawn_link(server_listener, init, [ Port ]),
    { ok , self() }.

init(Port, Processor) ->
    case gen_tcp:listen(Port, ?TCP_OPTIONS) of
     { ok , LSocket } ->
           accept_loop(LSocket);
     { error, Reason } ->
        { stop, Reason }
     end.

accept_loop( LSocket) ->
  ?LOG("Current socket acceptor PID [~w]~n", [self()]),
  case gen_tcp:accept(LSocket) of
      { ok, Socket } ->   
      %do stuff here
         spawn(server_listener , accept_loop, [ LSocket ]);
      { error, Reason }  ->
         ?LOG("Error accepting socket! [ ~s ]~n", [ Reason ])   
  end.

问题是：每次我尝试通过此端口上的 telnet 连接时，我都会收到错误 { error, close }在 gen_tcp 上：接受。这已经让我抓狂，想弄清楚到底发生了什么。

谢谢，

Answer 1

你的“接受循环”并不是真正的循环......而且它是人为的。

您可能需要“do_accept_loop”和适当的“server_loop”来处理连接。看看这个。

你想要一些类似的东西：

% Call echo:listen(Port) to start the service.
listen(Port) ->
    {ok, LSocket} = gen_tcp:listen(Port, ?TCP_OPTIONS),
    accept(LSocket).

% Wait for incoming connections and spawn the echo loop when we get one.
accept(LSocket) ->
    {ok, Socket} = gen_tcp:accept(LSocket),
    spawn(fun() -> loop(Socket) end),
    accept(LSocket).

% Echo back whatever data we receive on Socket.
loop(Socket) ->
    case gen_tcp:recv(Socket, 0) of
        {ok, Data} ->
            gen_tcp:send(Socket, Data),
            loop(Socket);
        {error, closed} ->
            ok
    end.