Erlang组播
时间:2020-03-05 18:57:37 来源:igfitidea点击:
如何在Erlang中使用gen_udp进行多播?我在代码中知道它,后面没有任何文档。发送数据是显而易见且简单的。我想知道如何添加成员资格。不仅在启动时添加成员身份,而且在运行时添加成员身份也很有用。
解决方案
回答
组播由IP地址指定
erlang和所有语言都一样。 IP地址224.0.0.0到239.255.255.255是多播地址。
选择一个在该范围内的地址,检查我们没有与已经分配的地址重叠,并且一切顺利。
http://www.iana.org/assignments/multicast-addresses
回答
已答复多播发送,接收需要订阅多播组。
它(仍然)似乎没有记录,但是以前在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}}`以停止收听该组。
回答
这是有关如何监听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.
回答
我尝试使此示例在我的PC上运行。如果我总是通过打开接收套接字收到消息{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]),
%-> {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}).