如何在Erlang中使用gen_udp进行多播？

Question

您如何使用Erlang中的gen_udp来执行multicasting？我知道它在代码中，后面没有任何文档。发送数据是显而易见且简单的。我想知道如何添加成员资格。不仅在启动时添加成员身份，而且在运行时添加成员身份也会很有用。

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

已答复多播发送，接收需要订阅多播组。

它（仍然）似乎没有记载，但是以前在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，包括inet:setopts以停止收听该组。

Answer 3

我试图在PC上运行此示例。如果我总是通过打开接收套接字收到消息{error，eaddrnotavail}，会发生什么情况？

示例1：有效：

{drop_membership, {Addr, LAddr}}

示例2：获取运行时错误：

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

％-> {error，eaddrnotavail}

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

Answer 4

多播由IP地址指定

erlang中的所有语言都是相同的。 IP地址224.0.0.0到239.255.255.255是多播地址。

选择该范围内的地址，请确认您没有与已经分配的地址重叠，并且可以使用。

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