Erlang Multicast
работает с функцией chr ():
fputcsv($f,$array,',',chr(0));
4 ответа
Вот пример кода о том, как прослушивать трафик 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.
Многоадресная передача определяется IP-адресом
, Это - то же в erlang что касается всех языков. IP-адреса 224.0.0.0 до 239.255.255.255 являются групповыми адресами.
Выбор адрес в том диапазоне, проверьте, что Вы не перекрываете уже присвоенный адрес, и Вы хороши для движения.
Многоадресной отправке ответили, получение требует подписки к группе многоадресной передачи.
Это (все еще) кажется недокументированным, но было покрыто в списке рассылки erlang-вопросов прежде. 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]),
% -> {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}).