nodejs+socket打造多人聊天室完整项目

//导入net var net = require('net'); var path = require('path') var config = require(path.join(__dirname, './config')); // 创建连接，产生socket对象 var client = net.createConnection({ host: config.host, port: config.port }) var username = ''; // 输入消息 client.on('connect', function () { console.log('进入聊天室......\n请输入用户名:'); /** * 准备输入聊天信息 * nodejs中提供了process模块，支持终端设备进行IO操作，全局模块。不需要导入 * stdin对象获得键盘输入（回车后） * 接收到键盘输入，就将消息发送到服务器 */ process.stdin.on('data', function (data) { data = data.toString().trim(); // 判断用户是否已经有来注册用户名 if (!username) {// 没有注册的话 var send = { mstype: 'singup', username: data } client.write(JSON.stringify(send)); // console.log("注册成功"); return; } var regex = /(.{1,18}):(.+)/; var matches = regex.exec(data); if (matches) { var from = username; var to = matches[1]; var message = matches[2]; var send = { mstype: 'p2p', from: from, to: to, message: message } client.write(JSON.stringify(send)); } else { var send = {//广播消息 mstype: 'broadcast', from: username, message: data }; client.write(JSON.stringify(send)) } }); }) //接收服务端的socket信息 client.on('data', function (data) { //console.log(JSON.parse(data)); data = JSON.parse(data); // console.log(data.mstype); 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: username = data.username; console.log(data.message); break; case 2001: console.log(data.message); break; default: break; } break; default: break; } }); client.on('error', function () { console.log('服务器异常退出。'); })