Эрланг многоадресная рассылка
-
09-06-2019 - |
Вопрос
Как использовать gen_udp в Erlang для многоадресной рассылки?Я знаю, что это есть в коде, просто за этим нет никакой документации.Отправка данных очевидна и проста.Мне было интересно, как добавить членство.Было бы полезно не только добавлять членство при запуске, но и добавлять членство во время работы.
Решение
Вот пример кода о том, как прослушивать трафик 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.
Другие советы
На многоадресную отправку получен ответ, для получения требуется подписка на группу многоадресной рассылки.
Это (все еще) кажется недокументированным, но уже обсуждалось в списке рассылки 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}}
перестать слушать группу.
Я пытаюсь запустить этот пример на своем компьютере.Что может произойти, если я всегда получаю сообщение {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]),
% --> {ошибка,eaddrnotavail}
-define(SERVER_IP, {10,31,123,123}). % The IP of the current computer
-define(PORT, 5353).
-define(MULTICAST_IP, {224,0,0,251}).
Многоадресная рассылка определяется IP-адресом
В эрланге то же самое, что и во всех языках.IP-адреса с 224.0.0.0 по 239.255.255.255 являются адресами многоадресной рассылки.
Выберите адрес в этом диапазоне, убедитесь, что вы не перекрываете уже назначенный адрес, и все готово.