Wie man einen tcp_listener stoppt, der in erlang als gen_server implementiert ist

Question

Ich habe einen tcp_listener als gen_server() implementiert. Ich habe eine Funktion namens start_link (Port) erstellt einen tcp_listener an diesem Port. Jetzt habe ich Probleme zu verstehen, wie ich dem tcp_listener sagen kann, dass er aufhört, durch stop() zu hören. Ich habe versucht, eine Funktion wie diese mit Stop aufzurufen.

in der terminate/2-Funktion Ich versuchte, die Abhörbuchse zu schließen, aber fehlgeschlagen.

terminate(_Reason, State = #state{lsocket = LSocket}) -> 
gen_tcp:close(LSocket), 
NewState = State#state{lsocket = null}, 
{ok, NewState}. 

Wenn ich den abhörenden Socket schließe, was passiert mit den akzeptierten Verbindungen, die ich hervorbrachte.

Vielen Dank!

start_link(Port) when is_integer(Port) -> 
    State = #state{port = Port}, 
    gen_server:start_link({local, ?MODULE}, ?MODULE, State, []). 

    init(State = #state{port = Port}) -> 
    io:format("Supervisor started me and I am listening at ~p ~n", [Port]), 
    case gen_tcp:listen(Port, ?TCP_OPTIONS) of 
    {ok, LSocket} -> 
    NewState = State#state{lsocket = LSocket}, 
    spawn(fun() -> accept(NewState) end), 
    {ok, NewState}; 
    {error, Reason} -> 
    {stop, Reason} 
    end. 

    accept(State = #state{lsocket = LSocket}) -> 
    case gen_tcp:accept(LSocket) of 
    {ok, Socket} -> 
    Pid = spawn(fun() -> 
    io:format("Connection accepted ~n"), 
    loop(Socket) 
       end), 
    gen_tcp:controlling_process(Socket, Pid), 
    accept(State); 
    {error, closed} -> error 
    end. 

    loop(Socket) -> 
    case gen_tcp:recv(Socket, 0) of 
     {ok, Data} -> 
     gen_tcp:send(Socket, Data), 
    loop(Socket); 
    {error, closed} -> 
     ok 
    end. 

Answer 1

empfehle ich Ihnen einen Blick auf this chapter in the Learn You Some Erlang book, insbesondere:

Beide Buchsen Nachrichten auf die gleiche Weise senden, und kann dann mit gen_tcp:close(Socket) geschlossen werden. Beachten Sie, dass das Schließen eines accept-Sockets diesen Socket alleine schließt, und das Schließen eines listen Sockets schließt keine der zugehörigen und etablierten accept-Sockets, sondern unterbricht die gerade laufenden akzeptierten Aufrufe durch die Rückgabe von {error, closed}.

So sollte es nur eine Frage des Aufrufs gen_tcp:close(Socket) auf allen Sockets sein.