//引入nodejs-websocketvar 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);

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);  })}以上就是本文