在分析 gen_server (或者是gen_fsm ）之前,首先应该弄明白,gen 这个module .
1 -module(gen). 2 -compile({inline,[get_node/1]}). 3 4 %%%----------------------------------------------------------------- 5 %%% This module implements the really generic stuff of the generic 6 %%% standard behaviours (e.g. gen_server, gen_fsm). 7 %%% 8 %%% The standard behaviour should export init_it/6. 9 %%%-----------------------------------------------------------------
也就是说,gen 这个模块 gen_server ,gen_fsm 的基础.
PS. 无特殊说明,以下提到的gen_server 都指代gen_server 和 gen_fsm .
export func
1 -export([start/5, start/6, debug_options/1, 2 call/3, call/4, reply/2]).
gen 模块导出了以上这些函数,其中:
start/N 是用于spawn gen_server 进程. 基本的流程是使用proc_lib:spawn(_link) 创建新的process, 并以init_it 作为初始化函数, 继而回调 gen_server 模块中的init_it函数, 完成gen_server 模块的init .
call/N 是用于gen_server call func 的实现，也就是 gen_server:call 的实际调用.
reply/2 的实现相对“简单”,即调用bif erlang:'!'/2 发送消息. 但是这个函数的作用很大, 之后会一一提到.
start/N
start/5 用于创建无名gen_server , start/6 用于创建指定name 的gen_server .
1 start(GenMod, LinkP, Name, Mod, Args, Options) 2 GenMod :: gen_server | gen_fsm 3 LinkP :: nolink | link 4 Name :: {local, atom()} | {global, term()} | {via, atom(), term()} %% 就是指定的name 5 Mod :: atom() %% 就是使用了gen_server behaviour 的模块名 6 Args :: term() %% Mod 模块 init func 的初始参数 7 Options :: [{timeout, Timeout} | {debug, [Flag]} | {spawn_opt, OptionList}] %% 这个参数是用来指定创建进程的参数 8 9 10 Flag :: trace | log | {logfile, File} | statistics | debug
1 start(GenMod, LinkP, Mod, Args, Options) 2 %% 相比start/6, 没有了执行name 的参数
start/6 会先确认给定的name 是否已经被使用, 如果被使用, 会返回
1 {error, {already_started, Pid}} %% Pid 是名字为name 的进程
反之, 继续执行do_spawn , do_spawn 会调用proc_lib:spawn(_link) 函数创建进程, 并以 init_it 为初始化函数. (先挖个坑, ** proc_lib:spawn VS erlang:spawn ** 后面填)
注意, 此时已经有新的进程被创建了, 而 init_it 函数，已经是在由新的进程执行.
1 init_it(GenMod, Starter, Parent, Mod, Args, Options) 2 Starter :: pid() %% 即调用proc_lib:spawn 的进程 3 Parent :: pid() | atom() %% Parent 只有在以link方式 start的时候才有意义 (此坑后填) 4 init_it(GenMod, Starter, Parent, Name, Mod, Args, Options) 5 %% Name 即指定的name, 首先会以Name 为参数调用 name_register/1 6 7 init_it2(GenMod, Starter, Parent, Name, Mod, Args, Options) -> 8 GenMod:init_it(Starter, Parent, Name, Mod, Args, Options). 9 %% 回调 gen_server/gen_fsm 模块的init_it 函数
call/N
call/3 使用default_timeout 作为第四个参数调用 call/4 .
call/4 首先会进程一系列的参数校验, 然后调用do_call/4
1 do_call(Process, Label, Request, Timeout) -> 2 %% 首先调用 bif monitor Process 3 try erlang:monitor(process, Process) of 4 Mref -> 5 %% 然后给 Process 发送消息 6 catch erlang:send(Process, {Label, {self(), Mref}, Request}, 7 [noconnect]), 8 %% 并等待 Process 的返回结果, 就是在 handle_call 中的Reply 或者是 gen:reply 的 结果 9 receive 10 {Mref, Reply} -> 11 %% 关于 erlang:monitor/erlang:demonitor 的文档很详细 12 erlang:demonitor(Mref, [flush]), 13 {ok, Reply}; 14 {'DOWN', Mref, _, _, noconnection} -> 15 Node = get_node(Process), 16 exit({nodedown, Node}); 17 {'DOWN', Mref, _, _, Reason} -> 18 exit(Reason) 19 after Timeout -> 20 erlang:demonitor(Mref, [flush]), 21 exit(timeout) 22 end 23 catch 24 %% bif monitor Process 失败, 就 monitor Process 所在的 Node 25 error:_ -> 26 Node = get_node(Process), 27 monitor_node(Node, true), 28 receive 29 {nodedown, Node} -> 30 monitor_node(Node, false), 31 exit({nodedown, Node}) 32 after 0 -> 33 Tag = make_ref(), 34 %% bif erlang:'!'/2 发送消息 35 Process ! {Label, {self(), Tag}, Request}, 36 %% 等待响应 37 wait_resp(Node, Tag, Timeout) 38 end 39 end.
call/3 以及 call/4 主要就做了这些事情.
reply/2
此函数实现在erl 代码层面很简单, 但对gen_server 进程来说,有独特的作用,后续会进行分析.
填坑
proc_lib:spawn 和 erlang:spawn 的区别:
翻下代码,就能看到, so easy
相比较 erlang:spawn, proc_lib:spawn 在被创建的进程中,添加了一些信息:
'$ancestors', '$initial_call'.
在某些场景下,这些信息对于定位进程的归属有很大的作用.比如说:定位僵死进程的归属,定位崩溃进程的归属等.