Erlang Multicast - PullRequest
Новая
       34

Erlang Multicast

16 голосов
/ 17 сентября 2008

Как вы используете gen_udp в Erlang для многоадресной рассылки? Я знаю это в коде, за ним просто нет документации. Отправка данных очевидна и проста. Мне было интересно, как добавить членство. Было бы полезно не только добавить членство при запуске, но и добавить членство во время работы.

Ответы [ 4 ]

14 голосов
/ 16 ноября 2009

Пример кода для прослушивания трафика Bonjour / Zeroconf. 

-module(zcclient).

-export([open/2,start/0]).
-export([stop/1,receiver/0]).

open(Addr,Port) ->
   {ok,S} = gen_udp:open(Port,[{reuseaddr,true}, {ip,Addr}, {multicast_ttl,4}, {multicast_loop,false}, binary]),
   inet:setopts(S,[{add_membership,{Addr,{0,0,0,0}}}]),
   S.

close(S) -> gen_udp:close(S).

start() ->
   S=open({224,0,0,251},5353),
   Pid=spawn(?MODULE,receiver,[]),
   gen_udp:controlling_process(S,Pid),
   {S,Pid}.

stop({S,Pid}) ->
   close(S),
   Pid ! stop.

receiver() ->
   receive
       {udp, _Socket, IP, InPortNo, Packet} ->
           io:format("~n~nFrom: ~p~nPort: ~p~nData: ~p~n",[IP,InPortNo,inet_dns:decode(Packet)]),
           receiver();
       stop -> true;
       AnythingElse -> io:format("RECEIVED: ~p~n",[AnythingElse]),
           receiver()
   end.
10 голосов
/ 17 сентября 2008

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

Это (все еще) кажется недокументированным, но ранее оно было включено в список рассылки erlang-questions. http://www.erlang.org/pipermail/erlang-questions/2003-March/008071.html

    {ok, Socket} = gen_udp:open(Port, [binary, {active, false},
                                       {reuseaddr, true},{ip, Addr}, 
                                       {add_membership, {Addr, LAddr}}]).

, где Addr - это группа многоадресной рассылки, а LAddr - локальный интерфейс. (код предоставлен mog)

Те же параметры, что и выше, могут быть переданы на inet:setopts, включая {drop_membership, {Addr, LAddr}}, чтобы прекратить прослушивание группы.

4 голосов
/ 10 декабря 2009

Я пытаюсь запустить этот пример на моем ПК. Что может произойти, если я всегда получаю сообщение {error, eaddrnotavail}, открывая сокет получения?

Пример 1: Это работает: 

{ok, Socket} = gen_udp:open(?PORT, [{reuseaddr,true}, {ip,?SERVER_IP},
               {multicast_ttl,4}, {multicast_loop,false}, binary]),

Пример 2. Получение ошибки выполнения: 

{ok, Socket} = gen_udp:open(?PORT, [{reuseaddr,true}, {ip,?MULTICAST_IP},
               {multicast_ttl,4}, {multicast_loop,false}, binary]),

% -> {error, eaddrnotavail} 

-define(SERVER_IP, {10,31,123,123}). % The IP of the current computer
-define(PORT, 5353).
-define(MULTICAST_IP, {224,0,0,251}).
0 голосов
/ 17 сентября 2008

Групповая адресация указывается по IP-адресу

В эрланге то же самое, что и для всех языков. IP-адреса с 224.0.0.0 по 239.255.255.255 являются многоадресными адресами.

Выберите адрес в этом диапазоне, убедитесь, что вы не перекрываете уже назначенный адрес, и вы готовы идти.

http://www.iana.org/assignments/multicast-addresses

...