nodejs簡介：Node.js是一個可以讓javascript運(yùn)行在服務(wù)器端的平臺，它可以讓javascript脫離瀏覽器的束縛運(yùn)行在一般的服務(wù)器下面，你可以用Node.js輕松地進(jìn)行服務(wù)器端應(yīng)用的開發(fā)。Node.js是一個為實時Web應(yīng)用開發(fā)而誕生的平臺，它充分考慮了在實時響應(yīng)和超大規(guī)模數(shù)據(jù)下架構(gòu)的可擴(kuò)展性，這使得它摒棄了傳統(tǒng)的平臺依靠多線程來實現(xiàn)高并發(fā)的的設(shè)計思路，而采用了單線程，異步式I/O和事件驅(qū)動的設(shè)計模式。這些特性不僅帶來了巨大的性能提升，還減少了多線程程序設(shè)計的復(fù)雜性，從而提高了開發(fā)效率。
websocket：websocket協(xié)議是html5中的一種新的協(xié)議，它實現(xiàn)了瀏覽器與服務(wù)器的全雙工通信。傳統(tǒng)的我們通過http協(xié)議實現(xiàn)即時通訊時是這樣做的，首先由瀏覽器對服務(wù)器發(fā)出http request（請求），然后服務(wù)器響應(yīng)客戶端的瀏覽器。這種模式所帶來的弊端就是瀏覽器需要不斷的向服務(wù)器發(fā)出請求。但是我們知道http request 的頭部（header）非常長，有時客戶端請求的只是很小的數(shù)據(jù)量卻要附帶這么長的頭部信息，這樣似乎在浪費(fèi)網(wǎng)絡(luò)帶寬。而是用websocket協(xié)議，這時瀏覽器和服務(wù)器只需要進(jìn)行一次握手的過程，之后，它們之間便形成了一條快速通道，接著就可以隨時互相發(fā)送數(shù)據(jù)。這樣不但響應(yīng)速度快，而且避免了每次都發(fā)送請求頭。
mongodb數(shù)據(jù)庫：mongodb是一個面向文檔的非關(guān)系型數(shù)據(jù)庫，它具有高性能，易部署，易使用，存儲數(shù)據(jù)方便等優(yōu)點(diǎn)。它支持的數(shù)據(jù)結(jié)構(gòu)很松散類似json格式。它也是面向集合的，數(shù)據(jù)被分組存放在數(shù)據(jù)集中，每個數(shù)據(jù)集就是一個集合，每個數(shù)據(jù)庫包含若干個集合。
實現(xiàn)和效果：下面要介紹的是使用nodejs實現(xiàn)的即時聊天室，主要用到的是websocket協(xié)議，數(shù)據(jù)庫中存放用戶民和密碼。首先服務(wù)器打開一個socket端口3000開始監(jiān)聽客戶端的連接，接著客戶端瀏覽器建立socket連接，用戶登錄時填寫用戶名和密碼，服務(wù)器端查詢mongodb數(shù)據(jù)庫驗證用戶名和密碼是否正確，用戶登錄聊天室后可以開始發(fā)送消息給其它在線的用戶。以上是基本的邏輯。
下面主要貼出服務(wù)器端代碼：
var express = require('express')
,path = require('path')
,app = express.createServer().listen(3000)
,io = require('socket.io').listen(app)
,mongodb = require('mongodb');
var users = [];//保存在線用戶
var socketlist = [];//保存當(dāng)前建立的所有socket
var socketnum = 0, usernum = 0;
//監(jiān)聽socket連接
io.on('connection', function(socket)
{
socketlist[socketnum++] = socket;
console.log('someone connected!');
socket.send(toUserList(users));
socket.on('message', function(data)
{
var result = eval_r('('+ data +')');
var username = result.username;
var content = result.content;
var wordsize = result.wordsize;
var wordcolor = result.wordcolor;
var sendcontent = "
"+username+":"+content+"
"
for(var i = 0; i < socketlist.length; ++i)
{
if(socketlist[i])
{
var jsonstr = '{type:"info",content:"'+sendcontent+'"}';
console.log(jsonstr);
socketlist[i].send(jsonstr);
}
}
});
});
//express基本配置
app.configure(function()
{
app.use(express.bodyParser());//添加解釋文檔的中間件
//app.use(express.methodOverride);
app.use(app.router);
app.use(express.static(path.join(__dirname, 'public')));//指定靜態(tài)文件目錄
});
app.get('/', function(req, res)
{
res.sendfile('views/login.html', {root:__dirname});
console.log('please login first.');
});
app.post('/login', function(req, res)
{
var username = req.body.username;
var password = req.body.password;
//query the database
var dbserver = new mongodb.Server('127.0.0.1', 27017);
new mongodb.Db('myqq', dbserver).open(function(err, client)
{
if(err) throw err;
console.log('connect mongodb success!!!');
app.user = new mongodb.Collection(client ,'users');
app.user.findOne({name:req.body.username, password:req.body.password}, function(err, doc)
{
if(doc)
{
if(isNewer(username))
{
users[usernum++] = username;
console.log(username + " login success!");
}
else
{
console.log(username + " welcome back!");
}
res.setHeader("Set-Cookie", 'username='+username);
res.sendfile('views/chartRoom.html', {root:__dirname});
}
else
{
res.sendfile('views/login.html', {root:__dirname});
console.log('login failure!');
}
});
});
});
function toUserList(userslist)
{
var temp, list = '';
for(var i = 0; i < userslist.length; ++i)
{
temp = "
" + userslist[i] + "
";
list += temp;
}
var jsonstr = '{type:"ulist",content:"'+list+'"}';
return jsonstr;
}
function isNewer(username)
{
for(var i = 0; i < users.length; ++i)
{
if(username == users[i])
return false;
}
return true;
}
console.log('server is running at port 3000...');
完整的代碼請見github,后續(xù)有時間上傳完整作品
