Node.js 使用node的net模块实现一个聊天室

矫情吗；* 2022-02-02 12:25 192阅读 0赞

net模块创建的是tcp服务，我们可以下载一个putty来连接服务器。

[putty][]

原理非常简单，我们使用net.createServer创建一个服务，回调函数里面的socket是一个可读可写流。

我们可以监听data来事件来读，同样也可以调用write方法来写。我们简单的使用客户端的ip+port来标识用户。

具体详情可以看一下代码，非常简单吧。

//使用net 模块 创建一个聊天室
    //实现广播 私聊 更改用户名 显示当前在线名单
    
    //b:消息  广播 
    // c:nickname:消息 私聊nickname  
    //l 展示名单  
    // n:newname 更换用户名
    
    const net = require("net");
    let users = {}; // 保存所以用户的信息
    const server = net.createServer(function (socket) {
        const id = socket.remoteAddress +  socket.remotePort; //ip地址 + 端口号 作为key
        users[id] = {
            nickname: "匿名",
            socket
        };
        server.getConnections((err, connect) => {
            socket.write(`你好，当前在线用户${connect}人\r\n`)
        })
        socket.setEncoding("utf8");
        socket.on("data", function (data) {
            data = data.replace(/\r\n/, "");
            let flag = data.slice(0,1);
            switch (flag) {
                case "b": { //广播
                    let text = data.slice(2);
                    boardCast(text);
                    break;
                }
                case "c": {//私聊
                    let t = data.split(":");
                    let text =  t[2];
                    let toUser =  t[1];
                    sentToUser(toUser, text);
                    break;
                }
                case "l": {//展示列表
                    let s = "";
                    for (let v_id in users) {
                        s += (users[v_id].nickname + "   ");
                    }
                    s+="\r\n";
                    socket.write(`当前用户表：${s}`)
                    break;
                }
                case "n": {//更新用户名
                    let text = data.slice(2);
                    users[id].nickname = text;
                    socket.write(`修改成功!\r\n`);
                    break;
                }
            }
        })
        function sentToUser(toUser, text) {
            let toSocket = null;
            for (let v_id in users) { //找到对应的人
                if (users[v_id].nickname === toUser) {
                    toSocket = users[v_id];
                    break;
                }
            }
            if (toSocket) {
                toSocket.socket.write(`${users[id].nickname}: ${text}\r\n`)
            } else {
                socket.write("对不起，你输入的用户名不存在!\r\n");
            }
    
        }
        function boardCast(text) {
            for (let v_id in users) {
                if (v_id !== id) {
                    users[v_id].socket.write(`${users[id].nickname}: ${text}\r\n`);
                }
            }
        }
    
    
    });
    
    
    server.listen(8080, function () {
        console.log("服务器已经启动！！！");
    })
    server.on("close", function () {
        console.log("服务器已经关闭");
    })

我们使用puttty来连接服务器

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1c3RfY3ls_size_16_color_FFFFFF_t_70][]点击open我们就创建了一个客户端，我们在这里创建3个

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1c3RfY3ls_size_16_color_FFFFFF_t_70 1][]

我们修改用户名称，然后 三号先对lym(2号）私聊 ； 然后广播消息；  一号（大西瓜）私聊3号（cyl)；代码最前面我控制了格式。

聊天功能基本实现了，很原始吧！

[putty]: https://www.chiark.greenend.org.uk/~sgtatham/putty/latest.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1c3RfY3ls_size_16_color_FFFFFF_t_70]: /images/20220202/ea772a4c642f45d2ad348d34bb106b07.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d1c3RfY3ls_size_16_color_FFFFFF_t_70 1]: /images/20220202/73ee4ef739c74238bb9c21f3699fee4c.png