Erlang 的行为真的有点像 class 继承吗?
Are Erlang behaviours really kind of the same as class inheritance?
目前我正在做一个使用 Apache Kafka 和 Erlang 作为流处理器语言的数据管道项目(除了从年初开始学习语言和概念外,我实际上没有使用过 erlang 的经验)。为了编写 Kafka 消费者,我们依赖于坚如磐石的 brod 模块。
我知道,我必须编写一个主管回调模块,负责启动我的 brod_client 和 group_consumer 模块。
my_app
+-- my_sup
+-- brod_client
+-- my_group_consumer
我写的这个 group_consumer 模块是 brod_group_subsriber_v2 行为的回调模块,它本身是 gen_server.
的回调模块
my_group_consumer > brod_group_subscriber > gen_server
当我 运行 我的应用程序时,我的主管正在启动 brod_client,但不是我的消费者 erlang:whereis(my_group_consumer).
returns undefined
。只有在消息到达后,brod_group_consumer_v2 本身似乎初始化 my_group_consumer 并调用其消息处理函数。这种“惰性”初始化对我来说很有意义,但与我期望的不同,因为我将主管配置为明确照顾我的_group_consumer(不是它的基本行为)。
所以毕竟我不确定我是否准确理解行为,因此我是否正确使用了 brod 模块,因为我尝试像使用 Java class 那样继承它们继承和多态性。
很难找到在主管中使用 brod 的示例,而不仅仅是在 shell 上用于演示目的。
编辑:我在这里使用 brod 作为 situation/use 案例的示例,我希望大多数专用模块的实现从 mst 通用模块“继承”,这似乎不是这种情况,因此我无法正确使用像 brod 这样的模块。
有人能解释一下概念上的区别吗?如果你喜欢按照我的例子来解释它就太好了,如果你能用另一个例子或根本没有例子来解释它......也很好,先谢谢了。
就像@alexey-romanov 在评论中所说的那样,我相信您最终会提出一个与标题中的问题截然不同的问题。
不过,如果您仍然对学习如何理解 Erlang/Elixir 行为感兴趣,我写了 two articles a while back and gave a talk about it on CodeBEAM SF 2019。
希望这会有所帮助:)
The same module can be a callback module for a behavior and define
another. If an existing behavior takes you half the way there, you can
just build your new behavior on top of it, like OTP does ;)"
...我希望能有第三篇文章完全涵盖这一点 ;)
以下示例对我有用——它在 gen_server
之上实现了 my_server
行为:
my_server.erl:
-module(my_server).
-compile(export_all).
-behaviour(gen_server).
-callback go( integer() ) -> atom(). %% Specifies that this module is a behaviour
%% which has one required callback function go/1
%%% required gen_server callback functions
init(_Args) ->
{ok, []}.
handle_call(Msg, _From, State) ->
io:format("In handle_call(), Msg= ~w~n", [Msg]),
{reply, hello_from_handle_call, State}.
handle_cast(Msg, State) ->
io:format("In handle_cast(), Msg= ~w~n", [Msg]),
{noreply, State}.
handle_info(Msg, State) ->
io:format("In handle_info(), Msg= ~w~n", [Msg]),
{noreply, State}.
b.erl:
-module(b).
-compile(export_all).
-behaviour(my_server).
%% my_server callback functions
go(_Count) ->
?MODULE ! hi_from_go, %% handle_info() gets this message
hi.
%% client functions
start() ->
gen_server:start_link( %% Calls the init() gen_server callback function.
{local, ?MODULE}, %% Registers the gen_server using this name.
my_server, %% Looks for the gen_server callback functions in this module.
[],
[]
).
do_call() ->
spawn(
fun() -> gen_server:call(?MODULE, hello) end %% handle_call() gets this message
).
do_go() ->
spawn(
fun() -> go(20) end
).
在shell中:
1> c(my_server).
my_server.erl:2: Warning: export_all flag enabled - all functions will be exported
{ok,my_server}
2> c(b).
b.erl:2: Warning: export_all flag enabled - all functions will be exported
{ok,b}
3> b:start().
{ok,<0.76.0>}
4> b:do_call().
In handle_call(), Msg= hello
<0.78.0>
5> b:do_go().
In handle_info(), Msg= hi_from_go
<0.80.0>
目前我正在做一个使用 Apache Kafka 和 Erlang 作为流处理器语言的数据管道项目(除了从年初开始学习语言和概念外,我实际上没有使用过 erlang 的经验)。为了编写 Kafka 消费者,我们依赖于坚如磐石的 brod 模块。
我知道,我必须编写一个主管回调模块,负责启动我的 brod_client 和 group_consumer 模块。
my_app
+-- my_sup
+-- brod_client
+-- my_group_consumer
我写的这个 group_consumer 模块是 brod_group_subsriber_v2 行为的回调模块,它本身是 gen_server.
的回调模块my_group_consumer > brod_group_subscriber > gen_server
当我 运行 我的应用程序时,我的主管正在启动 brod_client,但不是我的消费者 erlang:whereis(my_group_consumer).
returns undefined
。只有在消息到达后,brod_group_consumer_v2 本身似乎初始化 my_group_consumer 并调用其消息处理函数。这种“惰性”初始化对我来说很有意义,但与我期望的不同,因为我将主管配置为明确照顾我的_group_consumer(不是它的基本行为)。
所以毕竟我不确定我是否准确理解行为,因此我是否正确使用了 brod 模块,因为我尝试像使用 Java class 那样继承它们继承和多态性。
很难找到在主管中使用 brod 的示例,而不仅仅是在 shell 上用于演示目的。
编辑:我在这里使用 brod 作为 situation/use 案例的示例,我希望大多数专用模块的实现从 mst 通用模块“继承”,这似乎不是这种情况,因此我无法正确使用像 brod 这样的模块。
有人能解释一下概念上的区别吗?如果你喜欢按照我的例子来解释它就太好了,如果你能用另一个例子或根本没有例子来解释它......也很好,先谢谢了。
就像@alexey-romanov 在评论中所说的那样,我相信您最终会提出一个与标题中的问题截然不同的问题。 不过,如果您仍然对学习如何理解 Erlang/Elixir 行为感兴趣,我写了 two articles a while back and gave a talk about it on CodeBEAM SF 2019。 希望这会有所帮助:)
The same module can be a callback module for a behavior and define another. If an existing behavior takes you half the way there, you can just build your new behavior on top of it, like OTP does ;)"
...我希望能有第三篇文章完全涵盖这一点 ;)
以下示例对我有用——它在 gen_server
之上实现了 my_server
行为:
my_server.erl:
-module(my_server).
-compile(export_all).
-behaviour(gen_server).
-callback go( integer() ) -> atom(). %% Specifies that this module is a behaviour
%% which has one required callback function go/1
%%% required gen_server callback functions
init(_Args) ->
{ok, []}.
handle_call(Msg, _From, State) ->
io:format("In handle_call(), Msg= ~w~n", [Msg]),
{reply, hello_from_handle_call, State}.
handle_cast(Msg, State) ->
io:format("In handle_cast(), Msg= ~w~n", [Msg]),
{noreply, State}.
handle_info(Msg, State) ->
io:format("In handle_info(), Msg= ~w~n", [Msg]),
{noreply, State}.
b.erl:
-module(b).
-compile(export_all).
-behaviour(my_server).
%% my_server callback functions
go(_Count) ->
?MODULE ! hi_from_go, %% handle_info() gets this message
hi.
%% client functions
start() ->
gen_server:start_link( %% Calls the init() gen_server callback function.
{local, ?MODULE}, %% Registers the gen_server using this name.
my_server, %% Looks for the gen_server callback functions in this module.
[],
[]
).
do_call() ->
spawn(
fun() -> gen_server:call(?MODULE, hello) end %% handle_call() gets this message
).
do_go() ->
spawn(
fun() -> go(20) end
).
在shell中:
1> c(my_server).
my_server.erl:2: Warning: export_all flag enabled - all functions will be exported
{ok,my_server}
2> c(b).
b.erl:2: Warning: export_all flag enabled - all functions will be exported
{ok,b}
3> b:start().
{ok,<0.76.0>}
4> b:do_call().
In handle_call(), Msg= hello
<0.78.0>
5> b:do_go().
In handle_info(), Msg= hi_from_go
<0.80.0>