nodejs实现多人实时聊天

Posted 2022-04-25 勇敢*牛牛

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('服务器异常退出。');
)