Domanda
Come si usa gen_udp in Erlang per eseguire il multicasting?So che è nel codice, semplicemente non c'è documentazione dietro.L'invio dei dati è ovvio e semplice.Mi chiedevo come aggiungere abbonamenti.Sarebbe utile non solo aggiungere abbonamenti all'avvio, ma anche aggiungere abbonamenti durante l'esecuzione.
Soluzione
Ecco un codice di esempio su come ascoltare il traffico 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.
Altri suggerimenti
È stata data risposta all'invio multicast, la ricezione richiede l'iscrizione al gruppo multicast.
Sembra (ancora) non documentato, ma è già stato trattato nella mailing list delle domande erlang. 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}}]).
dove il Addr
è il gruppo multicast e LAddr
è un'interfaccia locale.(codice per gentile concessione di mog)
È possibile passare alle stesse opzioni usate sopra inet:setopts
Compreso {drop_membership, {Addr, LAddr}}
smettere di ascoltare il gruppo.
Provo a far funzionare questo esempio sul mio PC.Cosa potrebbe succedere se ricevo sempre il messaggio {error,eaddrnotavail} aprendo il socket di ricezione?
Esempio 1:Funziona:
{ok, Socket} = gen_udp:open(?PORT, [{reuseaddr,true}, {ip,?SERVER_IP},
{multicast_ttl,4}, {multicast_loop,false}, binary]),
Esempio 2:Ricevo un errore di runtime:
{ok, Socket} = gen_udp:open(?PORT, [{reuseaddr,true}, {ip,?MULTICAST_IP},
{multicast_ttl,4}, {multicast_loop,false}, binary]),
% --> {errore,eaddrnotavail}
-define(SERVER_IP, {10,31,123,123}). % The IP of the current computer
-define(PORT, 5353).
-define(MULTICAST_IP, {224,0,0,251}).
Il multicast è specificato dall'indirizzo IP
In Erlang è lo stesso come in tutte le lingue.Gli indirizzi IP da 224.0.0.0 a 239.255.255.255 sono indirizzi multicast.
Scegli un indirizzo in quell'intervallo, controlla che non si sovrapponga a un indirizzo già assegnato e sei a posto.