class UNIXServer

static VALUE
unix_svr_init(VALUE sock, VALUE path)
{
    return rsock_init_unixsock(sock, path, 1);
}

创建一个新的 UNIX 服务器套接字，绑定到 path。

require 'socket'

serv = UNIXServer.new("/tmp/sock")
s = serv.accept
p s.read

static VALUE
unix_accept(VALUE server)
{
    struct sockaddr_un buffer;
    socklen_t length = sizeof(buffer);

    return rsock_s_accept(rb_cUNIXSocket, server, (struct sockaddr*)&buffer, &length);
}

接受一个传入的连接。它返回一个新的 UNIXSocket 对象。

UNIXServer.open("/tmp/sock") {|serv|
  UNIXSocket.open("/tmp/sock") {|c|
    s = serv.accept
    s.puts "hi"
    s.close
    p c.read #=> "hi\n"
  }
}

# File ext/socket/lib/socket.rb, line 1771
def accept_nonblock(exception: true)
  __accept_nonblock(exception)
end

在底层文件描述符设置了 O_NONBLOCK 之后，使用 accept(2) 接受一个传入的连接。它返回一个为传入连接接受的 UNIXSocket。

示例¶ ↑

require 'socket'
serv = UNIXServer.new("/tmp/sock")
begin # emulate blocking accept
  sock = serv.accept_nonblock
rescue IO::WaitReadable, Errno::EINTR
  IO.select([serv])
  retry
end
# sock is an accepted socket.

请参考 Socket#accept 以了解如果调用 UNIXServer#accept_nonblock 失败可能抛出的异常。

UNIXServer#accept_nonblock 可能会引发任何与 accept(2) 失败相对应的错误，包括 Errno::EWOULDBLOCK。

如果异常是 Errno::EWOULDBLOCK, Errno::EAGAIN, Errno::ECONNABORTED 或 Errno::EPROTO，它将被 IO::WaitReadable 扩展。因此，可以使用 IO::WaitReadable 来捕获异常，以便重试 accept_nonblock。

通过为 exception 关键字参数指定 false，您可以指示 accept_nonblock 不应引发 IO::WaitReadable 异常，而是返回符号 :wait_readable。

参见¶ ↑

• UNIXServer#accept

• Socket#accept

VALUE
rsock_sock_listen(VALUE sock, VALUE log)
{
    rb_io_t *fptr;
    int backlog;

    backlog = NUM2INT(log);
    GetOpenFile(sock, fptr);
    if (listen(fptr->fd, backlog) < 0)
        rb_sys_fail("listen(2)");

    return INT2FIX(0);
}

监听连接，使用指定的 int 作为积压。只有当 socket 的类型为 SOCK_STREAM 或 SOCK_SEQPACKET 时，调用 listen 才适用。

参数¶ ↑

• backlog - 待处理连接队列的最大长度。

示例 1¶ ↑

require 'socket'
include Socket::Constants
socket = Socket.new( AF_INET, SOCK_STREAM, 0 )
sockaddr = Socket.pack_sockaddr_in( 2200, 'localhost' )
socket.bind( sockaddr )
socket.listen( 5 )

示例 2（监听任意端口，仅限基于 Unix 的系统）：¶ ↑

require 'socket'
include Socket::Constants
socket = Socket.new( AF_INET, SOCK_STREAM, 0 )
socket.listen( 1 )

基于 Unix 的异常¶ ↑

在基于 Unix 的系统上，上述代码可以工作，因为会在地址 ADDR_ANY 上创建一个新的 sockaddr 结构体，用于内核分配的任意端口号。它在 Windows 上不起作用，因为 Windows 要求在 listen 之前通过调用 bind 来绑定 socket。

如果 backlog 的值超过了实现相关的最大队列长度，则将使用该实现的最大队列长度。

在基于 Unix 的系统上，如果调用 listen 失败，可能会引发以下系统异常

• Errno::EBADF - socket 参数不是有效的文件描述符

• Errno::EDESTADDRREQ - socket 没有绑定到本地地址，并且协议不支持在未绑定的套接字上监听

• Errno::EINVAL - socket 已连接

• Errno::ENOTSOCK - socket 参数未指向套接字

• Errno::EOPNOTSUPP - socket 协议不支持监听

• Errno::EACCES - 调用进程没有相应的权限

• Errno::EINVAL - socket 已关闭

• Errno::ENOBUFS - 系统中没有足够的资源来完成调用

Windows 异常¶ ↑

在 Windows 系统上，如果调用 listen 失败，可能会引发以下系统异常

• Errno::ENETDOWN - 网络已关闭

• Errno::EADDRINUSE - 套接字的本地地址已被使用。这通常发生在执行 bind 期间，但如果调用 bind 是部分通配符地址（涉及 ADDR_ANY），并且在调用 listen 时需要提交特定地址，则可能会延迟

• Errno::EINPROGRESS - Windows Sockets 1.1 调用正在进行中，或者服务提供商仍在处理回调函数

• Errno::EINVAL - socket 没有通过调用 bind 进行绑定。

• Errno::EISCONN - socket 已连接

• Errno::EMFILE - 没有更多可用的套接字描述符

• Errno::ENOBUFS - 没有可用的缓冲区空间

• Errno::ENOTSOC - socket 不是一个套接字

• Errno::EOPNOTSUPP - 引用的 socket 不是支持 listen 方法的类型

参见¶ ↑

• 基于 Unix 的系统的 listen 手册页

• Microsoft Winsock 函数参考中的 listen 函数

static VALUE
unix_sysaccept(VALUE server)
{
    struct sockaddr_un buffer;
    socklen_t length = sizeof(buffer);

    return rsock_s_accept(0, server, (struct sockaddr*)&buffer, &length);
}

接受新的连接。它返回新的文件描述符，它是一个整数。

UNIXServer.open("/tmp/sock") {|serv|
  UNIXSocket.open("/tmp/sock") {|c|
    fd = serv.sysaccept
    s = IO.new(fd)
    s.puts "hi"
    s.close
    p c.read #=> "hi\n"
  }
}