独钓寒江雪

erlang 的进程监控 link

说明

link 是双向的, 任何一个进程挂掉, 另外一个都会受影响

1
2
3
A 挂掉, B 会检查自己有没有设置 process_flag(trap_exit, true)
如果没有设置, 则也挂掉。
如果设置了, 则在消息循环里面检测 {'EXIT', _From, Msg} 消息, 就算 A 是被 kill 的, 在 B 这里也是收到消息, 不会直接挂掉

演示代码

dist_proc.erl

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
-module(dist_proc).

-export([start/0]).
-export([init/0]).
-export([loop/0]).

start() ->
  Pid = spawn_link(?MODULE,init,[]),
  register(?MODULE, Pid),
  {ok, Pid}.

init() ->
  io:format("on ~p init ~n", [?MODULE]),
  process_flag(trap_exit, true),
  loop().

loop() ->
  receive
    {'EXIT', From, Reason} ->
      io:format("~p got exit msg ~p ~p~n", [?MODULE, From, Reason]),
      loop();
    Msg ->
      io:format("~p got other msg ~p~n", [?MODULE, Msg]),
      loop()
  end.

mon_proc.erl

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
-module(mon_proc).

-export([start/0]).
-export([init/0]).
-export([loop/0]).

start() ->
  Pid = spawn(?MODULE,init,[]),
  register(?MODULE, Pid),
  {ok, Pid}.

init() ->
  io:format("on ~p init ~n", [?MODULE]),
  process_flag(trap_exit, true),
  dist_proc:start(),
  loop().

loop() ->
  receive
    {'EXIT', From, Reason} ->
      io:format("~p got exit msg ~p ~p~n", [?MODULE, From, Reason]),
      loop();
    Msg ->
      io:format("~p got other msg ~p~n", [?MODULE, Msg]),
      loop()
  end.

测试

1
2
3
4
5
6
7
8
9
mon_proc:start().

exit(whereis(mon_proc), normal).
exit(whereis(mon_proc), shutdown).
exit(whereis(mon_proc), xxx).
exit(whereis(mon_proc), kill).

whereis(mon_proc).
whereis(dist_proc).
erlang