2

Erlangレシーバーに送信する.NET TCP Senderがあります。.NET コンポーネントは::1、解決時に IPv6 アドレスを使用することを好みますlocalhost。Erlang に gen_tcp を使用して IPv6 アドレスをリッスンさせる方法がよくわかりません。これが私の試みです。リスニングを行うように間違ったソケットに指示していますか? ありがとう！

listen(Config) ->
    PortString = Config#cfg.eventbusport,
    GoodPort = check_int(PortString),
    Port = if GoodPort -> 
               list_to_integer(PortString);
           true ->
               ?DEFAULT_PORT
           end,                      %% IPv6 here --->
    {ok, XSocket} = gen_tcp:listen(Port, [binary, {packet, line}, {active, false}, {reuseaddr, true}, inet6, {ip, {0,0,0,0,0,0,0,1}}])
    end,
    accept(XSocket, Config).

accept(LSocket, Config) ->
    case gen_tcp:accept(LSocket) of
        {ok, Socket} ->
            spawn_link(fun() -> loop(Socket, Config) end),
            accept(LSocket, Config);
        {error, closed} ->
            logger("Accept: Closed socket.",[],1),
            listen(Config)
    end.

loop(Socket, Config) ->
    case inet:setopts(Socket, [{recbuf, 64000}]) of
        ok ->
            case gen_tcp:recv(Socket, 0) of
                {ok, Data} ->
                    SplitData = binary:split(Data,?CRLF,[global]),
                    discrim(SplitData, Config),
                    loop(Socket, Config);
                {error, closed} ->
                    logger("Loop: Closed socket.",[],1),
                    ok
            end;
        {error, Reason} ->
            logger("ERROR: Couldn't set the recbuf to 64k! Because ~p",[Reason],1)
    end.
4

1 に答える 1

1

あなたが抱えている実際の問題は何ですか？

おそらく、ソケットの制御プロセスを、接続を使用するために生成したプロセスに設定する必要があります。したがって、あなたaccept/2は次のようなことをします：

accept(LSocket, Config) ->
    case gen_tcp:accept(LSocket) of
        {ok, Socket} ->
            Pid = spawn_link(fun() -> loop(Socket, Config) end),
            gen_tcp:controlling_process(Socket, Pid),
            accept(LSocket, Config);
...

受け入れループを記述する別の方法は、代わりに新しい受け入れループを生成しすぎることです。次のようなものが得られます。

accept_loop(LSocket, Config) ->
    {ok,Socket} = gen_tcp:accept(LSocket),
    spawn_link(fun() -> accept_loop(LSocket, Config) end),
    loop(Socket, Config).

これはエラー処理なしです。リッスン ソケットを他のプロセスに問題なく渡すことができます。もちろん、リッスン ソケットを開いたプロセスが終了すると、ソケットは閉じられます。

于 2011-11-26T14:04:59.247 に答える