erlang:UNIX域套接字支持?

11

有没有一种方法可以直接从Erlang访问UNIX域套接字(例如/var/run/dbus/system_bus_socket),而不需要使用第三方驱动程序?

有没有办法在不使用第三方驱动程序的情况下,直接从Erlang访问UNIX域套接字,如 /var/run/dbus/system_bus_socket ?

2
在Erlang源代码分发中有一个/lib/kernel/examples/uds_dist,但它使用了一个驱动程序。这算第三方吗? :) - Zed
4个回答

14
在Erlang/OTP 19.0中,UNIX套接字现在可用,如自述在readme中:(参见)

OTP-13572 应用程序:erts、kernel

相关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> 

14

那太太太悲哀了。 - igor

1

nanomsg支持Unix域套接字,enm驱动程序nanomsg提供了Erlang语言绑定。

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

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

这里,Rep 是一个 nanomsg 套接字。它支持 sendrecv,以及所有常规 Erlang TCP/SCTP/UDP 套接字提供的 {active, true | false | N} 模式等。有关更多详细信息,请参阅 enm github README


0

如果您想要接收HTTP响应,可以使用hackney,因为hackney提供对UNIX套接字的支持。

hackney:get<<"http+unix://path_to_ sock_file.sock">>


网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接