2017-06-01 99 views
0

我试图启动一个主管和一个gen_server进程,同时一个节点从命令行创建的,我用下面的命令来启动节点:无法启动过程

erl -name [email protected] -s ets_sup start [email protected] calc 

但是,当我使用whereis检查新创建的节点上的进程时,我发现进程为undefined。我没有直接在节点外壳上运行ets_sup和ets_srv,但从命令行启动节点不起作用。我想知道为什么会发生这种情况?

ets_sup.erl:

-module(ets_sup). 
-behaviour(supervisor). 
-export([start/1, start_link/1, init/1]). 

start([A, B]) -> 
     start_link([A, B]). 


start_link([A, B]) -> 
     supervisor:start_link({local, ?MODULE}, ?MODULE, [A, B]). 

init([A, B]) -> 
     {ok, {{one_for_all, 0, 1}, 
       [{ets_srv, {ets_srv, start_link, [A, B]}, permanent, 5000, worker, [ets_srv]}]}}. 

ets_srv.erl:

-module(ets_srv). 
-behaviour(gen_server). 
-compile(export_all). 

-record(state, {a, b}). 

start_link(A,B) -> 
     gen_server:start_link({local, ?MODULE}, ?MODULE, [A, B], []). 

init([A, B]) -> 
     {ok, #state{a = A, b = B}}. 

check_sys() -> 
     gen_server:call(?MODULE, check_sys). 

handle_call(check_sys, _From, #state{a = A, b = B} = State) -> 
     {reply, {A, B}, State}. 

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

handle_cast(_Req, State) -> {noreply, State}. 

code_change(_Ol, State, _Ex) -> {ok, State}. 

terminate(_R, _S) -> ok. 

回答

1

我认为你真正开始你的参数列表功能ets_sup:start/1。您可以通过在ets_sup:start_link/1之前添加io:format(...)来验证它。

但是执行功能ets_sup:start/1的过程很早就会因为shutdown而很快死亡,而当您的主管与其链接时,它也会与其所有子女一起死亡。

您必须从不会死的进程调用此函数(通常,它是应用程序管理器的角色)。例如,做到:

start([A, B]) -> 
    % spawn a new process 
    spawn(fun() -> 
       start_link([A, B]), 
       % add a loop to keep it alive 
       loop() 
       end). 


loop() -> 
    receive 
     stop -> ok; 
     _ -> loop() 
    end. 

编辑,但不是一个答案

我已修改了代码:

  • 在init服务器添加process_flag(trap_exit, true),,为了赶退出消息,
  • 在服务器终止函数中添加io:format("server terminate with reason ~p, process ~p~n",[_R,self()]),以打印最终由主管发送的退出原因(注意:如果a n退出消息由另一个进程发送,handle_info将被触发)。
  • 在监督器中添加ets_srv:check_sys(),刚好在服务器启动之后,以检查它是否确实正确地显示了星号。

这里是修改后的代码。

-module(ets_sup). 
-behaviour(supervisor). 
-export([start/1, start_link/1, init/1]). 

start([A, B]) -> 
    start_link([A, B]). 


start_link([A, B]) -> 
    supervisor:start_link({local, ?MODULE}, ?MODULE, [A, B]), 
    ets_srv:check_sys(). 

init([A, B]) -> 
    {ok, {{one_for_all, 0, 1}, 
      [{ets_srv, {ets_srv, start_link, [A, B]}, permanent, 5000, worker, [ets_srv]}]}}. 

-module(ets_srv). 
-behaviour(gen_server). 
-compile(export_all). 

-record(state, {a, b}). 

start_link(A,B) -> 
    gen_server:start_link({local, ?MODULE}, ?MODULE, [A, B], []). 

init([A, B]) -> 
    process_flag(trap_exit, true), 
    {ok, #state{a = A, b = B}}. 

check_sys() -> 
    gen_server:call(?MODULE, check_sys). 

handle_call(check_sys, _From, #state{a = A, b = B} = State) -> 
    io:format("check_sys state ~p, process ~p~n",[State,self()]), 
    {reply, {A, B}, State}. 

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

handle_cast(_Req, State) -> 
    {noreply, State}. 

code_change(_Ol, State, _Ex) -> 
    {ok, State}. 

terminate(_R, _S) -> 
    io:format("server terminate with reason ~p, process ~p~n",[_R,self()]), 
    ok. 

运行此版本显示,管理程序正确启动服务器,然后向其发送关闭消息。如果主管在shell中启动,则不会发生这种情况。

C:\src>erl -s ets_sup start [email protected] calc 
check_sys state {state,'[email protected]',calc}, process <0.56.0> 
server terminate with reason shutdown, process <0.56.0> 
Eshell V8.2 (abort with ^G) 
1> whereis(ets_srv). 
undefined 
2> ets_sup:start(['[email protected]',calc]). 
check_sys state {state,'[email protected]',calc}, process <0.61.0> 
{'[email protected]',calc} 
3> whereis(ets_srv). 
<0.61.0> 
4> ets_srv:check_sys(). 
check_sys state {state,'[email protected]',calc}, process <0.61.0> 
{'[email protected]',calc} 
5> exit(whereis(ets_srv),shutdown). 
true 
6> whereis(ets_srv). 
<0.61.0> 
7> exit(whereis(ets_srv),kill). 
** exception exit: shutdown 
8> whereis(ets_srv). 
undefined 
9> 

我已经验证了,如果你使用spawn_link启动普通程序(不是管理器)以同样的方式,它不接受任何退出消息。

-module (st). 

-compile([export_all]). 

start(Arg) -> 
    do_start(Arg). 

do_start(Arg) -> 
    io:format("spawn from ~p~n",[self()]), 
    register(?MODULE,spawn_link(fun() -> init(Arg) end)). 

init(Arg) -> 
    io:format("init with ~p in ~p~n",[Arg,self()]), 
    process_flag(trap_exit, true), 
    Pid = self(), 
    spawn(fun() -> monitor(process,Pid), receive M -> io:format("loop received ~p~n",[M]) end end), 
    loop(Arg). 

loop(Arg) -> 
    receive 
     state -> 
      io:format("state is ~p~n",[Arg]), 
      loop(Arg); 
     stop -> 
      io:format("stopping~n"); 
     _ -> 
      loop(Arg) 
    end. 

执行给:

C:\src>erl -s st start [email protected] calc 
spawn from <0.3.0> 
init with ['[email protected]',calc] in <0.55.0> 
Eshell V8.2 (abort with ^G) 
1> whereis(st). 
<0.55.0> 
2> exit(whereis(st),shutdown). 
true 
3> whereis(st). 
<0.55.0> 
4> st ! state. 
state is ['[email protected]',calc] 
state 
5> st ! stop. 
stopping 
loop received {'DOWN',#Ref<0.0.4.66>,process,<0.55.0>,normal} 
stop 
6> whereis(st). 
undefined 
7> 

编辑,另一种方式来“分离”主管

我所做的表明,主管接收到关闭消息的测试。我不知道为什么,通常我会使用应用程序机制来启动一个监督树,并且我从未遇到过这种情况。

我建议你从其父断开链接的主管,所以不会收到一个关机消息:

-module(ets_sup). 
-behaviour(supervisor). 
-export([start/1, start_link/1, init/1]). 

start([A, B]) -> 
    start_link([A, B]). 


start_link([A, B]) -> 
    supervisor:start_link({local, ?MODULE}, ?MODULE, [A, B]), 
    ets_srv:check_sys(). 

init([A, B]) -> 
    {links,[Parent]} = process_info(self(),links), 
    unlink(Parent), 
    {ok, {{one_for_all, 0, 1}, 
      [{ets_srv, {ets_srv, start_link, [A, B]}, permanent, 5000, worker, [ets_srv]}]}}. 

的现在,它的工作原理:

C:\src>erl -s ets_sup start [email protected] calc 
check_sys state {state,'[email protected]',calc}, process <0.56.0> 
Eshell V8.2 (abort with ^G) 
1> ets_srv:check_sys(). 
check_sys state {state,'[email protected]',calc}, process <0.56.0> 
{'[email protected]',calc} 
2>