亚洲激精日韩激精欧美精品,亚洲激情校园春色,一区二区三区日韩欧美

區(qū)服節(jié)點(diǎn)互連

區(qū)服節(jié)點(diǎn)互連
(金慶的專欄)

【上海龍圖招聘】

所有Erlang服務(wù)器節(jié)點(diǎn)加入同一集群，使用相同的cookie。
使用BIF erlang:set_cookie(node(), C)把本地節(jié)點(diǎn)的cookie設(shè)置為原子C。

1個(gè)或多個(gè)節(jié)點(diǎn)配置為主節(jié)點(diǎn)（主服務(wù)器）。
主節(jié)點(diǎn)不必全部啟動，但要求至少啟動1個(gè)。
主節(jié)點(diǎn)配置可熱更新即時(shí)生效。
主節(jié)點(diǎn)啟動后，主動連接所有未連接的主節(jié)點(diǎn)，每隔5s嘗試連接。
其他節(jié)點(diǎn)，如新開區(qū)服，僅需連接主節(jié)點(diǎn)。
所有主節(jié)點(diǎn)和其他節(jié)點(diǎn)最終全互連。

僅需配置主服務(wù)器內(nèi)網(wǎng)地址，利用net_adm:world_list([Host])連接所有節(jié)點(diǎn)。
客戶端僅需配置數(shù)個(gè)主服務(wù)器的地址，連上某個(gè)主服后即可查詢所有服務(wù)器的地址與負(fù)載。
客戶端一般會記錄后最連接的服務(wù)器，用于角色重登，同樣也可查詢服務(wù)器列表。

ping_main_hosts() ->
    MainHosts = config_main_hosts:get(),
    Nodes = net_adm:world_list(MainHosts),
    lager:debug("Ping main hosts: ~p. Result nodes: ~p", [MainHosts, Nodes]),
    ok.

18:34:45.023 [debug] Ping main hosts: ['127.0.0.1']. Result nodes: []
18:34:50.029 [debug] Ping main hosts: ['127.0.0.1']. Result nodes: []
Reloading config_main_hosts ... ok.
18:34:55.272 [debug] Ping main hosts: ['192.168.8.9','127.0.0.1']. Result nodes: ['s3@192.168.8.9']
18:35:00.057 [debug] Ping main hosts: ['192.168.8.9','127.0.0.1']. Result nodes: ['s3@192.168.8.9']

cluster_svr 處理集群互連。

%%%-------------------------------------------------------------------
%%% @author jinqing
%%% @copyright (C) 2015, <COMPANY>
%%% @doc 集群互連服務(wù)器。
%%%      處理集群互連。廣播自身節(jié)點(diǎn)狀態(tài)，接收其他節(jié)點(diǎn)狀態(tài)。
%%% @end
%%% Created : 23. 四月 2015 12:12
%%%-------------------------------------------------------------------
-module(cluster_svr).
-author("jinqing").

-behaviour(gen_server).

...
-type state() :: #{nodes => [node()]}.
-type server_info() :: #{host_cfg => config_gateway:host_cfg(),
                         current_load => integer()}.
-export_type([server_info/0]).
...
init([]) ->
    init_ets(),
    init_timer(),
    {ok, #{}}.

...
handle_info(timer_ping, State) ->
    NewState = timer_ping(State),
    {noreply, NewState};

handle_info(timer_bcast_info, State) ->
    timer_bcast_info(),
    {noreply, State};

handle_info({server_info, ServerId, ServerInfo}, State)
    when is_integer(ServerId), is_map(ServerInfo) ->
    lager:debug("~p Server~p info: ~p", [self(), ServerId, ServerInfo]),
    ets:insert(ets_server, {ServerId, ServerInfo}),
    {noreply, State};

...
init_timer() ->
    % 啟動時(shí)短時(shí)間內(nèi)Ping多次，接著每隔10s定時(shí)Ping.
    {ok, _} = timer:send_after(200, self(), timer_ping),
    {ok, _} = timer:send_after(1000, self(), timer_ping),
    {ok, _} = timer:send_interval(10000, self(), timer_ping),

    {ok, _} = timer:send_after(2000, self(), timer_bcast_info),
    {ok, _} = timer:send_after(5000, self(), timer_bcast_info),
    {ok, _} = timer:send_interval(31000, self(), timer_bcast_info),
    ok.

init_ets() ->
    ets:new(ets_server, [named_table]), % 區(qū)服列表
    ok.

-spec timer_ping(State :: state()) -> state().
timer_ping(State) ->
    % lager:debug("timer_ping"),
    spawn(cluster_ping, ping_main_hosts, []),
    PrevNodes = maps:get(nodes, State, []),
    Nodes = nodes(),
    case (Nodes =:= PrevNodes) of
        true -> State;
        _ ->
            % 如果有節(jié)點(diǎn)更新，就打印節(jié)點(diǎn)列表。
            AllNodes = [node() | Nodes],
            lager:info("All nodes: ~p", [AllNodes]),
            State#{nodes => Nodes}
    end.

timer_bcast_info() ->
    % lager:debug("timer_bcast_info"),
    ServerId = six_util:get_server_id(),
    ServerInfo = cluster_server_info:get(ServerId),
    rpc:abcast(nodes(), ?MODULE, {server_info, ServerId, ServerInfo}),
    ok.

【上海龍圖招聘】

posted on 2015-05-11 10:37 金慶閱讀(531) 評論(0) 編輯收藏引用

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



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

青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品

金慶的專欄

公告

留言簿(12)

隨筆分類(502)

隨筆檔案(423)

相冊

搜索

積分與排名

最新評論

閱讀排行榜

評論排行榜