1、首先安裝好nodejs-websocket
	npm install nodejs-websocket --save -g
2、編寫服務端
var ws = require("nodejs-websocket")var AllUserData = new Array()// Scream server example: "hi" -> "HI!!!"var server = ws.createServer(function (conn) {  console.log("New connection")  conn.on("text", function (str) {    console.log("Received "+str)    AllUserData.push({      'id':str,      'ws':conn    })    conn.sendText(str.toUpperCase()+"!!!")  })  conn.on("close", function (code, reason) {    console.log("Connection closed")    // 當用戶退出的時候捕捉到退出的用戶    for (var i=0 in AllUserData) {      if (AllUserData[i].ws == conn) {        console.log(AllUserData[i])      }    }  })}).listen(8001)3、簡易客戶端
<!DOCTYPE html><html><head>  <title>django-websocket</title>  <script src="http://code.jquery.com/jquery-1.11.1.min.js"></script>  <script type="text/javascript">//<![CDATA[  $(function () {    $('#connect_websocket').click(function () {      if (window.s) {        window.s.close()      }      /*創建socket連接*/      var socket = new WebSocket("ws://127.0.0.1:8001");      socket.onopen = function () {        console.log('WebSocket open');//成功連接上Websocket      };      socket.onmessage = function (e) {        console.log('message: ' + e.data);//打印出服務端返回過來的數據        $('#messagecontainer').prepend('<p>' + e.data + '</p>');      };      // Call onopen directly if socket is already open      if (socket.readyState == WebSocket.OPEN) socket.onopen();      window.s = socket;    });    $('#send_message').click(function () {      //如果未連接到websocket      if (!window.s) {        alert("websocket未連接.");      } else {        window.s.send($('#message').val());//通過websocket發送數據      }    });    $('#close_websocket').click(function () {      if (window.s) {        window.s.close();//關閉websocket        console.log('websocket已關閉');      }    });  });  //]]></script></head><body><br><input type="text" id="message" value="user1"/><button type="button" id="connect_websocket">連接 websocket</button><button type="button" id="send_message">發送 message</button><button type="button" id="close_websocket">關閉 websocket</button><h1>Received Messages</h1><div id="messagecontainer"></div></body></html>總結
以上所述是小編給大家介紹的nodejs 使用nodejs-websocket模塊實現點對點實時通訊,希望對大家有所幫助,如果大家有任何疑問請給我留言,小編會及時回復大家的。在此也非常感謝大家對VeVb武林網網站的支持!
新聞熱點
疑難解答