0
点赞
收藏
分享

微信扫一扫

【nodejs实打造多人实时聊天室】


server.js文件

// 加载net模块
var net = require("net");
// 创建net实例对象
var server = net.createServer();
// 保存所有客户的socket对象
var users = [];
// 创建服务
server.on('connection', function (socket) { //a.告诉所有其他客户,有新成员进来了
// 遍历客户实例对象,通过套接字获取客户端口号
users.forEach(function (client) {
client.write(socket.remotePort + '进入聊天室》');
});
users.push(socket); //b.保存当前的socket

socket.on('data', function (data) { //c.设置当前socket的消息传输的处理方式
data = data.toString().trim(); //一旦收到消息,就转发给其他所有客户
users.forEach(function (uesr) {
if (uesr != socket) {//不是自己
uesr.write(socket.remotePort + ':' + data)
}
});
})

socket.on('error', function (err) {
console.log(socket.remotePort + '退出聊天室');
})
})
server.listen(3000, function () { //4.启动监听
console.log('服务器已经在端口号3000启动监听。。。。。');
})
server.on('error', function () {
console.log('服务器异常退出');
})

client.js文件

//导入net
var net = require('net');
// 创建连接,产生socket对象
var socket = net.createConnection({
host: '127.0.0.1',
port: 3000
})
// 输入消息
socket.on('connect', function () {
console.log('进入聊天室......');
/**
* 准备输入聊天信息
* nodejs中提供了process模块,支持终端设备进行IO操作,全局模块。不需要导入
* stdin对象获得键盘输入(回车后)
* 接收到键盘输入,就将消息发送到服务器
*/
process.stdin.on('data', function (data) {
socket.write(data.toString().trim());
});
})
//接收消息
socket.on('data', function (data) {
console.log(data.toString().trim());
});
socket.on('error', function (err) {
console.log('服务器异常退出。');
})


举报

相关推荐

0 条评论