nodejs 服务器&telnet 实现区分多客户端请求服务

缘由:因有多个客户端会不定期的与服务器端建立联系,想要区分哪个客户端来完成相应的处理

原版代码:

var net = require('net');//1 引入net模块  
var chatServer = net.createServer();//创建net服务器  
var clientList=[];//保存多个客户端的数组  
chatServer.on('connection', function (client) {//服务器连接客户端  
    client.name=client.remoteAddress+':'+client.remotePort;  
    /*增加name属性*/  
    client.write('Hi'+client.name+'!\n');  
    clientList.push(client);  
    client.on('data', function (data) {  
    /*添加事件监听器,这样就可以访问到连接事件所对应的client对象,当client发送数据给服务器时,这一事件就会触发*/  
        for(var i=0;i<clientList.length;i++){  
            if(clientList[i]!==this){  
                // 把数据发送给其他客户端  
                clientList[i].write(this.name+"says "+data);  
            }  
        }  
    });  
});  
chatServer.listen(9000, "127.0.0.1");//服务器端口

注意:这里有个坑——如果有个客户端断开连接,那么所有人都会玩完!
因为如果再往服务器发送消息,这时候服务器并不知道某个客户端已经断开了连接,因此会继续向其发送数据,但是这时断开的这个客户端对应的socket已经无法写入数据,而对已关闭的socket进行write()操作node程序会抛出异常,进而导致全军覆没。所以,这个问题应该从两个方面来解决:
(1)当客户端断开连接时,通知服务器,将其从客户端列表中移除,防止其调用write方法(V8引擎也会把响应的socket对象作为垃圾回收,并释放相应的内存);
(2)采用更保险的方式调用write()方法。
改进如下:

最后,监听客户端关闭事件,并记录错误

var net = require('net');//1 引入net模块  
var chatServer = net.createServer();//创建net服务器  
var clientList = [];//保存多个客户端的数组  

chatServer.on('connection', function (client) {//服务器连接客户端  
    // console.log(' client remoteAddress =' + client.remoteAddress);
    // console.log(' client remotePort = ' + client.remotePort);
    client.name = client.remoteAddress + ':' + client.remotePort;  

    /*增加name属性*/  
    client.write('Hi' + client.name + '!\n');  
    // console.log(''client.name+'connected');
    clientList.push(client);  
    console.log('clientList length = ' + clientList.length);
    for(var i = 0; i<clientList.length; i++){
      console.log('client remoteAddress'+[i] + clientList[i].name);
    }
    client.on('data', function (data) {  
        /*添加事件监听器,这样就可以访问到连接事件所对应的client对象,当client发送数据给服务器时,这一事件就会触发*/  
       //广播消息给其他客户端  
        broadcast(data,client);  
    });  
  //监听客户端终止  
    client.on('end',function(){  
        console.log(''+client.name+'quit');//如果某个客户端断开连接,node控制台就会打印出来  
        clientList.splice(clientList.indexOf(client),1);  
    });  
    /*记录错误*/  
    client.on('error',function(e){  
        console.log(' error'+e);  
    });  
  
    function broadcast(message,client){  
        var cleanup=[];//断开了的客户端们  
        for (var i = 0; i < clientList.length; i++) {  
            if (clientList[i] !== client) {  
                //检查socket的可写状态  
                if (clientList[i].writable) {  
                    // 把数据发送给其他客户端  
                    clientList[i].write(client.name + "says " + message);  
                }else{  
                    /*socket不可写,则将其从列表中移除*/  
                    cleanup.push(clientList[i]);  
                    clientList[i].destroy();  
                }  
            }  
        }  
        /*删除掉服务器的客户端数组中,已断开的客户端*/  
        for(var i=0;i<cleanup.length;i++){  
            clientList.splice(clientList.indexOf(cleanup[i]),1);  
        }  
    }  
});  
//服务器端口  
chatServer.listen(9000, function(){
    console.log("server bound : 9000");
});
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,991评论 19 139
  • 1、TCP状态linux查看tcp的状态命令:1)、netstat -nat 查看TCP各个状态的数量2)、lso...
    北辰青阅读 9,528评论 0 11
  • iPhone的标准推荐是CFNetwork 库编程,其封装好的开源库是 cocoa AsyncSocket库,用它...
    Ethan_Struggle阅读 2,283评论 2 12
  • 最近项目有这样的需求,项目中有一个控制器显示一个二维码,然而把二维码对准打卡机扫描,经常会因为在室外光照强烈、屏幕...
    Daeva_Song阅读 3,955评论 1 1
  • 清晨,懒懒的,不想起来,躺在床上。这是久违的享受了。很久很久,已经记不清有多久了,都是早早的就起床,多早呢,反正都...
    华客鲁俊阅读 134评论 0 3