基于express+socket.io的nodejs聊天室

//========================变量定义===============================/** * modules引入 */var express = require('express'),	sio = require('socket.io'),	fs=require('fs'),	path = require('path')	url = require('url'),	parseCookie = require('connect').utils.parseCookie,	MemoryStore = require('connect/middleware/session/memory'); /** * 私人聊天使用session */var usersWS = {}, //私人聊天用的websocket	storeMemory = new MemoryStore({		reapInterval: 60000 * 10	});//session store//=========================app配置=============================	/** * app配置 */var app = module.export = express.createServer(); app.configure(function(){	app.use(express.bodyParser());	app.use(express.cookieParser());	app.use(express.session({		secret: 'wyq',		store:storeMemory 	}));	app.use(express.methodOverride());	app.use(app.router);//要放在bodyParser之后，处理post	app.set('views', __dirname + '/views');	app.set('view engine', 'jade');	app.use(express.static(__dirname + '/public'));});//=================配置socket.io=========================/** * 配置socket.io *  */	var io = sio.listen(app);//设置sessionio.set('authorization', function(handshakeData, callback){	// 通过客户端的cookie字符串来获取其session数据	handshakeData.cookie = parseCookie(handshakeData.headers.cookie)	var connect_sid = handshakeData.cookie['connect.sid']; 	if (connect_sid) {		storeMemory.get(connect_sid, function(error, session){			if (error) {				// if we cannot grab a session, turn down the connection				callback(error.message, false);			}			else {				// save the session data and accept the connection				handshakeData.session = session;				callback(null, true);			}		});	}	else {		callback('nosession');	}});//=========================URL=============================/** * url处理开始鸟~ * @param {Object} req * @param {Object} res */app.get('/',function(req,res){ 	if( req.session.name && req.session.name!==''){		//需要判断下是否已经登录		res.redirect('/chat');	}else{		//读取登录页面，要求登录		var realpath = __dirname + '/views/' + url.parse('login.html').pathname;		var txt = fs.readFileSync(realpath);		res.end(txt);	}});app.get('/chat',function(req,res){	if (req.session.name && req.session.name !== '') {		//需要判断下是否已经登录		res.render('chat',{name:req.session.name});	}else{		res.redirect('/');	}})app.post('/chat',function(req,res){	var name = req.body.nick;	if(name && name!==''){		req.session.name = name;//设置session		res.render('chat',{name:name});	}else{		res.end('nickname cannot null');	} }); //===================socket链接监听=================/** * 开始socket链接监听 * @param {Object} socket */io.sockets.on('connection', function (socket){	var session = socket.handshake.session;//session	var name = session.name;	usersWS[name] = socket;	var refresh_online = function(){		var n = [];		for (var i in usersWS){			n.push(i);		}		io.sockets.emit('online list', n);//所有人广播	}	refresh_online(); 	socket.broadcast.emit('system message', '【'+name + '】回来了，大家赶紧去找TA聊聊~~'); 	//公共信息	socket.on('public message',function(msg, fn){		socket.broadcast.emit('public message', name, msg);		fn(true);	});	//私人@信息	socket.on('private message',function(to, msg, fn){		var target = usersWS[to];		if (target) {			fn(true);			target.emit('private message', name+'[私信]', msg);		}		else {			fn(false)			socket.emit('message error', to, msg);		}	}); 	//掉线，断开链接处理	socket.on('disconnect', function(){		delete usersWS[name];		session = null;		socket.broadcast.emit('system message', '【'+name + '】无声无息地离开了。。。');		refresh_online();	}); }); //===========app listen 开始鸟~==========app.listen(3000, function(){	var addr = app.address();	console.log('app listening on http://127.0.0.1：' + addr.port);});