Socket聊天逻辑

 

         一、A发送消息到服务器

         二、服务器接收到消息后会给全部用户发送这条消息

         三、若是有用户断开链接，则不用给此用户发送

1、建立持久性链接服务器  net，设置其端口号为9000

const net = require(“net”);

const server = net.creatServer();

server.listen(9000);

2、当用户链接到服务器之后

         server.on("connection",(client)=>{}）

3、存储下全部的用户

         const clients = [];

         clients.push(client);

4、给用户编号，断开链接后删除

         client.id = clients.length;

         4.1 建立client.js文件，链接到服务器

                  const net = require("net");

                  const client = new net.Socket();

                  client.connect(9000,"127.0.0.1",()=>{

});

                  4.1.1 接受服务器传递过来的消息

                          client.on("data",(data)=>{

        console.log(data)

    })

         4.2 接收客户端传递过来的消息

                  client.on("data",(data)=>{

    })

                  4.2.1将buffer文件转换为字符串

                          client.setEncoding("utf8")

                  4.2.2而后将这个消息发送给全部的用户   

                                  clients.map((item)=>{

            if(item){

                item.write(data);

            }

        })

          client.on("close",()=>{

        clients[client.id] = null;

})

5、建立文件的读写流

         const readline = require("readline");

         const rl = readline.createInterface({

    input:process.stdin,

    output:process.stdout

})

         rl.on("line",(text)=>{

    //发送消息

    client.write(text);

})