Как вы используете gen_udp в Erlang для многоадресной рассылки? Я знаю его в коде, у него нет документации. Отправка данных очевидна и проста. Мне было интересно, как добавить членство. Не только добавление членства при запуске, но и добавление членства во время работы было бы полезно также.
Многоадресная рассылка Erlang
Ответ 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.
Ответ 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
, включая {drop_membership, {Addr, LAddr}}
, чтобы прекратить прослушивание группы.
Ответ 3
Я пытаюсь запустить этот пример на моем ПК. Что может случиться, если я всегда получаю сообщение {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}).
Ответ 4
Многоадресная рассылка определяется IP-адресом
Это то же самое в erlang, что и для всех языков. IP-адреса 224.0.0.0 - 239.255.255.255 - это адреса многоадресной рассылки.
Выберите адрес в этом диапазоне, убедитесь, что вы не перекрываете уже назначенный адрес, и вам хорошо идти.