Действительно ли поведение Эрланга такое же, как наследование классов? - PullRequest
Новая
       84

Действительно ли поведение Эрланга такое же, как наследование классов?

2 голосов
/ 18 февраля 2020

В настоящее время я работаю над проектом конвейера данных, использующим Apache Kafka и Erlang в качестве языка потокового процессора (у меня фактически нет предыдущего опыта работы с erlang, кроме изучения языка и концепций с начала года). Чтобы писать потребителям Kafka, мы опираемся на модуль rock solid 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). возвращает undefined. Только после того, как сообщение достигло, сам brod_group_consumer_v2, кажется, оживляет my_group_consumer и вызывает его функцию-обработчик сообщений. Этот "ленивый" init имеет смысл для меня, но отличается от того, что я ожидал, так как я настроил супервизор для явной заботы о my_group_consumer (не его базовом поведении).

Так что после всего этого я не уверен, если Я точно понимаю поведение, и поэтому, если я правильно использую модули brod, я пытаюсь наследовать их, как если бы я наследовал класс Java и полиморфизм.

Очень трудно найти примеры, когда brod используется в супервизоре, а не только в оболочке для демонстрационных целей.

РЕДАКТИРОВАТЬ: я использую brod в качестве примера ситуации / использования здесь, где я ожидал, что реализация наиболее специализированного модуля "унаследует" от mst generi c, который не кажется и поэтому я не могу правильно использовать такой модуль, как Брод.

Может, кто-нибудь объяснит мне различия в понятиях? Если вы хотите объяснить это в соответствии с моим примером, было бы здорово, если бы вы могли объяснить это другим примером или вообще без примера ... также хорошо, заранее спасибо.

Ответы [ 2 ]

1 голос
/ 18 февраля 2020

Этот же модуль может быть модулем обратного вызова для поведения и определять другой. Если существующее поведение ведет вас на половину пути, вы можете просто построить новое поведение поверх него, как это делает OTP;) "

... Я бы там sh быть третьей статьей, охватывающей именно это;)

Следующий пример работает для меня - он реализует поведение my_server поверх gen_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
    ).

В оболочке: 

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>
1 голос
/ 18 февраля 2020

Точно так же, как @ alexey-romanov заявляет в комментарии, я верю, что вы в конечном итоге столкнетесь с вопросом, который сильно отличается от вопроса в заголовке. Тем не менее, если вам все еще интересно узнать, как понимать поведение Erlang / Elixir, я некоторое время назад написал две статьи и дал доклад об этом на CodeBEAM SF 2019 . Надеюсь, это поможет:)

...