问题gen_tcp：接受

Question

我做了一个tcp服务器产生一个进程监听传入的连接。下面是示例代码（从我的原代码中删除了一些东西）：

模块：

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

模块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连接，我在gen_tcp：accept上收到错误{error，closed}。这已经迫使我试图弄清楚发生了什么。

感谢，

Answer 1

你“接受环”是不是一个真正的环...它是人为的。

您可能想要“do_accept_loop”和适当的“server_loop”来处理连接。看看this。

你想沿着线的东西：

% 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.