Erlang中文论坛

标题: 对socket执行gen_tcp:accept/1返回{error, closed} [打印本页]

作者: 茶叶feng    时间: 2018-9-4 19:13
标题: 对socket执行gen_tcp:accept/1返回{error, closed}
本帖最后由 茶叶feng 于 2018-9-4 19:15 编辑

shell脚本启动listen后accept总是报{error, closed}错误
书上说,socket的生命周期和它的归属进程一样,也就是说归属进程死了,socket也就死了,之前没有对这句话理解好,当用shell脚本启动erlang虚拟机的时候,就出现了下面的问题
以下是socket_example.erl部分的代码,用shell脚本直接执行erl -s socket_example -- start,但是执行gen_tcp:accept(LSocket)时候总是报{error, closed}错误
  1. start() ->
  2.     Args = [binary, {packet, 4}, {reuseaddr, false}, {active, true}],
  3.     {ok, LSocket} = gen_tcp:listen(8088, Args),
  4.     spawn(fun() -> wait_client(LSocket) end).

  5. wait_client(LSocket) ->
  6.     case gen_tcp:accept(LSocket) of
  7.         {ok, Socket} ->
  8.             spawn(fun() -> wait_client(LSocket) end),
  9.             loop(Socket);
  10.         {error, Reason} ->
  11.             io:format("error ~p~n", [Reason])
  12.     end.
复制代码
经过排查,原来是因为脚本执行完start/0函数时候,进程就结束了,socket的生存是跟归属进程一起的,所以,归属进程死了,socket也跟着死了,所以只要改变归属权就行了
  1. start() ->
  2.     Args = [binary, {packet, 4}, {reuseaddr, false}, {active, true}],
  3.     {ok, LSocket} = gen_tcp:listen(8088, Args),
  4.     Pid = spawn(fun() -> wait_client(LSocket) end),
  5.     gen_tcp:controlling_process(LSocket, Pid).

  6. wait_client(LSocket) ->
  7.     case gen_tcp:accept(LSocket) of
  8.         {ok, Socket} ->
  9.             Pid = spawn(fun() -> wait_client(LSocket) end),
  10.             gen_tcp:controlling_process(LSocket, Pid),               
  11.             loop(Socket);
  12.         {error, Reason} ->
  13.             io:format("error ~p~n", [Reason])
  14.     end.
复制代码







欢迎光临 Erlang中文论坛 (https://bbs.erldoc.com/) Powered by Discuz! X3.3