32

正如我从“Erlang and OTP in action”一书中了解到的那样,行为一词是指:

  • 行为接口,它是一组函数;
  • 行为实现,它是特定于应用程序的代码(回调模块);
  • 行为容器,它是一个过程。

问题:

Erlang/OTP 初学者应该了解哪些行为?是否可以概括地描述和理解 OTP 行为的概念?

在 Elang/OTP 的上下文中,“回调函数”实际上意味着什么?

我们可以将行为实现中的回调视为 Java 中重写的方法吗?

这本书说,以下代码中库函数“gen_server:start_link/4”的关联回调函数是“Module:init/1”。

这是否意味着使用 init/1 我们调用 gen_server:start_link/4 库函数?或者这意味着什么?

-module(tr_server).

-behaviour(gen_server).

-include_lib("eunit/include/eunit.hrl").

%% API
-export([
         start_link/1,
         start_link/0,
         get_count/0,
         stop/0
         ]).

%% gen_server callbacks
-export([init/1, handle_call/3, handle_cast/2, handle_info/2,
         terminate/2, code_change/3]).

-define(SERVER, ?MODULE).
-define(DEFAULT_PORT, 1055).

-record(state, {port, lsock, request_count = 0}).


%%%===================================================================
%%% API
%%%===================================================================


%%--------------------------------------------------------------------
%% @doc Starts the server.
%%
%% @spec start_link(Port::integer()) -> {ok, Pid}
%% where
%%  Pid = pid()
%% @end
%%--------------------------------------------------------------------
start_link(Port) ->
    gen_server:start_link({local, ?SERVER}, ?MODULE, [Port], []).

