Erlang Multicast

Question

Comment utilisez-vous gen_udp à Erlang pour la multidiffusion? Je sais que c'est dans le code, il n'y a aucune documentation derrière. L'envoi de données est évident et simple. Je me demandais comment ajouter des abonnements. Il ne serait pas utile non seulement d’ajouter des membres au démarrage, mais également d’ajouter des membres en cours d’exécution.

Answer 1

Voici un exemple de code sur la façon d'écouter le trafic 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

On a répondu à l’envoi en multidiffusion, la réception nécessite un abonnement au groupe de multidiffusion.

Cela (encore) semble non documenté, mais a déjà été couvert sur la liste de diffusion erlang-questions. http://www.erlang.org/pipermail/erlang- questions / 2003-mars / 008071.html

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

où Addr est le groupe de multidiffusion, et LAddr est une interface locale. (code gracieuseté de mog)

Les mêmes options que celles utilisées ci-dessus peuvent être passées à inet : setopts , y compris {drop_membership, {Addr, LAddr}}, pour arrêter d'écouter le groupe.

Answer 3

J'essaie de faire fonctionner cet exemple sur mon PC. Que pourrait-il se passer si je reçois toujours le message {error, eaddrnotavail} en ouvrant le socket de réception?

Exemple 1: cela fonctionne:

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

Exemple 2: Obtention d'une erreur d'exécution:

{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}). 

Answer 4

La multidiffusion est spécifiée par l'adresse IP

C'est la même chose en erlang que pour toutes les langues. Les adresses IP 224.0.0.0 à 239.255.255.255 sont des adresses de multidiffusion.

Choisissez une adresse dans cette plage, vérifiez que vous ne chevauchez pas une adresse déjà attribuée et que vous pouvez continuer.

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