erlang：UNIX 域套接字支持？答案

【问题标题】：erlang: UNIX domain socket support?erlang：UNIX 域套接字支持？
【发布时间】：2010-12-01 12:27:26
【问题描述】：

有没有办法直接从 Erlang 访问 UNIX 域套接字（例如 /var/run/dbus/system_bus_socket ）而不求助于第三方驱动程序？

【问题讨论】：

erlang 源代码发行版中有一个 /lib/kernel/examples/uds_dist，但它使用了驱动程序。这算不算第三方？ :)

标签： linux sockets erlang unix-socket

【解决方案1】：

Erlang/OTP 仅附带 tcp 和 udp 套接字的驱动程序。所以...

没有。

第三方驱动程序

http://jungerl.sourceforge.net/ 中的 unixdom_drv
源树驱动程序示例中的uds_dist
procket 在https://github.com/msantos/procket

【讨论】：

真是太伤心了

【解决方案2】：

nanomsg library 支持 Unix 域套接字，enm driver 为nanomsg 提供 Erlang 语言绑定。

例如，打开请求/响应协议的响应端并绑定到 Unix 域套接字地址：

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

这里，Rep 是一个nanomsg 套接字。它支持send 和recv 以及常规Erlang TCP/SCTP/UDP 套接字提供的所有常见的Erlang {active, true | false | N} 模式等。更多详情请咨询enm github README。

【讨论】：

【解决方案3】：

在 Erlang/OTP 19.0 中，UNIX 套接字现在可用，as stated in the readme：

OTP-13572 应用程序：erts、内核

相关 ID：PR-612

* 亮点 *

对 Unix 域套接字的实验性支持已经实施的。如果您想尝试，请阅读源代码出去。示例：gen_udp:open(0, [{ifaddr,{local,"/tmp/socket"}}])。文件将在用户反馈实验性 API 后编写。

示例：

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.

下面展示了它的结果：

$ 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>

【讨论】：

【解决方案4】：

如果您想接收 http 响应，您可以使用 hackney，因为 hackney 提供对 UNIX socket 的支持。 hackney:get>

【讨论】：