Node.js+websocket+mongodb實現即時聊天室

nodejs簡介：Node.js是一個可讓javascript運行在服務器端的平臺，它可讓javascript脫離瀏覽器的束縛運行在通常的服務器下面，你能夠用Node.js輕鬆地進行服務器端應用的開發。Node.js是一個爲實時Web應用開發而誕生的平臺，它充分考慮了在實時響應和超大規模數據下架構的可擴展性，這使得它摒棄了傳統的平臺依靠多線程來實現高併發的的設計思路，而採用了單線程，異步式I/O和事件驅動的設計模式。這些特性不只帶來了巨大的性能提高，還減小了多線程程序設計的複雜性，從而提升了開發效率。

websocket：websocket協議是html5中的一種新的協議，它實現了瀏覽器與服務器的全雙工通訊。傳統的咱們經過http協議實現即時通信時是這樣作的，首先由瀏覽器對服務器發出http request（請求），而後服務器響應客戶端的瀏覽器。這種模式所帶來的弊端就是瀏覽器須要不斷的向服務器發出請求。可是咱們知道http request 的頭部（header）很是長，有時客戶端請求的只是很小的數據量卻要附帶這麼長的頭部信息，這樣彷佛在浪費網絡帶寬。而是用websocket協議，這時瀏覽器和服務器只須要進行一次握手的過程，以後，它們之間便造成了一條快速通道，接着就能夠隨時互相發送數據。這樣不但響應速度快，並且避免了每次都發送請求頭。

mongodb數據庫：mongodb是一個面向文檔的非關係型數據庫，它具備高性能，易部署，易使用，存儲數據方便等優勢。它支持的數據結構很鬆散相似json格式。它也是面向集合的，數據被分組存放在數據集中，每一個數據集就是一個集合，每一個數據庫包含若干個集合。

實現和效果：下面要介紹的是使用nodejs實現的即時聊天室，主要用到的是websocket協議，數據庫中存放用戶民和密碼。首先服務器打開一個socket端口3000開始監聽客戶端的鏈接，接着客戶端瀏覽器創建socket鏈接，用戶登陸時填寫用戶名和密碼，服務器端查詢mongodb數據庫驗證用戶名和密碼是否正確，用戶登陸聊天室後能夠開始發送消息給其它在線的用戶。以上是基本的邏輯。

下面主要貼出服務器端代碼：

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 = [];//保存當前創建的全部socket
var socketnum = 0, usernum = 0;
//監聽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')));//指定靜態文件目錄
});
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,後續有時間上傳完整做品