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