UDP server

UDP 收到的數(shù)據(jù)是有邊界的, 可以確定收到的數(shù)據(jù)是發(fā)送端發(fā)出來的一個完整包.

const dgram = require('dgram');
const events = require('events');
const ip = require('internal-ip');

module.exports = class UDPServer extends events.EventEmitter {
    constructor(port) {
        super();
        this.port = port;
        this.server = dgram.createSocket('udp4');
        this.server.on('error', err => {
            console.log(`UDP 服務異常: ${err.stack}`);
            this.server.close();
        });
        this.server.on('listening', async () => {
            var host = await ip.v4();
            console.log(`UDP 服務監(jiān)聽 ${host}:${this.port}`);
        })
        this.server.on('message', (msg, addr) => {
            console.log(`UDP 服務收到數(shù)據(jù)長度: ${msg.length}`);
        })
        this.server.bind(this.port);
    }
}

TCP server

TCP 收到的數(shù)據(jù)是流式的, 需要通過讀取固定字節(jié)頭的方式來解析數(shù)據(jù)包的邊界.

const net = require('net');
const events = require('events');
const ip = require('internal-ip');

module.exports = class TCPServer extends events.EventEmitter {
    constructor(port) {
        super();
        this.port = port;
        this.server = net.createServer();
        this.server.on('listening', async () => {
            var host = await ip.v4();
            console.log(`TCP 服務監(jiān)聽 ${host}:${this.port}`);
        })
        this.server.on('connection', socket => {
            console.log(`TCP server has a new connection`);
            socket.on('error', e => {
                console.log(`connect error: ${e.stack}`);
            })
            socket.on('end', () => {
                console.log('connect end');
            })
        })
        this.server.on('close', () => {
            console.log('TCP server closed');
        })
        this.server.listen(this.port);
    }
}