erlang四大behaviour之四-supervisor

1. 监督规则

一个监督者负责启动、停止、监控他的子进程。监督者的一个基本概念就是当必要的时候重启子进程保证它们的存活

 

哪个子进程要重启和被监控是由一个子规程列表决定的，子进程按照列表中指定的顺序启动，并按相反的顺序终止

 

2. 实例

监督者的回调模块

 

-module(ch_sup).

 -behaviour(supervisor).

 -export([start_link/0]).

 -export([init/1]).

 start_link() ->    

supervisor:start_link(ch_sup, []).

 init(_Args) ->   

　　 {ok, {{one_for_one, 1, 60},      

    [{ch3, {ch3, start_link, []},      

      permanent, brutal_kill, worker, [ch3]}]}}.

one_for_one是重启策略

1和60定义了最大重启频率

{ch3, …}是子规程

 

3. 重启策略

one_for_one

 

假如一个进程终止了，仅仅这个进程会被重启

 

one_for_all

 

 

假如一个进程停止了，所有其他子进程也要被停止，然后所有子进程，包括这个引发停止的子进程都被重启

 

 

 

rest_for_one

 

假如一个进程停止了，它后面的子进程，也就是以启动顺序来说这个被终止的进程后面的子进程都将被停止，然后他们又被启动。

 

 

 

4. 最大启动频率

监督者有一个内建机制限制在给定的时间间隔里的重启次数，这由子进程启动规程中的两个参数值决定，MaxR和MaxT，它们定义在回调函数init中

 

init(...) ->   

 {ok, {{RestartStrategy, MaxR, MaxT},       

   [ChildSpec, ...]}}.

如果在时间MaxT里重启次数大于MaxR ，监督者进程就停止它所有子进程，然后再终止自己。

 

当监督者进程终止了，那么更高级别的监督者要采取些动作，它或者重启被终止的监督者或者停止自己

 

这个重启机制的目的是预防一个进程因某种原因频繁的终止，然后简单的重启。

 

5. 子规范

下面的是类型定义

 

{Id, StartFunc, Restart, Shutdown, Type, Modules}   

 Id = term()   

 StartFunc = {M, F, A}  

      M = F = atom()   

     A = [term()] 

   Restart = permanent | transient | temporary  

  Shutdown = brutal_kill | integer() >=0 | infinity   

 Type = worker | supervisor    

Modules = [Module] | dynamic      

  Module = atom()

Id用来内部标识子规范

StartFunc是启动子进程时调用的函数，它将成为对supervisor:start_link, gen_server:start_link, gen_fsm:start_link or gen_event:start_link的调用

Restart标识一个进程终止后将怎样重启，一个permanent 进程总会被重启；一个temporary 进程从不会被重启；一个transient 进程仅仅当是不正常的被终止后才重启，例如非normal得退出原因

Shutdown 定义一个进程将怎样被终止，brutal_kill意味着子进程被exit(Child, kill)无条件的终止；一个整数值的超时时间意味着监督者告诉子进程通过调用exit(Child, shutdown)而被终止，然后等待一个返回的退出信号，假如在指定的时间里没有收到退出信号，那么子进程用exit(Child, kill)被无条件终止。

Type指定子进程是supervisor还是worker

Modules 是有一个元素的列表[Module]，假如子进程是supervisor、gen_server 或 gen_fsm，那么Module 是回调模块的名称；假如子进程是gen_event，那么Modules 应该是dynamic

例如：子规范用于启动一个服务器ch3

 

{ch3, {ch3, start_link, []}, permanent, brutal_kill, worker, [ch3]}

子规范用于启动一个事件管理器

 

{error_man, {gen_event, start_link, [{local, error_man}]}, permanent, 5000, worker, dynamic}

 

 

监督者然后根据子规程启动所有子进程，这个例子中是一个子进程ch3

 

6. 启动supervisor

像这样

 

start_link() ->   

 supervisor:start_link(ch_sup, []).

启动

 

监督者进程调用init

 

init(_Args) ->    

{ok, {{one_for_one, 1, 60},       

   [{ch3, {ch3, start_link, []},      

      permanent, brutal_kill, worker, [ch3]}]}}.

并期待init返回{ok, StartSpec}

 

注意supervisor:start_link是同步的，它一直等到所有子进程都启动了才返回

 

7. 添加子进程

除静态监控树外，我们也可以通过supervisor:start_child(Sup, ChildSpec)向监督者动态添加子进程，Sup 是监督者的pid或名称，ChildSpec 是一个子规范。子进程用start_child/2来添加。注意：假如监督者死掉后重启，那么所有动态添加的子进程都不复存在

 

8. 停止子进程

任何静态动态添加的子进程都可以用supervisor:terminate_child(Sup, Id)来停止。一个停止子进程规范可以用supervisor:delete_child(Sup, Id)来删除。Sup是监督者的pid或名称，Id是子规范的id

 

9. Simple-One-For-One

监督者的simple_one_for_one启动策略是one_for_one的简版，所有子进程都是同一进程实例而被动态添加，下面是一个simple_one_for_one监督者的实例

 

-module(simple_sup).

-behaviour(supervisor).

-export([start_link/0]).

-export([init/1]).

start_link() ->    supervisor:start_link(simple_sup, []).

init(_Args) -> 

   {ok, {{simple_one_for_one, 0, 1},   

       [{call, {call, start_link, []}, 

           temporary, brutal_kill, worker, [call]}]}}.

当启动时，监督者不启动任何子进程，取而代之的是所有子进程都通过调用supervisor:start_child(Sup, List)来动态添加，Sup 是监督者的pid或名称，List 是添加给子规范中指定参数列表term列表，如果启动函数是{M, F, A}这种形式，那么子进程通过调用apply(M, F, A++List)而被启动

 

例如，给上面的例子添加一个子进程

 

supervisor:start_child(Pid, [id1])

那么子进程通过调用apply(call, start_link, []++[id1])而被启动，实际上就是call:start_link(id1)

 

10. 停止

因为监控者是监控树的一部分，它自动被他的监督者停止，根据相应规范，它反序停止它的所有子进程，然后终止自己