Node.js之TCP（net）_代码007(未授权)

本文介绍: 需要使用到 net 模块，是 node.js 的核心模块，直接可以引入使用。const net = require(‘net‘);Nod e.js 将服务端和客户端区分开了，使用起来还是非常的简单，服务端大概就是监…

最近使用No de js 编写程序，需要用到自己编写的分布式工具，于是需要将Ja va版的用No deJs重新写一遍，需要使用到TCP通信，于是在这里记录下No de.js TCP 的使用方法

const net = require('net');

No de.js 将服务端和客户端区分开了，使用起来还是非常的简单，服务端大概就是监听连接，读写数据

通过 createServer 函数来创建一个服务端，函数接收一个回调函数，用于处理新的客户端连接，回调函数有一个参数 socket，代表与客户端的连接，通过sock e t来读取客户端发送的数据，以及发送数据给客户端

var server = net.createServer(function (socket) {
    console.log("有新的客户端连接了");
});

通过 listen 函数

var port = 80;
server.listen(port, function () {
    // 在启动成功后执行
    console.log(`服务端已启动，端口：${that.port}`);
});

let ip = socket.remoteAddress;
ip = ip.substring(ip.lastIndexOf(":") + 1);

socket.setTimeout(5000, () => {
    socket.end();
});

通过 on 监听 data 事件来读取数据

// data 为 Buffer 类型
socket.on("data", function (data) {
    console.log(data.toString());
});

// 读取的数据缓存
var readData = Buffer.from([]);

// 收到数据触发data事件
socket.on("data", function (data) {
    readData = Buffer.concat([readData, data]);
    let index = readData.indexOf(Buffer.from([20]));
    if (index != -1) {
        // 读取到了一个完整的协议数据，进行处理
        let pData = readData.subarray(0, index + 1);
        // 处理...
        console.log(pData.toString());
        // 处理完从缓存中移除这部分数据
        readData = readData.subarray(index + 1, readData.length);
    } else {
        // 没有读取到完整的协议数据，不做操作
    }
});

socket.write("hello,world", function () {
    console.log(`发送成功，数据长度为：${socket.bytesWritten}`);
});

不管是服务端还是socket，都可以通过 on 来监听事件，同读取数据那样

名称	描述
listen ing	调用 server.listen 后触发
connection	当新连接创建后会被触发。socket 是 net.Socket实例
close	服务器关闭时会触发。注意，如果存在连接，这个事件不会被触发直到所有的连接关闭
error	发生错误时触发

名称	描述
lookup	在解析域名后，但在连接前，触发这个事件。对 UNIX sok cet 不适用
connect	成功建立 socket 连接时触发
data	当接收到数据时触发
end	当 socket 另一端发送 FIN 包时，触发该事件
timeout	当 socket 空闲超时时触发，仅是表明 socket 已经空闲。用户必须手动关闭连接
drain	当写缓存为空时触发。可用来控制上传
error	错误发生时触发
close	当 socket 完全关闭时触发。参数 h ad _error 是布尔值，它表示是否因为传输错误导致 socket 关闭

socket.on('error', function(err) {
    console.log(`客户端出错，err：${err}`);
    that.connNum--;
});

通过 net 模块的 createConnection 创建客户端，函数返回 net.Socket，与上面服务端的Socket是一样的类型，所以使用方法也是一样的

let socket = net.createConnection(port, host);

let socket = net.createConnection(80, "127.0.0.1");

// 发送数据
socket.write(Buffer.from("Shendi"));
socket.on('data', (data) => {
    console.log(`接收到数据: ${data}`);
});

conn.client.on('end', function(data) {
   	console.log(`客户端连连接关闭`);
});

conn.client.on('error', function(err) {
    console.log(`客户端连接出错，err：${err}`);
});