socket实时聊天技术

知识点：

网络协议：TCP、UDP、TLS、DCCP、SCTP、RSVP、OSPF 等
网络：tcp(4层)模型和osi(7层)模型

TCP/IP:

数据链路层：ARP,RARP
网络层： IP,ICMP,IGMP
传输层：TCP ,UDP,UGP
应用层：Telnet,FTP,SMTP,SNMP `

OSI:

物理层：EIA/TIA-232, EIA/TIA-499, V.35, V.24, RJ45, Ethernet, 802.3, 802.5, FDDI, NRZI, NRZ, B8ZS
数据链路层：Frame Relay, HDLC, PPP, IEEE 802.3/802.2, FDDI, ATM, IEEE 802.5/802.2
网络层：IP，IPX，AppleTalk DDP
传输层：TCP，UDP，SPX
会话层：RPC,SQL,NFS,NetBIOS,names,AppleTalk,ASP,DECnet,SCP
表示层:TIFF,GIF,JPEG,PICT,ASCII,EBCDIC,encryption,MPEG,MIDI,HTML
应用层：FTP,WWW,Telnet,NFS,SMTP,Gateway,SNMP
网络链接方式：全双工、半双工、单双工
全双工：既可以发送数据，也可以接受数据，同时进行，比如：闭路电视
单工模式：只能接收不能发送 比如：闭路电视
双工模式：网络、电话
TCP、UDP区别：
TCP协议和UDP协议各有所长、各有所短，适用于不同要求的通信环境。TCP协议和UDP协议之间的差别如附表所示。

聊天客户端：

//调用net模块
const net = require('net');
//回调函数，设置端口号
const client = net.connect({port: 8888}, () => {
  // 'connect' listener
  console.log('连上去了~!');

});
//执行on方法，接收data数据
client.on('data', (data) => {
  console.log('收到数据');
//以字符串类型输出数据
  console.log(data.toString());
});
//执行on方法，断开连接
client.on('end', () => {
  console.log('断开了');
    rl.close();
});
//调用readline模块
const readline = require('readline');
const rl = readline.createInterface(process.stdin, process.stdout);
console.log('多人聊天室');
// console.log('1.进入聊天室');
console.log('88.不聊了走人～');
rl.setPrompt('随便说点什么吧～> ');
rl.prompt();

rl.on('line', (line) => {
  switch(line.trim()) {
    // case '1':
    //   console.log('连接聊天服务中');
    //   break;
    case '88':
      console.log('欢迎下次再来～玩耍哦～～!');
      rl.close();
      break;
    default:
        s=line.trim();
        client.write(s+'\r\n');
        rl.setPrompt('随便说点什么吧～> ');
        rl.prompt();
      break;
  }
}).on('close', () => {
  console.log('记得回来继续聊.');
  process.exit(0);
});

聊天服务器端：

//调用net模块
var net = require('net');
//创建socket服务
var server = net.createServer((socket) => {
//获取当前时间
    var time = getTime();
    //加入一个标志
    //加入到客户列表中
    var name = clients.add( socket );
    //接收客户发过来的信息
    socket.on('data', function(data) {
        // guangbo(data, socket);// 接受来自客户端的信息
        console.log('收到数据啦---' );
        //接收数据并转换为字符串类型
        console.log(data.toString());
        //发送给所有人
        clients.sendAll(socket,data);
    });
    //客户关闭了连接
    //执行socket的on事件，关闭事件，回调函数
    socket.on('close', function(data) {
        //输出字符串和IP地址
        console.log('客户走了~: ' + socket.remoteAddress + ' ' + socket.remotePort);
        //删除客户
        clients.del(socket);
        //发送给所有人，并且发送客户列表的人数
        clients.sendAll(socket, '有人走了!当前聊天人数:' + clients.length());
    });
    //执行客户连接的事件
    console.log('有人连了,客户端数量:'+ clients.length() );
    console.log('有人连了,客户端数量:'+ clients.length() );
    //使用socket的write方法输出
    socket.write(time +'  欢迎进来聊天~ ' + name + '!\n' + '当前聊天人数:' + clients.length());
    //发送给所有人当前聊天人数
    clients.sendAll(socket, '有人进来了!当前聊天人数:' + clients.length());
}).on('error', (err) => {//执行on事件检测是否有异常
  // handle errors here
  throw err;
});
//实例化一个对象
clients = new Object();
//数组
clients.list = [];
//添加客户端到客户列表
/*
    socket  当前的连接
*/
clients.add = function(socket){
    socket.name = socket.remoteAddress + ':' + socket.remotePort;
    this.list.push(socket);
    return socket.name;
}
//从客户端列表删除
/*
    socket  当前的socket
*/
//执行删除操作
clients.del = function(socket){
    console.log('用户要走了!删除他!!');

    for(var i=0 ; i < this.list.length ; i++){
        if(socket == this.list[i]){
            console.log('用户要走了!已经删除了~~~');

            this.list.splice(i,1);
        }
    }
}
//把信息发给全部人
/*
    socket 当前的连接
    data   要发送的数据
*/
clients.sendAll = function(socket,data){
    console.log('开始发送给全部人啦!!');
    for(var i=0 ; i < this.list.length ; i++){
        if(socket !== this.list[i]){
            var o = this.list[i];
            //检查socket是否可以写
            if (o.writable) {
                console.log('发送给:' + o.name);
                o.write('-----\n' + getTime() + '\n' + socket.name + '说:\n');
                o.write(data);
                o.write('-----');
            } else {
                console.log('socket 失效了:' + o.name);
                //socket断开了什么的,就不能发送啦,需要删除这个连接
                this.del(o);
            }

        }

    }
}
clients.length = function(){
    return this.list.length;
}


// 对Date的扩展，将 Date 转化为指定格式的String
// 月(M)、日(d)、小时(h)、分(m)、秒(s)、季度(q) 可以用 1-2 个占位符，
// 年(y)可以用 1-4 个占位符，毫秒(S)只能用 1 个占位符(是 1-3 位的数字)
// 例子：
// (new Date()).Format("yyyy-MM-dd hh:mm:ss.S") ==> 2006-07-02 08:09:04.423
// (new Date()).Format("yyyy-M-d h:m:s.S")      ==> 2006-7-2 8:9:4.18
Date.prototype.Format = function (fmt) { //author: meizz
    var o = {
        "M+": this.getMonth() + 1, //月份
        "d+": this.getDate(), //日
        "h+": this.getHours(), //小时
        "m+": this.getMinutes(), //分
        "s+": this.getSeconds(), //秒
        "q+": Math.floor((this.getMonth() + 3) / 3), //季度
        "S": this.getMilliseconds() //毫秒
    };
    if (/(y+)/.test(fmt)) fmt = fmt.replace(RegExp.$1, (this.getFullYear() + "").substr(4 - RegExp.$1.length));
    for (var k in o)
    if (new RegExp("(" + k + ")").test(fmt)) fmt = fmt.replace(RegExp.$1, (RegExp.$1.length == 1) ? (o[k]) : (("00" + o[k]).substr(("" + o[k]).length)));
    return fmt;
}


function getTime(){
    return new Date().Format("yyyy-MM-dd hh:mm:ss");
}



//开启聊天服务器~~
server.listen({
  host: 'localhost',
  port: 8888,
  exclusive: true
});