客服电话
APP下载
迪恩网络APP
随时随地掌握行业动态
官方微信
扫描二维码
关注迪恩网络微信公众号
|
本文实例为大家分享了js代码实现多人聊天室的具体代码，供大家参考，具体内容如下 设计要求：1）用户应通过注册登录聊天室 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("聊天室已关闭！！");
})
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持极客世界。 |
请发表评论