网络#

稳定度: 3 - 稳定

net 模块封装了异步网络功能，提供了一些方法来创建服务器和客户端（称之为流）。您可以用 require('net') 来引入这个模块。

net.createServer([options], [connectionListener])#

创建一个新的 TCP 服务器。参数 connectionListener 会被自动作为 'connection' 事件的监听器。

options 是一个包含下列缺省值的对象：

{ allowHalfOpen: false
}

如果允许半开连接 allowHalfOpen 被设置为 true，则当另一端的套接字发送 FIN 报文时套接字并不会自动发送 FIN 报文。套接字会变为不可读，但仍然可写。您应当明确地调用 end() 方法。详见 'end' 事件。

下面是一个监听 8124 端口连接的应答服务器的例子：

var net = require('net');
var server = net.createServer(function(c) { // 'connection' 监听器
  console.log('服务器已连接');
  c.on('end', function() {
    console.log('服务器已断开');
  });
  c.write('hello\r\n');
  c.pipe(c);
});
server.listen(8124, function() { // 'listening' 监听器
  console.log('服务器已绑定');
});

使用 telnet 测试：

telnet localhost 8124

要监听套接字 /tmp/echo.sock 仅需更改倒数第三行代码：

server.listen('/tmp/echo.sock', function() { // 'listening' 监听器

使用 nc 连接到一个 UNIX domain 套接字服务器：

nc -U /tmp/echo.sock

net.connect(options, [connectionListener])#

net.createConnection(options, [connectionListener])#

构建一个新的套接字对象并打开所给位置的套接字。当套接字就绪时会触发 'connect' 事件。

对于 TCP 套接字，选项 options 参数应为一个指定下列参数的对象：

• port：客户端连接到的端口（必须）

• host：客户端连接到的主机，缺省为 'localhost'

• localAddress：网络连接绑定的本地接口

• family：IP 栈版本，缺省为 4

对于 UNIX domain 套接字，选项 options 参数应当为一个指定下列参数的对象：

• path：客户端连接到的路径（必须）

通用选项：

• allowHalfOpen：允许半开连接，如果被设置为 true，则当另一端的套接字发送 FIN 报文时套接字并不会自动发送 FIN 报文。缺省为 false。详见 'end' 事件。

connectListener 用于 'connect' 事件的监听器

下面是一个上述应答服务器的客户端的例子：

var net = require('net');
var client = net.connect({port: 8124},
    function() { //'connect' 监听器
  console.log('client connected');
  client.write('world!\r\n');
});
client.on('data', function(data) {
  console.log(data.toString());
  client.end();
});
client.on('end', function() {
  console.log('客户端断开连接');
});

要连接到套接字 /tmp/echo.sock，仅需将第二行改为

var client = net.connect({path: '/tmp/echo.sock'},

net.connect(port, [host], [connectListener])#

net.createConnection(port, [host], [connectListener])#

创建一个 host 主机 port 端口的 TCP 连接。如果省略 host 则假定为 'localhost'。connectListener 参数会被用作 'connect' 事件的监听器。

net.connect(path, [connectListener])#

net.createConnection(path, [connectListener])#

创建一个到路径 path 的 UNIX 套接字连接。connectListener 参数会被用作 'connect' 事件的监听器。

类: net.Server#

该类用于创建一个 TCP 或 UNIX 服务器。服务器本质上是一个可监听传入连接的 net.Socket。

server.listen(port, [host], [backlog], [callback])#

在指定端口 port 和主机 host 上开始接受连接。如果省略 host 则服务器会接受来自所有 IPv4 地址（INADDR_ANY）的连接；端口为 0 则会使用分随机分配的端口。

积压量 backlog 为连接等待队列的最大长度。实际长度由您的操作系统通过 sysctl 设置决定，比如 Linux 上的 tcp_max_syn_backlog 和 somaxconn。该参数缺省值为 511（不是 512）。

这是一个异步函数。当服务器已被绑定时会触发 'listening' 事件。最后一个参数 callback 会被用作 'listening' 事件的监听器。

有些用户会遇到的情况是遇到 'EADDINUSE' 错误。这表示另一个服务器已经运行在所请求的端口上。一个处理这种情况的方法是等待一段时间再重试

server.on('error', function (e) {
  if (e.code == 'EADDRINUSE') {
    console.log('地址被占用，重试中...');
    setTimeout(function () {
      server.close();
      server.listen(PORT, HOST);
    }, 1000);
  }
});

（注意：Node 中的所有套接字已设置了 SO_REUSEADDR）

server.listen(path, [callback])#

启动一个 UNIX 套接字服务器在所给路径 path 上监听连接。

这是一个异步函数。当服务器已被绑定时会触发 'listening' 事件。最后一个参数 callback 会被用作 'listening' 事件的监听器。

server.listen(handle, [callback])#

• handle处理器 {Object}
• callback回调函数 {Function}

handle 变量可以被设置为server 或者 socket(任一以下划线开头的成员 _handle), 或者一个 {fd: <n>} 对象

这将使服务器用指定的句柄接受连接，但它假设文件描述符或者句柄已经被绑定在特定的端口或者域名套接字。

Windows 不支持监听一个文件描述符。

这是一个异步函数。当服务器已被绑定时会触发 'listening' 事件。最后一个参数 callback 会被用作 'listening' 事件的监听器。

server.close([callback])#

用于停止服务器接受新连接，但保持已存在的连接。这是一个异步函数， 服务器将在所有的连接都结束后关闭，并且服务器发送 'close'事件 你可以有选择的传入回调函数来监听 'close'事件。

server.address()#

返回操作系统报告的绑定的地址，协议族和端口。 对查找操作系统分配的地址哪个端口已被分配非常有用， 如. { port: 12346, family: 'IPv4', address: '127.0.0.1' }

实例：

// 获得随机端口
server.listen(function() {
  address = server.address();
  console.log("opened server on %j", address);
});

在 'listening' 事件发生前请勿调用 server.address()。

server.unref()#

如果这是事件系统中唯一一个活动的服务器，调用 unref 将允许程序退出。如果服务器已被 unref，则再次调用 unref 并不会产生影响。

server.ref()#

与 unref 相反，如果这是仅剩的服务器，在一个之前被 unref 了的服务器上调用 ref 将不会让程序退出（缺省行为）。如果服务器已经被 ref，则再次调用 ref 并不会产生影响。

server.maxConnections#

设置这个选项能在当服务器连接数超过数量时拒绝连接。

这个选项不推荐使用在套接字已经用 child_process.fork()发送给子进程。

server.connections#

这个函数已被 废弃; 请用 [server.getConnections()][] 代替. 服务器的当前活动连接的数量。

当用child_process.fork()发送一个套接字给子进程时，它将是 null 。 要轮询子进程来获取当前活动的连接请用 server.getConnections 代替.

net.Server 是一个包含下列事件的 EventEmitter :

server.getConnections(callback)#

异步获取服务器当前活跃的连接数. 用于套接字呗发送给子进程。

回调函数需要两个参数 err 和 count.

事件: 'listening'#

在服务器调用 server.listen绑定后触发。

事件: 'connection'#

• {Socket object} 连接对象

在一个新连接被创建时触发。 socket 是一个net.Socket的实例。

事件: 'close'#

当服务被关闭时触发. 注意：如果当前仍有活动连接，他个事件将等到所有连接都结束后才触发。

事件: 'error'#

• {Error Object}

当一个错误发生时触发。 'close' 事件将直接被下列时间调用。 请查看讨论 server.listen的例子。

类: net.Socket#

这个对象是一个TCP或UNIX套接字的抽象。 net.Socket 实例实现了一个双工流接口。 他们可以被用户使用在客户端(使用 connect()) 或者它们可以由 Node创建，并通过 'connection'服务器事件传递给用户。

new net.Socket([options])#

构造一个新的套接字对象。

options 是一个包含下列缺省值的对象：

{ fd: null
  type: null
  allowHalfOpen: false
}

fd 允许你指定一个存在的文件描述符和套接字。 type 指定一个优先的协议。 他可以是 'tcp4', 'tcp6', 或 'unix'. 关于 allowHalfOpen, 参见 createServer() 和 'end' 事件。

socket.connect(port, [host], [connectListener])#

socket.connect(path, [connectListener])#

使用传入的套接字打开一个连接 如果 port 和 host 都被传入， 那么套接字将会被已TCP套接字打开，如果 host 被省略, 默认为localhost . 如果 path 被传入, 套接字将会被已指定路径UNIX套接字打开。

一般情况下这个函数是不需要使用, 比如用 net.createConnection 打开套接字. 只有在您实现了自定义套接字时候才需要。

这是一个异步函数。 当 'connect' 触发了的套接字是established状态 .或者在连接的时候出现了一个问题, 'connect' 事件不会被触发， 而 'error' 事件会触发并发送异常信息。

connectListener 用于 'connect' 事件的监听器

socket.bufferSize#

是一个net.Socket 的属性，用于 socket.write() . 用于帮助用户获取更快的运行速度。 计算机不能一直处于大量数据被写入状态 —— 网络链接可能会变得过慢。 Node 在内部会排队等候数据被写入套接字并确保传输连接上的数据完好。 (内部实现为：轮询套接字的文件描述符等待它为可写).

内部缓冲的可能后果是内存使用会增加。这个属性表示了现在处于缓冲区等待被写入的字符数。（字符的数目约等于要被写入的字节数，但是缓冲区可能包含字符串，而字符串是惰性编码的，所以确切的字节数是未知的。）

遇到数值很大或者增长很快的bufferSize的时候，用户应该尝试用pause()和resume()来控制数据流。

socket.setEncoding([encoding])#

设置套接字的编码为一个可读流. 更多信息请查看 stream.setEncoding()

socket.write(data, [encoding], [callback])#

在套接字上发送数据。第二参数指明了使用字符串时的编码方式-默认为UTF8编码。

如果所有数据被成功刷新到内核缓冲区，则返回true。如果所有或部分数据在用户内存里还处于队列中，则返回false。当缓冲区再次被释放时，'drain'事件会被分发。

当数据最终被完整写入时，可选的callback参数会被执行 - 但不一定是马上执行。

socket.end([data], [encoding])#

半关闭套接字 如., 它发送一个 FIN 包 .可能服务器仍在发送数据。

如果 data被传入, 等同于调用 socket.write(data, encoding) 然后调用 socket.end().

socket.destroy()#

确保没有I/O活动在这个套接字。 只有在错误发生情况下才需要（处理错误等等）。

socket.pause()#

暂停读取数据。 'data' 事件不会被触发。 对于控制上传非常有用。

socket.resume()#

在调用 pause()后恢复读操作。

socket.setTimeout(timeout, [callback])#

如果套接字超过timeout毫秒处于闲置状态，则将套接字设为超时。默认情况下net.Socket不存在超时。

当一个闲置超时被触发时，套接字会接收到一个'timeout'事件，但是连接将不会被断开。用户必须手动end()或destroy()这个套接字。

如果timeout为0，那么现有的闲置超时会被禁用。

可选的callback参数将会被添加成为'timeout'事件的一次性监听器。

socket.setNoDelay([noDelay])#

禁用纳格（Nagle）算法。默认情况下TCP连接使用纳格算法，这些连接在发送数据之前对数据进行缓冲处理。 将noDelay设成true会在每次socket.write()被调用时立刻发送数据。noDelay默认为true。

socket.setKeepAlive([enable], [initialDelay])#

禁用/启用长连接功能，并在第一个在闲置套接字上的长连接probe被发送之前，可选地设定初始延时。enable默认为false。

设定initialDelay (毫秒)，来设定在收到的最后一个数据包和第一个长连接probe之间的延时。将initialDelay设成0会让值保持不变(默认值或之前所设的值)。默认为0。

socket.address()#

返回 socket 绑定的IP地址, 协议类型 (family name) 以及 端口号 (port). 具体是一个包含三个属性的对象, 形如 { port: 12346, family: 'IPv4', address: '127.0.0.1' }

socket.unref()#

如果这是事件系统中唯一一个活动的套接字，调用 unref 将允许程序退出。如果套接字已被 unref，则再次调用 unref 并不会产生影响。

socket.ref()#

与 unref 相反，如果这是仅剩的套接字，在一个之前被 unref 了的套接字上调用 ref 将不会让程序退出（缺省行为）。如果一个套接字已经被 ref，则再次调用 ref 并不会产生影响。

socket.remoteAddress#

远程IP地址的字符串表示。例如，'74.125.127.100'或 '2001:4860:a005::68'。

socket.remotePort#

远程端口的数值表示。例如，80 或 21。

socket.localAddress#

远程客户端正在连接的本地IP地址的字符串表示。例如，如果你在监听'0.0.0.0'而客户端连接在'192.168.1.1'，这个值就会是 '192.168.1.1'。

socket.localPort#

本地端口的数值表示。比如80 或 21。

socket.bytesRead#

所接收的字节数。

socket.bytesWritten#

所发送的字节数。

net.Socket实例是带有以下事件的EventEmitter对象：

事件: 'lookup'#

这个事件在解析主机名之后，连接主机之前被分发。对UNIX套接字不适用。

• err {Error | Null} 错误对象。见[dns.lookup()][]。
• address {String} IP地址。
• family {String | Null} 得知类型。见[dns.lookup()][]。

事件: 'connect'#

该事件在一个套接字连接成功建立后被分发。见connect()。

事件: 'data'#

• {Buffer object}

当收到数据时被分发。data参数会是一个Buffer或String对象。数据的编码方式由socket.setEncoding()设定。 （详见 [可读流][] 章节）

请注意，如果一个Socket对象分发一个'data'事件时没有任何监听器存在，则 数据会丢失。

事件: 'end'#

当套接字的另一端发送FIN包时，该事件被分发。

默认情况下 （allowHalfOpen == false），当套接字完成待写入队列中的任务时，它会destroy文件描述符。然而，如果把allowHalfOpen设成true，那么套接字将不会从它这边自动调用end()，使得用户可以随意写入数据，但同时使得用户自己需要调用end()。

事件: 'timeout'#

当套接字因为非活动状态而超时时该事件被分发。这只是用来表明套接字处于空闲状态。用户必须手动关闭这个连接。

参阅：socket.setTimeout()

事件: 'drain'#

当写入缓冲被清空时产生。可被用于控制上传流量。

参阅：socket.write() 的返回值

事件: 'error'#

• {Error object}

当一个错误发生时产生。'close' 事件会紧接着该事件被触发。

事件: 'close'#

• had_error {Boolean} 如果套接字发生了传输错误则此字段为true

当套接字完全关闭时该事件被分发。参数had_error是一个布尔值，表示了套接字是否因为一个传输错误而被关闭。

net.isIP(input)#

测试 input 是否 IP 地址。无效字符串返回 0；IP 版本 4 地址返回 4；IP 版本 6 地址返回 6。

net.isIPv4(input)#

如果 input 为版本 4 地址则返回 true，否则返回 false。

net.isIPv6(input)#

如果 input 为版本 6 地址则返回 true，否则返回 false。