【问题标题】:How to implement a function to notify a node that the other node quit or not如何实现一个函数来通知一个节点另一个节点是否退出
【发布时间】:2020-12-21 23:55:24
【问题描述】:

我正在创建一个节点集群,我想在每次连接节点时收到通知,这怎么可能?

【问题讨论】:

标签: erlang elixir beam


【解决方案1】:

创建一个gen_server 并在init 方法中调用net_kernel:monitor_nodes(true)。现在,每当节点加入或离开集群时,gen_server 都会收到 {node_up, Node}{node_down, Node} 消息。

-module(node_monitor).

-behaviour(gen_server).

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

%% export gen_server callbacks
-export([init/1,
     handle_call/3,
     handle_cast/2,
     handle_info/2,
     terminate/2,
     code_change/3]).

-record(state, {}).

-define(SERVER_NAME, ?MODULE).
%%====================================
%% API
%%====================================
start_link() ->
    gen_server:start_link({local, ?SERVER_NAME}, ?MODULE, [], []).

stop() ->
    gen_server:cast(?SERVER_NAME, stop).

%%====================================
%% callbacks
%%====================================
init([]) ->
    net_kernel:monitor_nodes(true),
    {ok, #state{}}.

terminate(_Reason, _State) ->
    ok.

code_change(_OldVsn, State, _Extra) ->
    {ok, State}.

handle_info({nodeup, _Node} = Event, State) ->
%%TODO: do something here
    {noreply, State};

handle_info({nodedown, _Node} = Event, State) ->
  %%TODO: do something here
    {noreply, State};

handle_info(_Msg, State) ->
    {noreply, State}.


handle_cast(stop, State) ->
    {stop, normal, State};
handle_cast(_Msg, State) ->
    {noreply, State}.

handle_call(_Msg, _From, State) ->
    Reply = ok,
    {reply, Reply, State}.

请注意,所有节点都会收到这些通知。因此,如果每个集群只有一个节点应该处理node_upnode_down 通知,则需要在此 gen_server 之上实现该逻辑。

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2021-10-16
    • 1970-01-01
    • 2018-10-07
    • 2021-01-01
    • 2016-04-03
    • 1970-01-01
    • 2017-05-15
    相关资源
    最近更新 更多