07_TCP 与 UPD 的通信

7.1 TCP链接

i> TCP服务器 与 socket 端口对象

var net = require('net');
var file = require('fs').createWriteStream('./a.txt');

// 或者 server = net.createServer((socket) => {})
var server = net.createServer();

server.maxConnections = 10;
// 设置TCP最大连接数
console.log('TCP服务器的最大连接个数为：%d', server.maxConnections);

server.on('connection', (socket) => {
    console.log('客户端与服务端链接已建立');

    address = socket.address();
    // 新客户端连上时显示，用来读取客户端发送的流数据
    console.log('socket端口对象的地址信息是%j', address);
    // socket端口对象的地址信息是{"address":"127.0.0.1","family":"IPv4","port":999}

    socket.setEncoding('utf8');
    // 连接上，发送什么，可以实时接收到
    socket.on('data', (data) => {
        // 设置了 setEncoding，否则 console.log(data.toString());
        console.log(data);
        console.log('已经接收到%d字节的数据', socket.bytesRead);
    });

    // 暂停 socket 的 data 事件的触发，此时数据暂存在一个单独的缓存区中
    // 激活是 socket.resume();
    // 作用是限制对某个或多个客户端的读取速度，只是暂时放在一个单独的缓存区中
    socket.pause();

    // 将客户端传入的数据写入到文件 socket 对象的 pipe方法
    // 当客户端主动断开时，可以先不关闭，等着触发一个 end 事件
    // 取消写入是 socket.unpipe(file)
    socket.pipe(file, { end: false });

    // 客户端主动关闭
    socket.on('end', () => {
        console.log('客户端连接被关闭');
        // 触发该 end 事件
        file.end('再见');
    });

    socket.setTimeout(10 * 1000);
    socket.on('timeout', () => {
        console.log('10秒内无新的交互,已超时');
        // 既只执行一次 取消再次触发该事件
        socket.setTimeout(0);
    });
});

server.getConnections((err, count) => {
    console.log('当前存在%d个客户端连接', count);
});

// error 是写死的
server.on('error', (e) => {
    if (e.code == 'EADDRINUSE') {
        console.log('服务器地址和端口被占用');
    };
});

server.close(() => {
    console.log('TCP服务器被关闭');
});

// 此时可以 telnet 127.0.0.1 999 连接测试
server.listen(999, '127.0.0.1', () => {
    console.log('服务器开始监听');
    address = server.address();
    console.log('被监听的地址信息为：%j', address);
    // 被监听的地址信息为：{"address":"127.0.0.1","family":"IPv4","port":999
});

i> 创建TCP客户端

 服务端：

var net = require('net');
var server = net.createServer();
var fs = require('fs');

// 建立TCP服务器
server.on('connection', (socket) => {
    console.log('客户端与服务端连接已建立');
    socket.setEncoding('utf8');

    socket.setKeepAlive(true, 5000);

    // 将文件内容发送过去
    // readStream 读取文件流，将读取的内容放到队列缓冲区中
    // 然后 socket.write 从队列缓冲区中拿数据发送
    var readStream = fs.createReadStream('./a.txt');
    readStream.on('data', (data) => {
        var flag = socket.write(data);
        // 如果一次性发不完，则 flag 为 false,否则为 true
        console.log('发送文件内容的返回值' + flag);
        console.log('缓存队列缓存了%d字节的字符', socket.bufferSize);
    });

    // 每当有新的连接进来，都会执行这里
    // 当前接收的客户端连接数为2时，拒绝新的客户端请求
    server.getConnections((err, count) => {
        console.log('现在客户端连接数量是:%d', count);
        if (count == 2) server.close();
        // 与服务器连接发生了错误，错误码为ECONNREFUSED
    });

    socket.on('data', (data) => {
        console.log('接收到客户端发送的数据:' + data);
        // socket.write('你好，Client');
    });


    // 缓冲区 有数据 => 没数据
    socket.on('drain', () => {
        console.log('TCP缓冲区的数据已经全部发送');
    });

    // 客户端 crtl + c 掉
    socket.on('error', (err) => {
        console.log('与客户端通信发生了一个错误，错误码是：%s', err.code);
        // 与客户端通信发生了一个错误，错误码是：ECONNRESET

        // destroy 销毁端口对象，确保端口不会再被利用
        socket.destroy();
        server.close();
    });

    // 客户端调用了 end 方法主动关闭之后
    // 此时 服务端仍然未关闭
    socket.on("end", () => {
        console.log('客户端连接被关闭');

        // 自己也主动关闭
        // 之后也可以用，server.ref() 方法阻止应用程序的关闭
        server.unref();
    });


    // 试着打开/ 关闭 客户端的 end事件，使用 ctrl + c 查看
    // 如果客户端自己正常 end ，则不会有 had_error 错误
    socket.on('close', (had_error) => {
        if (had_error) {
            console.log('由于一个错误导致socket端口被关闭');
            socket.unref();
        } else {
            console.log('socket端口正常关闭');
        }
    });
});


server.on('close', () => {
    console.log('关闭TCP服务器');
});

server.listen(999, '127.0.0.1');

客户端：

var net = require('net');
var client = new net.Socket();
client.setEncoding('utf8');

// TCP 客户端
client.connect(999, '127.0.0.1', () => {
    console.log('已经连接到服务端');
    client.write('你好,Server');
    console.log('当前已经发送%d字节的数据', client.bytesWritten);

    setTimeout(() => {
        // end 方法关闭与服务端的链接
        client.end('10秒后我主动断开,再见');
        console.log('当前已经发送%d字节的数据', client.bytesWritten);
    }, 10 * 1000);
});

client.on('data', (data) => {
    console.log('收到服务端发送的数据：' + data);
});

client.on('error', (err) => {
    console.log('与服务器连接发生了错误，错误码为%s', err.code);
    client.destroy();
});

i> net 模块中的类和方法