Erlangsupervisor

supervisor监控者

supervisor模块提供了一个监控其他进程的进程。通过supervisor能够构建监控树&＃xff0c;用于构造容错应用程序。监控者能够启动、关闭及重启它的子进程。

supervisor进程通过supervisor:start_link(Module, Args)或supervisor:start_link(SupName, Module, Args)启动&＃xff0c;成功的话返回值为{ok, Pid}。此时会通过调用回调函数Module:init(Args)来初始化监supervisor进程&＃xff0c;如果成功&＃xff0c;init将返回{ok, {SupFlags, [ChildSpec]}}

其中&＃xff0c;SupFlags定义了supervisor进程的重启策略&＃xff0c;它是如下的maps&＃xff1a;

#{strategy &＃61;> one_for_one, % optionalintensity &＃61;> 1, % optionalperiod &＃61;> 5} % optional


或元组{strategy, intensity, period}

strategy表示子进程的重启策略&＃xff0c;主要有以下几种&＃xff1a;
one_for_one&＃xff1a;一个子进程挂掉后&＃xff0c;只有该子进程会被重启。默认选项&＃xff1b;
one_for_all&＃xff1a;一个子进程挂掉后&＃xff0c;其他子进程也会被终止&＃xff0c;然后重启所有子进程&＃xff1b;
rest_for_one&＃xff1a;一个子进程挂掉后&＃xff0c;在该子进程后启动的子进程会被终止&＃xff0c;然后重启这些子进程&＃xff1b;
注意&＃xff1a;所有子进程是按照列表顺序去启动的&＃xff0c;终止时&＃xff0c;按照列表顺序的逆序去终止。
simple_one_for_one&＃xff1a;简单版的one_for_one&＃xff0c;在这种策略下&＃xff0c;所有子进程都是动态添加的。此时返回的ChildSpec只有一个元组。

intensity和period共同指定supervisor的重启限度。默认为1、5&＃xff0c;表示5s内最多重启1次&＃xff0c;超过这个限度后&＃xff0c;supervisor进程将会终止所有子进程和它本身。能够有效地防止supervisor无限重启。
注意&＃xff0c;intensity&＃61;2、period&＃61;10与intensity&＃61;1、period&＃61;5是不同的&＃xff0c;{1,5}短时间内不允许重启2次而{2,10}是允许的。

ChildSpec定义为以下的maps&＃xff1a;

#{id &＃61;> Id, % mandatorystart &＃61;> {M,F,A}}, % mandatoryrestart &＃61;> permanet|temporary|transient, % optionalshutdown &＃61;> brutal_kill|TimeOut, % optionaltype &＃61;> supervisor|worker, % optionalmodules &＃61;> modules()} % optional


或元组{id, start, restart, shutdown, type, modules}
id为子进程的标识符&＃xff1b;
start是一个{M,F,A}元组&＃xff0c;用于启动子进程&＃xff0c;返回{ok,Child}或{ok,Child,Info}&＃xff0c;Child为子进程的Pid&＃xff1b;
restart是指定了子进程终止时的处理策略&＃xff0c;permanent参数表示每次终止都重启&＃xff0c;temporary表示不再重启&＃xff08;即使因为其他进程终止导致本进程终止而后需要重启的情况&＃xff09;&＃xff0c;transient表示只有当进程被意外终止才会重启&＃xff0c;正常原因包括normal, shutdown, or {shutdown,Term}&＃xff0c;默认为permanent&＃xff1b;
shutdown指定子进程的终止方式&＃xff0c;brutal_kill表示通过调用exit(ChildPid, kill)终止子进程&＃xff0c;TimeOut表示表示通过调用exit(ChildPid, shutdown)终止子进程&＃xff0c;此时将会等待TimeOut ms等待子进程返回一个理由为shutdown的退出信号。当子进程为supervisor进程时&＃xff0c;应该设置成infinity。默认为50000;
type指定子进程的类型&＃xff0c;默认worker&＃xff1b;
module指定回调模块&＃xff0c;默认为{M,F,A}中的M。

注意&＃xff0c;在init返回后&＃xff0c;supervisor会根据子进程列表[ChildSpec]&＃xff0c;启动所有的子进程。supervisor:start_link是同步调用&＃xff0c;在所有子进程启动之前它不会返回。

可以通过supervisor:check_childspecs([ChildSpec])检查ChildSpec是否合法。
可以通过supervisor:count_children(SupRef)获取supervisor进程的子进程情况。
可以通过supervisor:start_child(SupRef, ChildSpec)动态启动一个子进程&＃xff0c;不过该子进程在supervisor进程重启后将会丢失。
可以通过supervisor:terminate_child(SupRef, Id)终止一个子进程&＃xff0c;无论该子进程是静态添加抑或是动态添加的。此处的Id&＃xff0c;如果是动态添加的则必须为子进程Pid。
可以通过supervisor:restart_child(SupRef, Id)重启一个子进程。此子进程必须在ChildSpecs中。
可以通过supervisor:delete_child(SupRef, Id)删除一个子进程&＃xff0c;并从ChildSpecs中删除。

两个例子