类 TCPServer

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

如果给出了 hostname，套接字将绑定到它。

serv = TCPServer.new("127.0.0.1", 28561)
s = serv.accept
s.puts Time.now
s.close

在内部，TCPServer.new 调用 getaddrinfo() 函数来获取地址。如果 getaddrinfo() 返回多个地址，TCPServer.new 将尝试为每个地址创建一个服务器套接字，并返回第一个成功的套接字。

static VALUE
tcp_svr_init(int argc, VALUE *argv, VALUE sock)
{
    VALUE hostname, port;

    rb_scan_args(argc, argv, "011", &hostname, &port);
    return rsock_init_inetsock(sock, hostname, port, Qnil, Qnil, INET_SERVER, Qnil, Qnil);
}

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

TCPServer.open("127.0.0.1", 14641) {|serv|
  s = serv.accept
  s.puts Time.now
  s.close
}

static VALUE
tcp_accept(VALUE server)
{
    union_sockaddr buffer;
    socklen_t length = sizeof(buffer);

    return rsock_s_accept(rb_cTCPSocket, server, &buffer.addr, &length);
}

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

示例¶ ↑

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

有关如果对 TCPServer#accept_nonblock 的调用失败可能会抛出的异常，请参阅 Socket#accept。

TCPServer#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。

参见¶ ↑

• TCPServer#accept

• Socket#accept

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

监听连接，使用指定的 int 作为 backlog。只有当 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 要求在 socket 可以 listen 之前，必须通过调用 bind 来绑定它。

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

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

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

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

• Errno::EINVAL - socket 已经连接

• Errno::ENOTSOCK - socket 参数不引用套接字

• Errno::EOPNOTSUPP - socket 协议不支持 listen

• 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 函数

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);
}

返回已接受连接的文件描述符。

TCPServer.open("127.0.0.1", 28561) {|serv|
  fd = serv.sysaccept
  s = IO.for_fd(fd)
  s.puts Time.now
  s.close
}

static VALUE
tcp_sysaccept(VALUE server)
{
    union_sockaddr buffer;
    socklen_t length = sizeof(buffer);

    return rsock_s_accept(0, server, &buffer.addr, &length);
}