美文网首页
2016年8月21日学习笔记

2016年8月21日学习笔记

作者: 刘宇龙 | 来源:发表于2016-08-22 08:44 被阅读0次

    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协议之间的差别如附表所示。


    长连接:链接是一个事件,需要时激发就可以。
    websocket:可以把链接、事件根据需求去执行去激发一个事件去请求数据
    nodejs模块:socket.io模块创建聊天技术 webqq

    聊天客户端:

    //调用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
    });

    相关文章

      网友评论

          本文标题:2016年8月21日学习笔记

          本文链接:https://www.haomeiwen.com/subject/yibwsttx.html