本文例項為大家分享了程式碼實現多人聊天室的具體程式碼，供大家參考，具體內容如下

設計要求：

1）使用者應通過註冊登入聊天室
2）聊天室可以顯示所有線上使用者
3）在每一條聊天內容之前，顯示發出這條聊天內容的使用者名稱。
4）可進行私密聊天。
5）當用戶進入和離開聊天室時，系統會在聊天室裡廣播

config.js 程式碼如下

module.exports={
    "port":3000,"host":"127.0.0.1"
}

broadcast.js 程式碼如下

exports.broadcast=function (data,users) {
    var from=data.from;
    var message=data.message;
    message = from+"說: "+message;
    //構建訊息
    var send={
        mstype:"broadcast",message:message
    };
    send =new Buffer(JSON.stringify(send));
    //遍歷使用者組所有使用者，出發送方的所有使用者
    for(var username in users){
        if(username!=from){
            
 
users[username].write(send);
        }
    }
};

Signup.js 程式碼如下

exports.signup = function (socket,data,users) {
//獲取註冊使用者的使用者名稱
    var username=data.username;
    if(!users[username]){  //不存在，則儲存使用者名稱和socket
        users[username]=socket;
        var send={
            mstype:"signup",code:1000,username:username,message:"註冊成功"
        };
        socket.write(JSON.stringify (send));
    }else{//cunzai
        var send={
            mstype:"signup",code:1001,message: "使用者名稱已被佔，請重新輸入使用者名稱"
        }
        socket.write(JSON.stringify(send));
    }
};

p2p.js 程式碼如下

exports.p2p=function (socket,users) {
    var from=data.from;
    var to=data.to;
    var message=data.message;
    var receiver=users[to];
    if(!receiver){//接收方不存在
      var send={
          mstype:"p2p",code:2001,message:"使用者"+to+"不存在"
      }
      socket.write(JSON.stringify(send));
    }else{
        //存在則向接收方傳送資訊
        var send={
            mstype:"p2p",YaxwY
 

            code:2000,from:from,message:from+"對你說"+message
        }
        receiver.write(JSON.stringify(send));
    }
};

Server伺服器端程式碼

//p2p 聊天室伺服器
var net=require("net");
var config=require("./confighttp://www.cppcns.com");
var broadcast=require("./broadcast");
var p2p=require("./p2p");
var signup=require("./signup");
var users={};
var server=net.createServer();
server.on ("connection",function (socket) {
    socket.on("data",function (data) {
        data = JSON.parse(data);
        switch (data.mstype) {
            case "signup":
                signup.signup(socket,users);
                break;
            case "broadcast":
                broadcast.broadcast(data,users);
                break;
            case "p2p":
                p2p.p2p(socket,users);
                break;
            default:
                break;
        }
    });
    socket.on("error",function () {
        console.log("有客戶端異常退出了");
    });
});
server.listen(config.port,config.host,function () {
    console.log("伺服器在埠"+config.port+"啟動監聽");
});

Client客戶端程式碼如下：

var net=require("net");
var config=require("./config");
var Client=net.createConnection({
    port:config.port,host:config.host
});
var username;
Client.on("connect",function () {
    console.log("請輸入使用者名稱：");
    process.stdin.on("data",function (data){
        data=data.toString().trim();
        //判斷使用者是否已經存在
        if(! username){
            var send={
                mstype:"signup",username:data
            };
            Client.write(JSON.stringify(send));
            return;
        }
        var regex=/(.{1,18}):(.+)/;
        var matches=regex=regex.exec(data);
        if(matches){
            //能匹配則是p2p
            var from=username;//傳送方是自己
            var to=matches[1];//發給誰
            var message=matches[2];
            //構造JSON形式資訊
            var send={
                mstype: "p2p",from:username,to:to,message:message
            };
            Client.write(JSON.stringify(send));
        }else{
            //廣播
            var send={
                mstype:"browww.cppcns.comadcast",message:data
            };
            Client.write(JSON.stringify(send));
        }
    });
});
Client.on("data",function (data) {
    data=JSON.parse(data);
    switch (data.mstype) {
        case "signup":
            var code=data.code;
            switch (code) {
                case 1000:
                    username=data.username;
                    console.log(data.message);
                    break;
                case 1001:
                    console.log(data.message);
                    break;
                default:
                    break;
            }
            break;
        case "broadcast":
            console.log(data.message);
            break;
        case "p2p":
            var code=data.code;
            switch (code) {
                case 2000:
                    console.log(data.message);
                    break;
                case 2001:
                    console.log(data.message);
                    break;
                default:
                    break;
            }
            break;
        default:
            break;
    }
});
Client.on("error",function () {
    console.log("聊天室已關閉！！");
})

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支援我們。