• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

js代码实现多人聊天室

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文实例为大家分享了js代码实现多人聊天室的具体代码,供大家参考,具体内容如下

设计要求:

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,data,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",
            code:2000,
            from:from,
            message:from+"对你说"+message
        }
        receiver.write(JSON.stringify(send));
    }
};

Server服务器端代码

//p2p 聊天室服务器
var net=require("net");
var config=require("./config");
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, data, users);
                break;
            case "broadcast":
                broadcast.broadcast(data, users);
                break;
            case "p2p":
                p2p.p2p(socket, data, 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:"broadcast",
                from:username,
                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("聊天室已关闭!!");
})

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持极客世界。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
vue实现宫格轮转抽奖发布时间:2022-02-05
下一篇:
React中10种Hook的使用介绍发布时间:2022-02-05
热门推荐
热门话题
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap