久久狠狠爱亚洲综合影院 ,久久久久免费精品国产,四虎国产精品成人免费久久

Erlang簡單并行服務(wù)器

Erlang簡單并行服務(wù)器

（金慶的專欄）

Erlang并行服務(wù)器為每個(gè)Tcp連接創(chuàng)建對應(yīng)的連接進(jìn)程，處理客戶端數(shù)據(jù)。

參考 Erlang程序設(shè)計(jì)（第2版）
17.1.3 順序和并行服務(wù)器

并行服務(wù)器的訣竅是：每當(dāng)gen_tcp:accept收到一個(gè)新連接時(shí)就立即分裂一個(gè)新進(jìn)程。
為每個(gè)新套接字連接創(chuàng)建一個(gè)并行進(jìn)程。

-module(gs_svr).
-author("jinqing").

-behaviour(gen_server).

%% API
-export([start_link/0]).

init([]) ->
    gs_listener:start_parallel(),
    {ok, #{}}.

gs_svr(GameServer gen_server)啟動Tcp監(jiān)聽，并維護(hù)連接，如連接計(jì)數(shù)，發(fā)送廣播。

start_parallel()創(chuàng)建監(jiān)聽端口，然后創(chuàng)建連接進(jìn)程。

start_parallel() ->
    Port = server_csv:get_my_port(),
    lager:info("Starting game server on port ~p...", [Port]),
    {ok, ListenSocket} = gen_tcp:listen(Port,
        [binary, {packet, 4},
            {packet_size, 256 * 1024}, % limit packet size
            {reuseaddr, true},
            {nodelay, true},
            {backlog, 999999},
            {active, once}]),
    connection:spawn_connection(ListenSocket).

spawn_connection()創(chuàng)建連接進(jìn)程。每接受一個(gè)連接就再創(chuàng)建一個(gè)新的連接進(jìn)程。

-module(connection).
-author("jinqing").

%% API
-export([spawn_connection/1]).
-export([parallel_connect/1, loop/2]).

-spec spawn_connection(ListenSocket :: gen_tcp:socket()) -> pid().
spawn_connection(ListenSocket) ->
    spawn(fun() -> ?MODULE:parallel_connect(ListenSocket) end).

-spec parallel_connect(ListenSocket :: gen_tcp:socket()) -> ok.
parallel_connect(ListenSocket) ->
    {ok, Socket} = gen_tcp:accept(ListenSocket),
    spawn_connection(ListenSocket),

    gs_svr:cast_connection_new(self()),
    ConnStat = conn_stat:new(),
    erlang:send_after(1000, self(), timer_sec),
    try ?MODULE:loop(Socket, ConnStat)
    catch
        Type:E -> lager:error("loop() ~p:~p. ~p",
            [Type, E, erlang:get_stacktrace()])
    end,
    gs_svr:cast_connection_ended(self()),
    ok.

-spec loop(Socket :: gen_tcp:socket(), ConnStat :: conn_stat:conn_stat()) -> any().
loop(Socket, ConnStat) ->
    receive
        {tcp, Socket, Bin} ->
            NewConnStat = rpc_handler:handle_bin(Socket, Bin, ConnStat),
            inet:setopts(Socket, [{active, once}]),
            NewConnStat2 = cutil_dos_checker:on_data(size(Bin), NewConnStat),
            ?MODULE:loop(Socket, NewConnStat2#{idle_sec=>0});
        {tcp_closed, Socket} ->
            save_on_end(ConnStat);
        {tcp_error, Socket, Reason} ->
            save_on_end(ConnStat);

        {gs_to_connection, Msg} ->
            NewConnStat = handle_gs_msg(Msg, Socket, ConnStat),
            ?MODULE:loop(Socket, NewConnStat);

        timer_sec ->
            case conn_timer:timer_sec(ConnStat) of
                {ok, NewConnStat} ->
                    erlang:send_after(1000, self(), timer_sec),
                    ?MODULE:loop(Socket, NewConnStat);
            end;
        Other ->
            lager:error("Unknown msg: ~p", [Other]),
            ?MODULE:loop(Socket, ConnStat)
    end. % This is tail-recursive.

缺點(diǎn)是連接進(jìn)程沒有加入監(jiān)控樹。gs_svr出錯(cuò)重啟時(shí)，連接進(jìn)程connection應(yīng)該斷開并退出。

posted on 2015-07-28 15:13 金慶閱讀(511) 評論(0) 編輯收藏引用所屬分類: 2. 網(wǎng)游開發(fā) 、7. Erlang

只有注冊用戶登錄后才能發(fā)表評論。
【推薦】100%開源！大型工業(yè)跨平臺軟件C++源碼提供，建模，組態(tài)！

相關(guān)文章: How are dtLinks created in NavMesh UE4 Blueprint Multiple Event BeginPlay 第9代游戲主機(jī) Canvas Scaler 的3種模式幀同步是否允許客戶端指定命令幀號 rpc應(yīng)答太快造成請求超時(shí) 測試 tolua 例子 TestErrorStack lua變量缺少local造成unity死鎖 C# tolua 之間互傳 byte[] Unity使用異步grpc

網(wǎng)站導(dǎo)航: 博客園 IT新聞 BlogJava 博問 Chat2DB 管理

金慶的專欄

公告

留言簿(12)

隨筆分類(502)

隨筆檔案(423)

相冊

搜索

積分與排名

最新評論

閱讀排行榜

評論排行榜