%% @spec start_link() -> {ok, Pid}
%% @doc Calls `start_link(Port)' using the default port.
s    tart_link() ->
    start_link(?DEFAULT_PORT).

%%--------------------------------------------------------------------
%% @doc Fetches the number of requests made to this server.
%% @spec get_count() -> {ok, Count}
%% where
%%  Count = integer()
%% @end
%%--------------------------------------------------------------------
get_count() ->
    gen_server:call(?SERVER, get_count).

%%--------------------------------------------------------------------
%% @doc Stops the server.
%% @spec stop() -> ok
%% @end
%%--------------------------------------------------------------------
stop() ->
    gen_server:cast(?SERVER, stop).


%%%===================================================================
%%% gen_server callbacks
%%%===================================================================

init([Port]) ->
    {ok, LSock} = gen_tcp:listen(Port, [{active, true}]),
    {ok, #state{port = Port, lsock = LSock}, 0}.

handle_call(get_count, _From, State) ->
    {reply, {ok, State#state.request_count}, State}.

handle_cast(stop, State) ->
    {stop, normal, State}.

handle_info({tcp, Socket, RawData}, State) ->
    do_rpc(Socket, RawData),
    RequestCount = State#state.request_count,
    {noreply, State#state{request_count = RequestCount + 1}};
handle_info(timeout, #state{lsock = LSock} = State) ->
    {ok, _Sock} = gen_tcp:accept(LSock),
    {noreply, State}.

terminate(_Reason, _State) ->
    ok.

code_change(_OldVsn, State, _Extra) ->
    {ok, State}.

%%%===================================================================
%%% Internal functions
%%%===================================================================

do_rpc(Socket, RawData) ->
    try
        {M, F, A} = split_out_mfa(RawData),
        Result = apply(M, F, A),
        gen_tcp:send(Socket, io_lib:fwrite("~p~n", [Result]))
    catch
        _Class:Err ->
            gen_tcp:send(Socket, io_lib:fwrite("~p~n", [Err]))
    end.

split_out_mfa(RawData) ->
    MFA = re:replace(RawData, "\r\n$", "", [{return, list}]),
    {match, [M, F, A]} =
        re:run(MFA,
               "(.*):(.*)\s*\\((.*)\s*\\)\s*.\s*$",
                   [{capture, [1,2,3], list}, ungreedy]),
    {list_to_atom(M), list_to_atom(F), args_to_terms(A)}.

args_to_terms(RawArgs) ->
    {ok, Toks, _Line} = erl_scan:string("[" ++ RawArgs ++ "]. ", 1),
    {ok, Args} = erl_parse:parse_term(Toks),
    Args.


%% test

start_test() ->
    {ok, _} = tr_server:start_link(1055).
4

5 回答 5

22

我不会像其他答案那样尝试解决您的具体问题,而是尝试用简单的术语解释行为背后的基础知识,并让您在了解这些基础知识的基础上回答您自己的问题。

行为基本上是一个消息处理框架,其中“框架”是指最终用户可以完成和定制的问题的部分解决方案的经典定义。OTP 行为本质上提供:

  • 消息循环
  • 与底层 OTP 支持集成,用于代码升级、跟踪、系统消息等。

行为将消息处理委托给回调模块,或“Erlang and OTP In Action”调用它们的行为实现。在调用其init/1函数时,回调模块通常为消息循环创建状态以代表它保持。然后行为循环将此状态传递给回调模块消息处理函数的每个后续调用,并且这些调用中的每一个都可以返回修改后的状态。回调函数还返回指令,告诉行为消息循环下一步该做什么。

这是行为核心的消息循环的一个大大简化的版本:

loop(Callbacks, State) ->
  {Next, NState} =
 receive
                     M1 ->

                       Callbacks:handle_m1(M1,State);
                     M2 ->
                       Callbacks:handle_m2(M2,State);
                     Other ->
                       Callbacks:handle_other(Other,State)
                   end,
  case Next of

    stop -> ok;
    _ -> loop(Callbacks, NState)
  end.

这个尾递归循环将Callbacks模块和State变量作为参数。在第一次调用此循环之前,您已经告诉行为您的回调模块是什么,然后基本 OTP 行为支持代码已经调用了您的init/1回调函数以获取State.

我们的示例行为循环接收 form M1M2和任何其他消息的消息,其细节在此无关紧要,并且对于每条消息,调用Callbacks模块中的不同回调函数。在这个例子中,handle_m1handle_m2回调函数分别处理消息M1M2,而回调函数handle_other处理所有其他类型的消息。请注意,State传递给每个回调函数。每个函数都应该返回一个元组,第一个元素告诉循环接下来要做什么,第二个元素包含循环可能的新状态State——与循环存储在其变量中的值相同或新的不同值NState。在这个例子中,如果Next是原子stop,循环停止,但如果是其他任何东西,循环会递归调用自身,将新状态传递NState给下一次迭代。而且由于它是尾递归的,因此循环永远不会破坏堆栈。

如果你挖掘标准 OTP 行为的来源,例如gen_servergen_fsm,你会发现一个很像这样的循环,但由于处理系统消息、超时、跟踪、异常等,它们要复杂得多。标准行为也开始它们的在单独的进程中循环,因此它们还包含用于启动循环进程并将消息传递给它的代码。

于 2011-04-26T21:48:29.327 回答
21

问: Erlang/OTP 初学者应该了解哪些行为?是否可以概括地描述和理解 OTP 行为的概念?

行为通常用于代码中,以便编译器可以根据其行为生成更直观的错误消息,即 application/supervisor/gen_server/gen_event/gen_fsm。

它使编译器能够给出特定于 ex 行为的错误消息:gen_server

问:在 Elang/OTP 的上下文中,“回调函数”实际上是什么意思?

回调函数可以说是取自GUI编程(至少类似)。每当发生事件时。鼠标点击有一个单独的函数来处理鼠标点击。

因此,无论何时,例如。从另一个模块调用 gen_server 的导出函数,该函数可以具有具有不同模式的回调函数(handle_call/handle_cast)。

问:我们可以将行为实现中的回调视为 Java 中重写的方法吗?

是的......也许......不:)

问:书上说下面代码中库函数“gen_server:start_link/4”的关联回调函数是“Module:init/1”。

gen_server:start_link 自己调用 init 函数,如 w55.... 回答的那样(对不起,名字很大)。


希望我已经回答了你所有的问题:)

于 2011-04-26T14:34:23.327 回答
12

Erlang/OTP 初学者应该了解哪些行为?

大概是这里写的。

是否可以概括地描述和理解 OTP 行为的概念?

从文档中读取:“行为是这些常见模式的形式化。想法是将流程的代码划分为通用部分(行为模块)和特定部分(回调模块)。”

在 Elang/OTP 的上下文中,“回调函数”实际上意味着什么?

查看上面提供了回调函数示例的链接。

我们可以将行为实现中的回调视为 Java 中重写的方法吗?

在 Java 术语中,行为可能是 Java 接口,而回调将是接口中定义的方法之一的实现。

这本书说,以下代码中库函数“gen_server:start_link/4”的关联回调函数是“Module:init/1”。这是否意味着使用 init/1 我们调用 gen_server:start_link/4 库函数?或者这意味着什么?

这意味着,每次调用 gen_server:start_link/4 时,都会调用函数 Module:init/1,其中 Module 是您传递给 start_link 函数的第二个参数,您提供的参数作为第四个参数。换句话说,这就是 start_link/4 幕后发生的事情:

...
start_link(Name, Module, Args, Opts) ->
  ...
  Module:init(Args)
  ...
...
于 2011-04-26T17:57:10.763 回答
3

查看 erlang lib 目录中的 gen_server 模块的源代码。源码里面解释的很好,注释也很详细。

于 2011-04-26T14:45:10.287 回答
0

gen_server:start_link 调用初始化。

于 2011-04-26T13:20:17.787 回答