//引入nodejs-websocket
var ws = require(“nodejs-websocket”);
//調(diào)用createServer方法創(chuàng)建服務(wù)器，回調(diào)函數(shù)中的conn是connection的實(shí)例
var server = ws.create(function(conn){
  console.log(“New connection”);
  //監(jiān)聽text事件，text事件每當(dāng)從服務(wù)器收到文本類型數(shù)據(jù)時(shí)觸發(fā)，回調(diào)函數(shù)的參數(shù)為傳過來的字符串
  conn.on(“text”, function(str){
 console.log(“Received ” + str);
  });
  //監(jiān)聽close事件，每次斷開連接時(shí)觸發(fā)
  conn.on(“close”, function(code, reason){
 console.log(“Connection closed”);
  })
}).listen(8888);

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)服務(wù)器端js：
 /*
websocket支持兩種類型的數(shù)據(jù)傳輸：text類型和binary類型，其中二進(jìn)制數(shù)據(jù)是通過流的模式發(fā)送和讀取的
*/
var app=require('http').createServer(handler); //為了簡化代碼，將服務(wù)器創(chuàng)建具體代碼放到handler函數(shù)中
var ws=require('nodejs-websocket');
var fs=require('fs');
app.listen(8888);
function handler(req,res){
  //__dirname返回該文件所在的當(dāng)前目錄。調(diào)用readFile方法進(jìn)行文件讀取
  fs.readFile(__dirname+'/index.html',function(err,data){
    if(err){
      res.writeHead(500);
      return res.end('error ');
    }
    res.writeHead(200);
    res.end(data);
  });
}
//以上步驟成功在8888端口渲染出相應(yīng)的html界面
//conn是對應(yīng)的connection的實(shí)例
var server = ws.createServer(function(conn){
  console.log('new conneciton');
  //監(jiān)聽text事件，每當(dāng)收到文本時(shí)觸發(fā)
  conn.on("text",function(str){
    broadcast(server,str);
  });
  //當(dāng)任何一端關(guān)閉連接時(shí)觸發(fā)，這里就是在控制臺輸出connection closed
  conn.on("close",function(code,reason){
    console.log('connection closed');
  })
}).listen(5000);
//注意這里的listen監(jiān)聽是剛才開通的那個(gè)服務(wù)器的端口，客戶端將消息發(fā)送到這里處理
 
function broadcast(server, msg) {
  //server.connections是一個(gè)數(shù)組，包含所有連接進(jìn)來的客戶端
  server.connections.forEach(function (conn) {
    //connection.sendText方法可以發(fā)送指定的內(nèi)容到客戶端，傳入一個(gè)字符串
    //這里為遍歷每一個(gè)客戶端為其發(fā)送內(nèi)容
    conn.sendText(msg);
  })
}

以上就是本文