{"id":98,"date":"2014-12-07T16:33:05","date_gmt":"2014-12-07T08:33:05","guid":{"rendered":"http:\/\/www.zhuyanbin.com\/?p=98"},"modified":"2014-12-07T16:33:05","modified_gmt":"2014-12-07T08:33:05","slug":"%e5%9f%ba%e4%ba%8eerlang-otp%e6%9e%84%e5%bb%ba%e4%b8%80%e4%b8%aatcp%e6%9c%8d%e5%8a%a1%e5%99%a8","status":"publish","type":"post","link":"https:\/\/www.yanbin888.com\/?p=98","title":{"rendered":"\u57fa\u4e8eErlang OTP\u6784\u5efa\u4e00\u4e2aTCP\u670d\u52a1\u5668"},"content":{"rendered":"

\u5957\u63a5\u5b57\u6a21\u5f0f<\/strong><\/h2>\n

\u4e3b\u52a8\u6a21\u5f0f\uff08\u9009\u9879{active, true}\uff09\u4e00\u822c\u8ba9\u4eba\u5f88\u559c\u6b22\uff0c\u975e\u963b\u585e\u6d88\u606f\u63a5\u6536\uff0c\u4f46\u5728\u7cfb\u7edf\u65e0\u6cd5\u5e94\u5bf9\u8d85\u5927\u6d41\u91cf\u8bf7\u6c42\u65f6\uff0c\u5ba2\u6237\u7aef\u53d1\u9001\u7684\u6570\u636e\u5feb\u8fc7\u670d\u52a1\u5668\u53ef\u4ee5\u5904\u7406\u7684\u901f\u5ea6\uff0c\u90a3\u4e48\u7cfb\u7edf\u5c31\u53ef\u80fd\u4f1a\u9020\u6210\u6d88\u606f\u7f13\u51b2\u533a\u88ab\u585e\u6ee1\uff0c\u53ef\u80fd\u51fa\u73b0\u6301\u7eed\u7e41\u5fd9\u7684\u6d41\u91cf\u7684\u6781\u7aef\u60c5\u51b5\u4e0b\uff0c\u7cfb\u7edf\u56e0\u8bf7\u6c42\u800c\u6ea2\u51fa\uff0c\u865a\u62df\u673a\u9020\u6210\u5185\u5b58\u4e0d\u8db3\u7684\u98ce\u9669\u800c\u5d29\u6e83\u3002<\/p>\n

\u4f7f\u7528\u88ab\u52a8\u6a21\u5f0f\uff08\u9009\u9879{active, false}\uff09\u7684\u5957\u63a5\u5b57\uff0c\u5e95\u5c42\u7684TCP\u7f13\u51b2\u533a\u53ef\u7528\u4e8e\u6291\u5236\u8bf7\u6c42\uff0c\u5e76\u62d2\u7edd\u5ba2\u6237\u7aef\u7684\u6d88\u606f\uff0c\u5728\u63a5\u6536\u6570\u636e\u7684\u5730\u65b9\u90fd\u4f1a\u8c03\u7528gen_tcp:recv\uff0c\u9020\u6210\u963b\u585e\uff08\u5355\u8fdb\u7a0b\u6a21\u5f0f\u4e0b\u5c31\u53ea\u80fd\u6d88\u6781\u7b49\u5f85\u67d0\u4e00\u4e2a\u5177\u4f53\u7684\u5ba2\u6237\u7aef\u5957\u63a5\u5b57\uff0c\u5f88\u5371\u9669\uff09\u3002\u9700\u8981\u6ce8\u610f\u7684\u662f\uff0c\u64cd\u4f5c\u7cfb\u7edf\u53ef\u80fd\u8fd8\u4f1a\u505a\u4e00\u4e9b\u7f13\u5b58\u5141\u8bb8\u5ba2\u6237\u7aef\u673a\u5668\u7ee7\u7eed\u53d1\u9001\u5c11\u91cf\u6570\u636e\uff0c\u7136\u540e\u624d\u4f1a\u5c06\u5176\u963b\u585e\uff0c\u6b64\u65f6Erlang\u5c1a\u672a\u8c03\u7528recv\u51fd\u6570\u3002<\/p>\n

\u6df7\u5408\u578b\u6a21\u5f0f\uff08\u534a\u963b\u585e\uff09\uff0c\u4f7f\u7528\u9009\u9879{active, once}\u6253\u5f00\uff0c\u4e3b\u52a8\u4ec5\u9488\u5bf9\u4e00\u4e2a\u6d88\u606f\uff0c\u5728\u63a7\u5236\u8fdb\u7a0b\u53d1\u9001\u5b8c\u4e00\u4e2a\u6570\u636e\u6d88\u606f\u540e\uff0c\u5fc5\u987b\u663e\u793a\u8c03\u7528inet:setopts(Socket, [{active, once}])\u91cd\u65b0\u6fc0\u6d3b\u4ee5\u4fbf\u63a5\u53d7\u4e0b\u4e00\u4e2a\u6d88\u606f\uff08\u5728\u6b64\u4e4b\u524d\uff0c\u7cfb\u7edf\u5904\u4e8e\u963b\u585e\u72b6\u6001\uff09\u3002\u53ef\u89c1\uff0c\u6df7\u5408\u578b\u6a21\u5f0f\u7efc\u5408\u4e86\u4e3b\u52a8\u6a21\u5f0f\u548c\u88ab\u52a8\u6a21\u5f0f\u7684\u4e24\u8005\u4f18\u52bf\uff0c\u53ef\u5b9e\u73b0\u6d41\u91cf\u63a7\u5236\uff0c\u9632\u6b62\u670d\u52a1\u5668\u88ab\u8fc7\u591a\u6d88\u606f\u6df9\u6ca1\u3002<\/p>\n

\u4ee5\u4e0bTCP Server\u4ee3\u7801\uff0c\u90fd\u662f\u5efa\u7acb\u5728\u6df7\u5408\u578b\u6a21\u5f0f\uff08\u534a\u963b\u585e\uff09\u57fa\u7840\u4e0a\u3002<\/p>\n

prim_inet\u76f8\u5173\u8bf4\u660e<\/strong><\/h2>\n

prim_inet\u6ca1\u6709\u5b98\u65b9\u6587\u6863\uff0c\u53ef\u4ee5\u8ba4\u4e3a\u662f\u5bf9\u5e95\u5c42socket\u7684\u76f4\u63a5\u5305\u88c5\u3002\u6dd8\u5b9dyufeng<\/a>\u8bf4\uff0c\u8fd9\u662fotp\u5185\u90e8\u5b9e\u73b0\u7684\u7ec6\u8282 \u662f\u9488\u5bf9Erlang\u5e93\u5f00\u53d1\u8005\u7684private module\uff0c\u5e95\u5c42\u6a21\u5757\uff0c\u4e0d\u63a8\u8350\u4f7f\u7528\u3002\u4f46\u5728Building a Non-blocking TCP server using OTP principles<\/a>\u793a\u8303\u4e2d\u6f14\u793a\u4e86prim_inet\u64cd\u4f5cSocket\u5f02\u6b65\u7279\u6027\u3002<\/p>\n

\u8bbe\u8ba1\u6a21\u5f0f<\/strong><\/h2>\n

\u4e00\u822c\u6765\u8bf4\uff0c\u9700\u8981\u4e00\u4e2a\u5355\u72ec\u8fdb\u7a0b\u8fdb\u884c\u5ba2\u6237\u7aef\u5957\u63a5\u5b57\u76d1\u542c\uff0c\u6bcf\u4e00\u4e2a\u5b50\u8fdb\u7a0b\u8fdb\u884c\u5904\u7406\u6765\u81ea\u5177\u4f53\u5ba2\u6237\u7aef\u7684socket\u8bf7\u6c42\u3002<\/p>\n

\u5728Building a Non-blocking TCP server using OTP principles<\/a>\u793a\u8303\u4e2d\uff0c\u5b50\u8fdb\u7a0b\u4f7f\u7528gen_fsm\u5904\u7406\uff0c\u5f88\u5de7\u5999\u7684\u7ed3\u5408\u72b6\u6001\u673a\u548c\u6d88\u606f\u4e8b\u4ef6\uff0c\u503c\u5f97\u5b66\u4e60\u3002<\/p>\n

\u5728Erlang: A Generalized TCP Server<\/a>\u6587\u7ae0\u4e2d\uff0c\u4f5c\u8005\u4e5f\u662f\u4f7f\u7528\u6b64\u6a21\u5f0f\uff0c\u4f46\u5b50\u8fdb\u7a0b\u4e0d\u7b26\u5408OTP\u89c4\u8303\uff0c\u56e0\u6b64\u4e2a\u4eba\u8ba4\u4e3a\u4e0d\u662f\u4e00\u4e2a\u5f88\u597d\u7684\u5b9e\u8df5\u6a21\u5f0f\u3002<\/p>\n

simple_one_for_one<\/strong><\/h2>\n

\u7b80\u6613\u7684\u4e00\u5bf9\u4e00\u76d1\u7763\u8fdb\u7a0b\uff0c\u7528\u6765\u521b\u5efa\u4e00\u7ec4\u52a8\u6001\u5b50\u8fdb\u7a0b\u3002\u5bf9\u4e8e\u9700\u8981\u5e76\u53d1\u5904\u7406\u591a\u4e2a\u8bf7\u6c42\u7684\u670d\u52a1\u5668\u8f83\u4e3a\u5408\u9002\u3002\u6bd4\u5982socket \u670d\u52a1\u7aef\u63a5\u53d7\u65b0\u7684\u5ba2\u6237\u7aef\u8fde\u63a5\u8bf7\u6c42\u4ee5\u540e\uff0c\u9700\u8981\u52a8\u6001\u521b\u5efa\u4e00\u4e2a\u65b0\u7684socket\u8fde\u63a5\u5904\u7406\u5b50\u8fdb\u7a0b\u3002\u82e5\u9075\u5b88OTP\u539f\u5219\uff0c\u90a3\u5c31\u662f\u5b50\u76d1\u7763\u8fdb\u7a0b\u3002<\/p>\n

TCP Server\u5b9e\u73b0<\/strong><\/h2>\n

\u57fa\u4e8e\u6807\u51c6API\u7b80\u5355\u5b9e\u73b0<\/strong><\/h3>\n

\u4e5f\u662f\u57fa\u4e8e{active, once}\u6a21\u5f0f\uff0c\u4f46\u963b\u585e\u7684\u7b49\u5f85\u4e0b\u4e00\u4e2a\u5ba2\u6237\u7aef\u8fde\u63a5\u7684\u4efb\u52a1\u88ab\u629b\u7ed9\u4e86\u5b50\u76d1\u7763\u8fdb\u7a0b\u3002<\/p>\n

\u770b\u4e00\u4e0b\u5165\u53e3tcp_server_app\u5427<\/p>\n

\n
\n
\n
\n\n\n\n
<\/td>\n\n
–module<\/span>(tcp_server_app<\/span>).<\/div>\n
–author<\/span>(‘yongboy@gmail.com’<\/span>).<\/div>\n
–behaviour<\/span>(application<\/span>).<\/div>\n
–export<\/span>([start<\/span>\/2<\/span>, stop<\/span>\/1<\/span>]).<\/div>\n
–define<\/span>(DEF_PORT<\/span>, 2222<\/span>).<\/div>\n
<\/div>\n
start<\/span>(_Type<\/span>, _Args<\/span>) -><\/span><\/div>\n
Opts<\/span> =<\/span> [binary<\/span>, {packet<\/span>, 2<\/span>}, {reuseaddr<\/span>, true<\/span>},<\/div>\n
{keepalive<\/span>, true<\/span>}, {backlog<\/span>, 30<\/span>}, {active<\/span>, false<\/span>}],<\/div>\n
ListenPort<\/span> =<\/span> get_app_env<\/span>(listen_port<\/span>, ?<\/span>DEF_PORT<\/span>),<\/div>\n
{ok<\/span>, LSock<\/span>} =<\/span> gen_tcp<\/span>:listen<\/span>(ListenPort<\/span>, Opts<\/span>),<\/div>\n
case<\/span> tcp_server_sup<\/span>:start_link<\/span>(LSock<\/span>) of<\/span><\/div>\n
{ok<\/span>, Pid<\/span>} -><\/div>\n
tcp_server_sup<\/span>:start_child<\/span>(),<\/div>\n
{ok<\/span>, Pid<\/span>};<\/div>\n
Other<\/span> -><\/div>\n
{error<\/span>, Other<\/span>}<\/div>\n
end<\/span>.<\/div>\n
<\/div>\n
stop<\/span>(_S<\/span>) -><\/span><\/div>\n
ok<\/span>.<\/div>\n
<\/div>\n
get_app_env<\/span>(Opt<\/span>, Default<\/span>) -><\/span><\/div>\n
case<\/span> application<\/span>:get_env<\/span>(application<\/span>:get_application<\/span>(), Opt<\/span>) of<\/span><\/div>\n
{ok<\/span>, Val<\/span>} -> Val<\/span>;<\/div>\n
_<\/span> -><\/div>\n
case<\/span> init<\/span>:get_argument<\/span>(Opt<\/span>) of<\/span><\/div>\n
[[Val<\/span> | _<\/span>]] -> Val<\/span>;<\/div>\n
error<\/span> -> Default<\/span><\/div>\n
end<\/span><\/div>\n
end<\/span>.<\/div>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n
view raw<\/a>tcp_server_app.erl<\/a> hosted with \u2764 by GitHub<\/a><\/div>\n<\/div>\n<\/div>\n

\u8bfb\u53d6\u7aef\u53e3\uff0c\u7136\u540e\u542f\u52a8\u4e3b\u76d1\u7763\u8fdb\u7a0b\uff08\u6b64\u65f6\u8fd8\u4e0d\u4f1a\u76d1\u542c\u5904\u7406\u5ba2\u6237\u7aefsocket\u8bf7\u6c42\uff09\uff0c\u7d27\u63a5\u7740\u542f\u52a8\u5b50\u76d1\u7763\u8fdb\u7a0b\uff0c\u5f00\u59cb\u5904\u7406\u6765\u81ea\u5ba2\u6237\u7aef\u7684socket\u7684\u8fde\u63a5\u3002<\/p>\n

\u76d1\u7763\u8fdb\u7a0btcp_server_sup\u4e5f\u5f88\u7b80\u5355\uff1a<\/p>\n

\n
\n
\n
\n\n\n\n
<\/td>\n\n
–module<\/span>(tcp_server_sup<\/span>).<\/div>\n
–author<\/span>(‘yongboy@gmail.com’<\/span>).<\/div>\n
–behaviour<\/span>(supervisor<\/span>).<\/div>\n
–export<\/span>([start_link<\/span>\/1<\/span>, start_child<\/span>\/0<\/span>]).<\/div>\n
–export<\/span>([init<\/span>\/1<\/span>]).<\/div>\n
–define<\/span>(SERVER<\/span>, ?<\/span>MODULE<\/span>).<\/div>\n
<\/div>\n
start_link<\/span>(LSock<\/span>) -><\/span><\/div>\n
supervisor<\/span>:start_link<\/span>({local<\/span>, ?<\/span>SERVER<\/span>}, ?<\/span>MODULE<\/span>, [LSock<\/span>]).<\/div>\n
<\/div>\n
start_child<\/span>() -><\/span><\/div>\n
supervisor<\/span>:start_child<\/span>(?<\/span>SERVER<\/span>, []).<\/div>\n
<\/div>\n
init<\/span>([LSock<\/span>]) -><\/span><\/div>\n
Server<\/span> =<\/span> {tcp_server_handler<\/span>, {tcp_server_handler<\/span>, start_link<\/span>, [LSock<\/span>]},<\/div>\n
temporary<\/span>, brutal_kill<\/span>, worker<\/span>, [tcp_server_handler<\/span>]},<\/div>\n
Children<\/span> =<\/span> [Server<\/span>],<\/div>\n
RestartStrategy<\/span> =<\/span> {simple_one_for_one<\/span>, 0<\/span>, 1<\/span>},<\/div>\n
{ok<\/span>, {RestartStrategy<\/span>, Children<\/span>}}.<\/div>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n
view raw<\/a>tcp_server_sup.erl<\/a> hosted with \u2764 by GitHub<\/a><\/div>\n<\/div>\n<\/div>\n

\u9700\u8981\u6ce8\u610f\u7684\u662f\uff0c\u53ea\u6709\u8c03\u7528start_child\u51fd\u6570\u65f6\uff0c\u624d\u771f\u6b63\u8c03\u7528tcp_server_handler:start_link([LSock])\u51fd\u6570\u3002<\/p>\n

tcp_server_handler\u7684\u4ee3\u7801\u4e5f\u4e0d\u590d\u6742\uff1a<\/p>\n

\n
\n
\n
\n\n\n\n
<\/td>\n\n
–module<\/span>(tcp_server_handler<\/span>).<\/div>\n
–behaviour<\/span>(gen_server<\/span>).<\/div>\n
–export<\/span>([start_link<\/span>\/1<\/span>]).<\/div>\n
–export<\/span>([init<\/span>\/1<\/span>, handle_call<\/span>\/3<\/span>, handle_cast<\/span>\/2<\/span>, handle_info<\/span>\/2<\/span>,<\/div>\n
terminate<\/span>\/2<\/span>, code_change<\/span>\/3<\/span>]).<\/div>\n
–record<\/span>(state<\/span>, {lsock<\/span>, socket<\/span>, addr<\/span>}).<\/div>\n
<\/div>\n
start_link<\/span>(LSock<\/span>) -><\/span><\/div>\n
gen_server<\/span>:start_link<\/span>(?<\/span>MODULE<\/span>, [LSock<\/span>], []).<\/div>\n
<\/div>\n
init<\/span>([Socket<\/span>]) -><\/span><\/div>\n
inet<\/span>:setopts<\/span>(Socket<\/span>, [{active<\/span>, once<\/span>}, {packet<\/span>, 2<\/span>}, binary<\/span>]),<\/div>\n
{ok<\/span>, #<\/span>state<\/span>{lsock<\/span> =<\/span> Socket<\/span>}, 0<\/span>}.<\/div>\n
<\/div>\n
handle_call<\/span>(Msg<\/span>, _From<\/span>, State<\/span>) -><\/span><\/div>\n
{reply<\/span>, {ok<\/span>, Msg<\/span>}, State<\/span>}.<\/div>\n
<\/div>\n
handle_cast<\/span>(stop<\/span>, State<\/span>) -><\/span><\/div>\n
{stop<\/span>, normal<\/span>, State<\/span>}.<\/div>\n
<\/div>\n
handle_info<\/span>({tcp<\/span>, Socket<\/span>, Data<\/span>}, State<\/span>) -><\/span><\/div>\n
inet<\/span>:setopts<\/span>(Socket<\/span>, [{active<\/span>, once<\/span>}]),<\/div>\n
io<\/span>:format<\/span>(“<\/span>~p<\/span> got message ~p<\/span>\\n<\/span>“<\/span><\/span>, [self<\/span>(), Data<\/span>]),<\/div>\n
ok<\/span> =<\/span> gen_tcp<\/span>:send<\/span>(Socket<\/span>, <<“<\/span>Echo back : “<\/span><\/span>, Data<\/span>\/binary<\/span>>>),<\/div>\n
{noreply<\/span>, State<\/span>};<\/div>\n
<\/div>\n
handle_info<\/span>({tcp_closed<\/span>, Socket<\/span>}, #<\/span>state<\/span>{addr<\/span>=<\/span>Addr<\/span>} =<\/span> StateData<\/span>) -><\/span><\/div>\n
error_logger<\/span>:info_msg<\/span>(“<\/span>~p<\/span> Client ~p<\/span> disconnected.\\n<\/span>“<\/span><\/span>, [self<\/span>(), Addr<\/span>]),<\/div>\n
{stop<\/span>, normal<\/span>, StateData<\/span>};<\/div>\n
<\/div>\n
handle_info<\/span>(timeout<\/span>, #<\/span>state<\/span>{lsock<\/span> =<\/span> LSock<\/span>} =<\/span> State<\/span>) -><\/span><\/div>\n
{ok<\/span>, ClientSocket<\/span>} =<\/span> gen_tcp<\/span>:accept<\/span>(LSock<\/span>),<\/div>\n
{ok<\/span>, {IP<\/span>, _Port<\/span>}} =<\/span> inet<\/span>:peername<\/span>(ClientSocket<\/span>),<\/div>\n
tcp_server_sup<\/span>:start_child<\/span>(),<\/div>\n
{noreply<\/span>, State<\/span>#<\/span>state<\/span>{socket<\/span>=<\/span>ClientSocket<\/span>, addr<\/span>=<\/span>IP<\/span>}};<\/div>\n
<\/div>\n
handle_info<\/span>(_Info<\/span>, StateData<\/span>) -><\/span><\/div>\n
{noreply<\/span>, StateData<\/span>}.<\/div>\n
<\/div>\n
terminate<\/span>(_Reason<\/span>, #<\/span>state<\/span>{socket<\/span>=<\/span>Socket<\/span>}) -><\/span><\/div>\n
(catch<\/span> gen_tcp<\/span>:close<\/span>(Socket<\/span>)),<\/div>\n
ok<\/span>.<\/div>\n
<\/div>\n
code_change<\/span>(_OldVsn<\/span>, State<\/span>, _Extra<\/span>) -><\/span><\/div>\n
{ok<\/span>, State<\/span>}.<\/div>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n
view raw<\/a>tcp_server_handler.erl<\/a> hosted with \u2764 by GitHub<\/a><\/div>\n<\/div>\n<\/div>\n

\u4ee3\u7801\u5f88\u7cbe\u5de7\uff0c\u6709\u4e9b\u5c0f\u6280\u5de7\u5728\u91cc\u9762\u3002\u5b50\u76d1\u7763\u8fdb\u7a0b\u8c03\u7528start_link\u51fd\u6570\uff0cinit\u4f1a\u8fd4\u56de{ok, #state{lsock = Socket}, 0}. \u6570\u5b570\u4ee3\u8868\u4e86timeout\u6570\u503c\uff0c\u610f\u5473\u7740gen_server\u9a6c\u4e0a\u8c03\u7528handle_info(timeout, #state{lsock = LSock} = State)\u51fd\u6570\uff0c\u6267\u884c\u5ba2\u6237\u7aefsocket\u76d1\u542c\uff0c\u963b\u585e\u4e8e\u6b64\uff0c\u4f46\u4e0d\u4f1a\u5f71\u54cd\u5728\u6b64\u6a21\u5f0f\u4e0b\u5176\u5b83\u51fd\u6570\u7684\u8c03\u7528\u3002\u76f4\u5230\u6709\u5ba2\u6237\u7aef\u8fdb\u6765\uff0c\u7136\u540e\u542f\u52a8\u4e00\u4e2a\u65b0\u7684\u5b50\u76d1\u7763\u8fdb\u7a0btcp_server_handler\uff0c\u5f53\u524d\u5b50\u76d1\u7763\u8fdb\u7a0b\u89e3\u9664\u963b\u585e\u3002<\/p>\n

 <\/p>\n

\u57fa\u4e8eprim_inet\u5b9e\u73b0<\/strong><\/h3>\n

\u8fd9\u4e2a\u5b9e\u73b0\u5e08\u4ece\u4e8eNon-blocking TCP server using OTP principles\u4e00\u6587\uff0c\u4f46\u5b50\u8fdb\u7a0b\u6539\u4e3a\u4e86gen_server\u5b9e\u73b0\u3002<\/p>\n

\u770b\u4e00\u770b\u5165\u53e3\uff0c\u5f88\u7b80\u5355\u7684\uff1a<\/p>\n

\n
\n
\n
\n\n\n\n
<\/td>\n\n
–module<\/span>(tcp_server_app<\/span>).<\/div>\n
–author<\/span>(‘yongboy@gmail.com’<\/span>).<\/div>\n
–behaviour<\/span>(application<\/span>).<\/div>\n
–export<\/span>([start_client<\/span>\/1<\/span>]).<\/div>\n
–export<\/span>([start<\/span>\/2<\/span>, stop<\/span>\/1<\/span>]).<\/div>\n
–define<\/span>(DEF_PORT<\/span>, 2222<\/span>).<\/div>\n
<\/div>\n
%% A startup function for spawning new client connection handling FSM.<\/span><\/div>\n
%% To be called by the TCP listener process.<\/span><\/div>\n
start_client<\/span>(Socket<\/span>) -><\/span><\/div>\n
tcp_server_sup<\/span>:start_child<\/span>(Socket<\/span>).<\/div>\n
<\/div>\n
start<\/span>(_Type<\/span>, _Args<\/span>) -><\/span><\/div>\n
ListenPort<\/span> =<\/span> get_app_env<\/span>(listen_port<\/span>, ?<\/span>DEF_PORT<\/span>),<\/div>\n
tcp_server_sup<\/span>:start_link<\/span>(ListenPort<\/span>, tcp_client_handler<\/span>).<\/div>\n
<\/div>\n
stop<\/span>(_S<\/span>) -><\/span><\/div>\n
ok<\/span>.<\/div>\n
<\/div>\n
get_app_env<\/span>(Opt<\/span>, Default<\/span>) -><\/span><\/div>\n
case<\/span> application<\/span>:get_env<\/span>(application<\/span>:get_application<\/span>(), Opt<\/span>) of<\/span><\/div>\n
{ok<\/span>, Val<\/span>} -> Val<\/span>;<\/div>\n
_<\/span> -><\/div>\n
case<\/span> init<\/span>:get_argument<\/span>(Opt<\/span>) of<\/span><\/div>\n
[[Val<\/span> | _<\/span>]] -> Val<\/span>;<\/div>\n
error<\/span> -> Default<\/span><\/div>\n
end<\/span><\/div>\n
end<\/span>.<\/div>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n
view raw<\/a>tcp_server_app.erl<\/a> hosted with \u2764 by GitHub<\/a><\/div>\n<\/div>\n<\/div>\n

\u76d1\u7763\u8fdb\u7a0b\u4ee3\u7801\uff1a<\/p>\n

\n
\n
\n
\n\n\n\n
<\/td>\n\n
–module<\/span>(tcp_server_sup<\/span>).<\/div>\n
–author<\/span>(‘yongboy@gmail.com’<\/span>).<\/div>\n
–behaviour<\/span>(supervisor<\/span>).<\/div>\n
–export<\/span>([start_child<\/span>\/1<\/span>, start_link<\/span>\/2<\/span>, init<\/span>\/1<\/span>]).<\/div>\n
–define<\/span>(SERVER<\/span>, ?<\/span>MODULE<\/span>).<\/div>\n
–define<\/span>(CLIENT_SUP<\/span>, tcp_client_sup<\/span>).<\/div>\n
–define<\/span>(MAX_RESTART<\/span>, 5<\/span>).<\/div>\n
–define<\/span>(MAX_TIME<\/span>, 60<\/span>).<\/div>\n
<\/div>\n
start_child<\/span>(Socket<\/span>) -><\/span><\/div>\n
supervisor<\/span>:start_child<\/span>(?<\/span>CLIENT_SUP<\/span>, [Socket<\/span>]).<\/div>\n
<\/div>\n
start_link<\/span>(ListenPort<\/span>, HandleMoudle<\/span>) -><\/span><\/div>\n
supervisor<\/span>:start_link<\/span>({local<\/span>, ?<\/span>SERVER<\/span>}, ?<\/span>MODULE<\/span>, [ListenPort<\/span>, HandleMoudle<\/span>]).<\/div>\n
<\/div>\n
init<\/span>([Port<\/span>, Module<\/span>]) -><\/span><\/div>\n
TcpListener<\/span> =<\/span> {tcp_server_sup<\/span>, % Id = internal id<\/span><\/div>\n
{tcp_listener<\/span>, start_link<\/span>, [Port<\/span>, Module<\/span>]}, % StartFun = {M, F, A}<\/span><\/div>\n
permanent<\/span>, % Restart = permanent | transient | temporary<\/span><\/div>\n
2000<\/span>, % Shutdown = brutal_kill | int() >= 0 | infinity<\/span><\/div>\n
worker<\/span>, % Type = worker | supervisor<\/span><\/div>\n
[tcp_listener<\/span>] % Modules = [Module] | dynamic<\/span><\/div>\n
},<\/div>\n
TcpClientSupervisor<\/span> =<\/span> {?<\/span>CLIENT_SUP<\/span>,<\/div>\n
{supervisor<\/span>, start_link<\/span>, [{local<\/span>, ?<\/span>CLIENT_SUP<\/span>}, ?<\/span>MODULE<\/span>, [Module<\/span>]]},<\/div>\n
permanent<\/span>,<\/div>\n
infinity<\/span>,<\/div>\n
supervisor<\/span>,<\/div>\n
[]<\/div>\n
},<\/div>\n
{ok<\/span>,<\/div>\n
{{one_for_one<\/span>, ?<\/span>MAX_RESTART<\/span>, ?<\/span>MAX_TIME<\/span>},<\/div>\n
[TcpListener<\/span>, TcpClientSupervisor<\/span>]<\/div>\n
}<\/div>\n
};<\/div>\n
<\/div>\n
init<\/span>([Module<\/span>]) -><\/span><\/div>\n
{ok<\/span>,<\/div>\n
{_SupFlags<\/span> =<\/span> {simple_one_for_one<\/span>, ?<\/span>MAX_RESTART<\/span>, ?<\/span>MAX_TIME<\/span>},<\/div>\n
[<\/div>\n
% TCP Client<\/span><\/div>\n
{ undefined<\/span>, % Id = internal id<\/span><\/div>\n
{Module<\/span>, start_link<\/span>, []}, % StartFun = {M, F, A}<\/span><\/div>\n
temporary<\/span>, % Restart = permanent | transient | temporary<\/span><\/div>\n
2000<\/span>, % Shutdown = brutal_kill | int() >= 0 | infinity<\/span><\/div>\n
worker<\/span>, % Type = worker | supervisor<\/span><\/div>\n
[] % Modules = [Module] | dynamic<\/span><\/div>\n
}<\/div>\n
]<\/div>\n
}<\/div>\n
}.<\/div>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n
view raw<\/a>tcp_server_sup.erl<\/a> hosted with \u2764 by GitHub<\/a><\/div>\n<\/div>\n<\/div>\n

\u7b56\u7565\u4e0d\u4e00\u6837\uff0cone_for_one\u5305\u62ec\u4e86\u4e00\u4e2a\u76d1\u542c\u8fdb\u7a0btcp_listener\uff0c\u8fd8\u5305\u542b\u4e86\u4e00\u4e2atcp_client_sup\u8fdb\u7a0b\u6811(simple_one_for_one\u7b56\u7565)<\/p>\n

tcp_listener\u5355\u72ec\u4e00\u4e2a\u8fdb\u7a0b\u7528\u4e8e\u76d1\u542c\u6765\u81ea\u5ba2\u6237\u7aefsocket\u7684\u8fde\u63a5:<\/p>\n

\n
\n
\n
\n\n\n\n
<\/td>\n\n
–module<\/span>(tcp_listener<\/span>).<\/div>\n
–author<\/span>(‘saleyn@gmail.com’<\/span>).<\/div>\n
–behaviour<\/span>(gen_server<\/span>).<\/div>\n
–export<\/span>([start_link<\/span>\/2<\/span>]).<\/div>\n
–export<\/span>([init<\/span>\/1<\/span>, handle_call<\/span>\/3<\/span>, handle_cast<\/span>\/2<\/span>, handle_info<\/span>\/2<\/span>, terminate<\/span>\/2<\/span>,<\/div>\n
code_change<\/span>\/3<\/span>]).<\/div>\n
<\/div>\n
–record<\/span>(state<\/span>, {<\/div>\n
listener<\/span>, % Listening socket<\/span><\/div>\n
acceptor<\/span>, % Asynchronous acceptor’s internal reference<\/span><\/div>\n
module<\/span> % FSM handling module<\/span><\/div>\n
}).<\/div>\n
<\/div>\n
start_link<\/span>(Port<\/span>, Module<\/span>) when<\/span> is_integer<\/span>(Port<\/span>), is_atom<\/span>(Module<\/span>) -><\/span><\/div>\n
gen_server<\/span>:start_link<\/span>({local<\/span>, ?<\/span>MODULE<\/span>}, ?<\/span>MODULE<\/span>, [Port<\/span>, Module<\/span>], []).<\/div>\n
<\/div>\n
init<\/span>([Port<\/span>, Module<\/span>]) -><\/span><\/div>\n
process_flag<\/span>(trap_exit<\/span>, true<\/span>),<\/div>\n
Opts<\/span> =<\/span> [binary<\/span>, {packet<\/span>, 2<\/span>}, {reuseaddr<\/span>, true<\/span>},<\/div>\n
{keepalive<\/span>, true<\/span>}, {backlog<\/span>, 30<\/span>}, {active<\/span>, false<\/span>}],<\/div>\n
case<\/span> gen_tcp<\/span>:listen<\/span>(Port<\/span>, Opts<\/span>) of<\/span><\/div>\n
{ok<\/span>, Listen_socket<\/span>} -><\/div>\n
%%Create first accepting process<\/span><\/div>\n
{ok<\/span>, Ref<\/span>} =<\/span> prim_inet<\/span>:async_accept<\/span>(Listen_socket<\/span>, –<\/span>1<\/span>),<\/div>\n
{ok<\/span>, #<\/span>state<\/span>{listener<\/span> =<\/span> Listen_socket<\/span>,<\/div>\n
acceptor<\/span> =<\/span> Ref<\/span>,<\/div>\n
module<\/span> =<\/span> Module<\/span>}};<\/div>\n
{error<\/span>, Reason<\/span>} -><\/div>\n
{stop<\/span>, Reason<\/span>}<\/div>\n
end<\/span>.<\/div>\n
<\/div>\n
handle_call<\/span>(Request<\/span>, _From<\/span>, State<\/span>) -><\/span><\/div>\n
{stop<\/span>, {unknown_call<\/span>, Request<\/span>}, State<\/span>}.<\/div>\n
<\/div>\n
handle_cast<\/span>(_Msg<\/span>, State<\/span>) -><\/span><\/div>\n
{noreply<\/span>, State<\/span>}.<\/div>\n
<\/div>\n
handle_info<\/span>({inet_async<\/span>, ListSock<\/span>, Ref<\/span>, {ok<\/span>, CliSocket<\/span>}},<\/div>\n
#<\/span>state<\/span>{listener<\/span>=<\/span>ListSock<\/span>, acceptor<\/span>=<\/span>Ref<\/span>, module<\/span>=<\/span>Module<\/span>} =<\/span> State<\/span>) -><\/span><\/div>\n
try<\/span><\/div>\n
case<\/span> set_sockopt<\/span>(ListSock<\/span>, CliSocket<\/span>) of<\/span><\/div>\n
ok<\/span> -> ok<\/span>;<\/div>\n
{error<\/span>, Reason<\/span>} -> exit<\/span>({set_sockopt<\/span>, Reason<\/span>})<\/div>\n
end<\/span>,<\/div>\n
<\/div>\n
%% New client connected – spawn a new process using the simple_one_for_one<\/span><\/div>\n
%% supervisor.<\/span><\/div>\n
{ok<\/span>, Pid<\/span>} =<\/span> tcp_server_app<\/span>:start_client<\/span>(CliSocket<\/span>),<\/div>\n
gen_tcp<\/span>:controlling_process<\/span>(CliSocket<\/span>, Pid<\/span>),<\/div>\n
<\/div>\n
%% Signal the network driver that we are ready to accept another connection<\/span><\/div>\n
case<\/span> prim_inet<\/span>:async_accept<\/span>(ListSock<\/span>, –<\/span>1<\/span>) of<\/span><\/div>\n
{ok<\/span>, NewRef<\/span>} -> ok<\/span>;<\/div>\n
{error<\/span>, NewRef<\/span>} -> exit<\/span>({async_accept<\/span>, inet<\/span>:format_error<\/span>(NewRef<\/span>)})<\/div>\n
end<\/span>,<\/div>\n
<\/div>\n
{noreply<\/span>, State<\/span>#<\/span>state<\/span>{acceptor<\/span>=<\/span>NewRef<\/span>}}<\/div>\n
catch<\/span> exit<\/span>:Why<\/span> -><\/div>\n
error_logger<\/span>:error_msg<\/span>(“<\/span>Error in async accept: ~p<\/span>.\\n<\/span>“<\/span><\/span>, [Why<\/span>]),<\/div>\n
{stop<\/span>, Why<\/span>, State<\/span>}<\/div>\n
end<\/span>;<\/div>\n
<\/div>\n
handle_info<\/span>({inet_async<\/span>, ListSock<\/span>, Ref<\/span>, Error<\/span>}, #<\/span>state<\/span>{listener<\/span>=<\/span>ListSock<\/span>, acceptor<\/span>=<\/span>Ref<\/span>} =<\/span> State<\/span>) -><\/span><\/div>\n
error_logger<\/span>:error_msg<\/span>(“<\/span>Error in socket acceptor: ~p<\/span>.\\n<\/span>“<\/span><\/span>, [Error<\/span>]),<\/div>\n
{stop<\/span>, Error<\/span>, State<\/span>};<\/div>\n
<\/div>\n
handle_info<\/span>(_Info<\/span>, State<\/span>) -><\/span><\/div>\n
{noreply<\/span>, State<\/span>}.<\/div>\n
<\/div>\n
terminate<\/span>(_Reason<\/span>, State<\/span>) -><\/span><\/div>\n
gen_tcp<\/span>:close<\/span>(State<\/span>#<\/span>state<\/span>.listener<\/span>),<\/div>\n
ok<\/span>.<\/div>\n
<\/div>\n
code_change<\/span>(_OldVsn<\/span>, State<\/span>, _Extra<\/span>) -><\/span><\/div>\n
{ok<\/span>, State<\/span>}.<\/div>\n
<\/div>\n
%% Taken from prim_inet. We are merely copying some socket options from the<\/span><\/div>\n
%% listening socket to the new client socket.<\/span><\/div>\n
set_sockopt<\/span>(ListSock<\/span>, CliSocket<\/span>) -><\/span><\/div>\n
true<\/span> =<\/span> inet_db<\/span>:register_socket<\/span>(CliSocket<\/span>, inet_tcp<\/span>),<\/div>\n
case<\/span> prim_inet<\/span>:getopts<\/span>(ListSock<\/span>, [active<\/span>, nodelay<\/span>, keepalive<\/span>, delay_send<\/span>, priority<\/span>, tos<\/span>]) of<\/span><\/div>\n
{ok<\/span>, Opts<\/span>} -><\/div>\n
case<\/span> prim_inet<\/span>:setopts<\/span>(CliSocket<\/span>, Opts<\/span>) of<\/span><\/div>\n
ok<\/span> -> ok<\/span>;<\/div>\n
Error<\/span> -> gen_tcp<\/span>:close<\/span>(CliSocket<\/span>), Error<\/span><\/div>\n
end<\/span>;<\/div>\n
Error<\/span> -><\/div>\n
gen_tcp<\/span>:close<\/span>(CliSocket<\/span>), Error<\/span><\/div>\n
end<\/span>.<\/div>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n
view raw<\/a>tcp_listener.erl<\/a> hosted with \u2764 by GitHub<\/a><\/div>\n<\/div>\n<\/div>\n

\u5f88\u663e\u7136\uff0c\u63a5\u6536\u5ba2\u6237\u7aef\u7684\u8fde\u63a5\u4e4b\u540e\uff0c\u8f6c\u4ea4\u7ed9tcp_client_handler\u6a21\u5757\u8fdb\u884c\u5904\u7406\uff1a<\/p>\n

\n
\n
\n
\n\n\n\n
<\/td>\n\n
–module<\/span>(tcp_client_handler<\/span>).<\/div>\n
–behaviour<\/span>(gen_server<\/span>).<\/div>\n
–export<\/span>([start_link<\/span>\/1<\/span>]).<\/div>\n
–export<\/span>([init<\/span>\/1<\/span>, handle_call<\/span>\/3<\/span>, handle_cast<\/span>\/2<\/span>, handle_info<\/span>\/2<\/span>, terminate<\/span>\/2<\/span>, code_change<\/span>\/3<\/span>]).<\/div>\n
–record<\/span>(state<\/span>, {socket<\/span>, addr<\/span>}).<\/div>\n
–define<\/span>(TIMEOUT<\/span>, 120000<\/span>).<\/div>\n
<\/div>\n
start_link<\/span>(Socket<\/span>) -><\/span><\/div>\n
gen_server<\/span>:start_link<\/span>(?<\/span>MODULE<\/span>, [Socket<\/span>], []).<\/div>\n
<\/div>\n
init<\/span>([Socket<\/span>]) -><\/span><\/div>\n
inet<\/span>:setopts<\/span>(Socket<\/span>, [{active<\/span>, once<\/span>}, {packet<\/span>, 2<\/span>}, binary<\/span>]),<\/div>\n
{ok<\/span>, {IP<\/span>, _Port<\/span>}} =<\/span> inet<\/span>:peername<\/span>(Socket<\/span>),<\/div>\n
{ok<\/span>, #<\/span>state<\/span>{socket<\/span>=<\/span>Socket<\/span>, addr<\/span>=<\/span>IP<\/span>}}.<\/div>\n
<\/div>\n
handle_call<\/span>(Request<\/span>, From<\/span>, State<\/span>) -><\/span><\/div>\n
{noreply<\/span>, ok<\/span>, State<\/span>}.<\/div>\n
<\/div>\n
handle_cast<\/span>(Msg<\/span>, State<\/span>) -><\/span><\/div>\n
{noreply<\/span>, State<\/span>}.<\/div>\n
<\/div>\n
handle_info<\/span>({tcp<\/span>, Socket<\/span>, Data<\/span>}, State<\/span>) -><\/span><\/div>\n
inet<\/span>:setopts<\/span>(Socket<\/span>, [{active<\/span>, once<\/span>}]),<\/div>\n
io<\/span>:format<\/span>(“<\/span>~p<\/span> got message ~p<\/span>\\n<\/span>“<\/span><\/span>, [self<\/span>(), Data<\/span>]),<\/div>\n
ok<\/span> =<\/span> gen_tcp<\/span>:send<\/span>(Socket<\/span>, <<“<\/span>Echo back : “<\/span><\/span>, Data<\/span>\/binary<\/span>>>),<\/div>\n
{noreply<\/span>, State<\/span>};<\/div>\n
<\/div>\n
handle_info<\/span>({tcp_closed<\/span>, Socket<\/span>}, #<\/span>state<\/span>{addr<\/span>=<\/span>Addr<\/span>} =<\/span> StateData<\/span>) -><\/span><\/div>\n
error_logger<\/span>:info_msg<\/span>(“<\/span>~p<\/span> Client ~p<\/span> disconnected.\\n<\/span>“<\/span><\/span>, [self<\/span>(), Addr<\/span>]),<\/div>\n
{stop<\/span>, normal<\/span>, StateData<\/span>};<\/div>\n
<\/div>\n
handle_info<\/span>(_Info<\/span>, StateData<\/span>) -><\/span><\/div>\n
{noreply<\/span>, StateData<\/span>}.<\/div>\n
<\/div>\n
terminate<\/span>(_Reason<\/span>, #<\/span>state<\/span>{socket<\/span>=<\/span>Socket<\/span>}) -><\/span><\/div>\n
(catch<\/span> gen_tcp<\/span>:close<\/span>(Socket<\/span>)),<\/div>\n
ok<\/span>.<\/div>\n
<\/div>\n
code_change<\/span>(OldVsn<\/span>, State<\/span>, Extra<\/span>) -><\/span><\/div>\n
{ok<\/span>, State<\/span>}.<\/div>\n<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<\/div>\n<\/div>\n
view raw<\/a>tcp_client_handler.erl<\/a> hosted with \u2764 by GitHub<\/a><\/div>\n<\/div>\n<\/div>\n

\u548c\u6807\u51c6API\u5bf9\u6bd4\u4e00\u4e0b\uff0c\u53ef\u4ee5\u611f\u53d7\u5230\u5f02\u6b65IO\u7684\u597d\u5904\u3002<\/p>\n

\u5c0f\u7ed3<\/strong><\/h2>\n

\u901a\u8fc7\u4e0d\u540c\u7684\u6a21\u5f0f\uff0c\u7b80\u5355\u5b9e\u73b0\u4e00\u4e2a\u57fa\u4e8eErlang OTP\u7684TCP\u670d\u52a1\u5668\uff0c\u4e5f\u662f\u5b66\u4e60\u603b\u7ed3\uff0c\u4e0d\u81f3\u4e8e\u5fd8\u8bb0\u3002<\/p>\n

\u60a8\u82e5\u6709\u66f4\u597d\u7684\u5efa\u8bae\uff0c\u6b22\u8fce\u544a\u77e5\uff0c\u8c22\u8c22\u3002<\/p>\n

link:\u00a0http:\/\/www.blogjava.net\/yongboy\/archive\/2012\/10\/24\/390185.html<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"

\u5957\u63a5\u5b57\u6a21\u5f0f \u4e3b\u52a8\u6a21\u5f0f\uff08\u9009\u9879{active, true}\uff09\u4e00\u822c\u8ba9\u4eba\u5f88\u559c\u6b22\uff0c\u975e\u963b\u585e\u6d88\u606f\u63a5\u6536\uff0c\u4f46\u5728\u7cfb\u7edf\u65e0\u6cd5\u5e94\u5bf9\u8d85\u5927\u6d41 …<\/span> Read More →<\/span><\/a><\/span><\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[16],"tags":[27],"class_list":["post-98","post","type-post","status-publish","format-standard","hentry","category-erlang","tag-erlang"],"_links":{"self":[{"href":"https:\/\/www.yanbin888.com\/index.php?rest_route=\/wp\/v2\/posts\/98","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.yanbin888.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.yanbin888.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.yanbin888.com\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.yanbin888.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=98"}],"version-history":[{"count":2,"href":"https:\/\/www.yanbin888.com\/index.php?rest_route=\/wp\/v2\/posts\/98\/revisions"}],"predecessor-version":[{"id":100,"href":"https:\/\/www.yanbin888.com\/index.php?rest_route=\/wp\/v2\/posts\/98\/revisions\/100"}],"wp:attachment":[{"href":"https:\/\/www.yanbin888.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=98"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.yanbin888.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=98"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.yanbin888.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=98"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}