Multicast de Erlang

Question

Como você usa gen_udp em Erlang para fazer multicast?Eu sei que está no código, simplesmente não há documentação por trás disso.O envio de dados é óbvio e simples.Eu queria saber como adicionar assinaturas.Não apenas adicionar assinaturas na inicialização, mas adicionar assinaturas durante a execução também seria útil.

Answer 1

Aqui está um exemplo de código sobre como ouvir o tráfego 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

O envio multicast foi respondido, o recebimento requer inscrição no grupo multicast.

(Ainda) parece não documentado, mas já foi abordado na lista de discussão erlang-questions antes. 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}}]).

onde o Addr é o grupo multicast, e LAddr é uma interface local.(código cortesia de mog)

As mesmas opções usadas acima podem ser passadas para inet:setopts Incluindo {drop_membership, {Addr, LAddr}} parar de ouvir o grupo.

Answer 3

Tento fazer este exemplo rodar no meu PC.O que poderia acontecer se eu recebesse sempre a mensagem {error,eaddrnotavail} ao abrir o soquete de recebimento?

Exemplo 1:Isso funciona:

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

Exemplo 2:Obtendo um erro de tempo de execução:

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

% --> {erro, eaddrnotavail}

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

Answer 4

Multicast é especificado pelo endereço IP

É o mesmo em erlang e em todos os idiomas.Os endereços IP 224.0.0.0 a 239.255.255.255 são endereços multicast.

Escolha um endereço nesse intervalo, verifique se você não está sobrepondo um endereço já atribuído e pronto.

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