erlang: Suporte soquete de domínio UNIX?

Question

Existe uma maneira de soquetes de domínio UNIX acesso (por exemplo, / var / run / dbus / system_bus_socket) diretamente do Erlang sem recorrer a um driver de terceiros?

Answer 1

Erlang / OTP vem com drivers para TCP e UDP apenas soquetes. Então ...

Não.

motoristas terceira parte

• http://jungerl.sourceforge.net/
• uds_dist em Exemplos de driver da árvore de origem
• Procket em https://github.com/msantos/procket

Answer 2

Em Erlang / OTP 19,0, UNIX Sockets estão agora disponíveis, como indicado no readme :

OTP-13572 Aplicação (s): erts, do kernel

Id relacionada (s): PR-612

* DESTAQUE *

O suporte experimental para Unix Sockets domínio foi implementadas. Leia as fontes se você quiser experimentá-lo Fora. Exemplo: gen_udp: aberta (0, [{Ifaddr, {local, "/ tmp / socket"}}]). vontade documentação ser escrito após o feedback do usuário na API experimental.

Exemplo:

lsock.erl:

-module(lsock).
-export([watcher/1, test/0]).

watcher(Parent) -> 
  {ok, Sockin} = gen_udp:open(0, [{ifaddr, {local, "/tmp/testsockin"}}]),
  io:format("watcher ok? ~w ~w~n", [ok, Sockin]),
  Parent ! start,
  receive
    Msg -> io:format("watcher got: ~p ~n", [Msg]) end.

test() ->
  file:delete("/tmp/testsockin"),
  file:delete("/tmp/testsockout"),
  _ = spawn(lsock, watcher, [self()]),
  {ok, Sockout} = gen_udp:open(0, [{ifaddr, {local, "/tmp/testsockout"}}]),
  io:format("parent ok? ~w ~w~n", [ok, Sockout]),
  receive start ->
    gen_udp:send(Sockout, {local, "/tmp/testsockin"}, 0, "hi") end.

E a seguir demonstra seus resultados:

$ erlc lsock.erl 
$ erl
Erlang/OTP 19 [erts-8.0.1] [source-ca40008] [64-bit] [smp:2:2] [async-threads:10] [hipe] [kernel-poll:false]

Eshell V8.0.1  (abort with ^G)
1> lsock:test().
<0.58.0>
parent ok? ok #Port<0.455>
watcher ok? ok #Port<0.456>
watcher got: {udp,#Port<0.456>,{local,<<"/tmp/testsockout">>},0,"hi"} 
ok
2> 

Answer 3

O nanomsg biblioteca suporta soquetes de domínio Unix, e motorista enm fornece uma ligação para nanomsg linguagem Erlang.

Por exemplo, para abrir o lado da resposta de um pedido de protocolo / resposta e se ligam a um endereço de soquete domínio Unix:

Url = "ipc:///path/to/socket/file",
{ok,Rep} = enm:rep([{bind,Url}]),

Aqui, Rep é um soquete nanomsg. Ele suporta send e recv, bem como todos os habituais modos {active, true | false | N} Erlang, etc. que soquetes / SCTP / UDP regulares Erlang TCP fornecer. Para mais informações consultar o enm github README .