var net=require('net');
var clientList=[];
var server=net.createServer(function(socket){
	//当有客户端进行链接时,就进入这个方法,并且告知客户端,连接诶成功:
    socket.write('客户端连接服务器成功:success!\r\n');
    //socket.pipe(socket);
    //data 就是接收的客户端传输来的内容
    socket.on('data',function(data){
        console.log("客户端说:"+data.toString());
        //socket.write("我是服务器----");将固定的输出内容改为,接收的客户端发来的内容,病广播给所有连接本服务器的客户端
         broadcast(data);
    });
    //没有写socket.end();的话不会自动结束,除非报错,会自动调用end();
    socket.on('end',function () {
    	//当有一个客户端中断连接之后,为了不报错,需要删除这个socket
         var index=clientList.indexOf(socket);//查找这个Socket在数组中的下标
         clientList.splice(index,1);//删除数组中的数据
        // socket.write('end');//必须注释掉,不然会报错;
    });
});
//每当接收到客户端发来的消息时,就进行广播,所有连接这个服务器的客户端都会收到这条消息
function broadcast(data){
    for(var i=0;i<clientList.length;i++){
        clientList[i].write(data);
    }
}
server.listen(2222,'127.0.0.1');

var net=require('net');
var hostname=process.argv[2];//补充学习中讲解
var port=process.argv[3];
var client =net.connect({host:hostname,port:port},function(){
    console.log('connected to server');
    //连接服务器成功,就发送给服务器一条消息,我是客户端;
    //client.write('我是客户端\r\n');
    //将上边的固定输出内容更改为用户自动输入,并将用户输入的内容发送给服务器;
    //设置编码格式,用户可以输入中文;
    process.stdin.setEncoding("utf8");
    //当有键盘输入时,触发这个事件
    process.stdin.on('readable',function(){
        //读取数据
        var chunk=process.stdin.read();
        if(chunk!=null){
            //将输入返回给服务器;
            client.write('data:'+chunk);
        }
    })
});
client.on('data',function(data){
	//将接收到的服务器发来的消息打印出来;
    console.log("服务器说:"+data.toString());
    //client.end();
});
//如果连接服务器后中间出现问题,即使没有调用end(),也会自动触发这个函数;
client.on('end',function () {
    console.log('disconnected from server');
});