本文實例node.js創建即時通信的Web聊天服務器,供大家參考,具體內容如下
1.使用nodejs-websocket
nodejs-websocket是基於node.js編寫的一個後端實現websocket協議的庫,
連接:https://github.com/sitegui/nodejs-websocket。
(1)安裝
在項目目錄下通過npm安裝:npm install nodejs-websocket
(2)創建服務器
//引入nodejs-websocket var ws = require(“nodejs-websocket”); //調用createServer方法創建服務器,回調函數中的conn是connection的實例 var server = ws.create(function(conn){ console.log(“New connection”); //監聽text事件,text事件每當從服務器收到文本類型數據時觸發,回調函數的參數為傳過來的字符串 conn.on(“text”, function(str){ console.log(“Received ” + str); }); //監聽close事件,每次斷開連接時觸發 conn.on(“close”, function(code, reason){ console.log(“Connection closed”); }) }).listen(8888);
2.客戶端使用websocket
在客戶端首先需要實例化一個websocket對象:ws = new WebSocket("ws://localhost:5000");其中的參數傳入格式為ws://+url,這就和http協議前綴http://一樣。接下來就可以通過websocket內置的一些方法進行事件監聽和數據展示。
這裡統一介紹各個監聽事件:onopen當服務器和客戶端建立起連接時觸發;onmessage當客戶端收到服務器發送的數據時觸發; onclose當客戶端和服務器的連接關閉時觸發;onerror當連接出現錯誤時觸發。
3.使用websocket+nodejs實現在線聊天室
(1)html和css代碼省略
(2)客戶端js:
oConnect.onclick=function(){ ws=new WebSocket('ws://localhost:5000'); ws.onopen=function(){ oUl.innerHTML+="<li>客戶端已連接</li>"; } ws.onmessage=function(evt){ oUl.innerHTML+="<li>"+evt.data+"</li>"; } ws.onclose=function(){ oUl.innerHTML+="<li>客戶端已斷開連接</li>"; }; ws.onerror=function(evt){ oUl.innerHTML+="<li>"+evt.data+"</li>"; }; }; oSend.onclick=function(){ if(ws){ ws.send(oInput.value); } }(3)服務器端js: /* websocket支持兩種類型的數據傳輸:text類型和binary類型,其中二進制數據是通過流的模式發送和讀取的 */ var app=require('http').createServer(handler); //為了簡化代碼,將服務器創建具體代碼放到handler函數中 var ws=require('nodejs-websocket'); var fs=require('fs'); app.listen(8888); function handler(req,res){ //__dirname返回該文件所在的當前目錄。調用readFile方法進行文件讀取 fs.readFile(__dirname+'/index.html',function(err,data){ if(err){ res.writeHead(500); return res.end('error '); } res.writeHead(200); res.end(data); }); } //以上步驟成功在8888端口渲染出相應的html界面 //conn是對應的connection的實例 var server = ws.createServer(function(conn){ console.log('new conneciton'); //監聽text事件,每當收到文本時觸發 conn.on("text",function(str){ broadcast(server,str); }); //當任何一端關閉連接時觸發,這裡就是在控制台輸出connection closed conn.on("close",function(code,reason){ console.log('connection closed'); }) }).listen(5000); //注意這裡的listen監聽是剛才開通的那個服務器的端口,客戶端將消息發送到這裡處理 function broadcast(server, msg) { //server.connections是一個數組,包含所有連接進來的客戶端 server.connections.forEach(function (conn) { //connection.sendText方法可以發送指定的內容到客戶端,傳入一個字符串 //這裡為遍歷每一個客戶端為其發送內容 conn.sendText(msg); }) } 以上就是本文
的全部內容,希望對大家的學習有所幫助,也希望大家多多支持。