erlang: UNIX-Domain-Socket-Unterstützung?
-
16-09-2019 - |
Frage
Gibt es eine Möglichkeit UNIX Domain Sockets zuzugreifen (z / var / run / dbus / system_bus_socket) direkt von Erlang ohne Rückgriff auf einen Treiber von Drittanbietern?
Lösung
Erlang / OTP wird mit Treibern für TCP- und UDP-Sockets nur. So ...
Nein.
Der dritte Teil Treiber
- unixdom_drv in http://jungerl.sourceforge.net/
- uds_dist in der Fahrer Beispiele des Quellbaum
- procket unter https://github.com/msantos/procket
Andere Tipps
In Erlang / OTP 19,0, UNIX Sockets ist ab sofort verfügbar, wie in der Readme-Datei angegeben
OTP-13572 Applikation (en): erts, kernel
Verwandte Id (n): PR-612
* HIGHLIGHT *
Experimentelle Unterstützung für Unix Domain Sockets wurde umgesetzt. Lesen Sie die Quellen, wenn Sie es versuchen wollen aus. Beispiel: gen_udp: open (0, [{Ifaddr, {local "/ tmp / socket"}}]). Dokumentation wird nach Nutzer-Feedback über die experimentelle API geschrieben werden.
Beispiel:
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.
Und folgendes zeigt seine Ergebnisse:
$ 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>
Die nanomsg
Bibliothek Unix-Domain-Sockets unterstützt, und die enm
Treiber eine Erlang-Sprachbindung für nanomsg
bietet.
Beispiel zum Öffnen der Antwortseite eines Anforderungs- / Antwort-Protokolls und bindet an eine Adresse Unix Domain-Socket:
Url = "ipc:///path/to/socket/file",
{ok,Rep} = enm:rep([{bind,Url}]),
Hier Rep
ist eine nanomsg
Buchse. Es unterstützt send
und recv
sowie alle üblichen Erlang {active, true | false | N}
Modi usw., dass regelmäßige Erlang TCP / SCTP / UDP-Sockets bieten. Weitere Einzelheiten finden Sie in der enm
Github README rel="nofollow">