Erlang Multicast

Question

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

Answer 1

Вот пример кода о том, как прослушивать трафик 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. 

Answer 2

Multicast задается IP-адрес

Это то же самое в Erlang, как и для всех языков. IP-адреса 224.0.0.0 - 239.255.255.255 - это адреса многоадресной рассылки.

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

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

Answer 3

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

Он (все еще) кажется недокументированным, но ранее был включен в список рассылки 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}}, чтобы прекратить слушать группу.

Answer 4

Я стараюсь, чтобы этот пример работал на моем ПК. Что может случиться, если я всегда получаю сообщение {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]), 

% -> {ошибка, EADDRNOTAVAIL}

-define(SERVER_IP, {10,31,123,123}). % The IP of the current computer 
-define(PORT, 5353). 
-define(MULTICAST_IP, {224,0,0,251}).