nodejs中怎么利用websocket實現(xiàn)一個實時聊天系統(tǒng),相信很多沒有經(jīng)驗的人對此束手無策,為此本文總結(jié)了問題出現(xiàn)的原因和解決方法,通過這篇文章希望你能解決這個問題。
目前成都創(chuàng)新互聯(lián)公司已為1000+的企業(yè)提供了網(wǎng)站建設(shè)、域名、網(wǎng)站空間、網(wǎng)站運營、企業(yè)網(wǎng)站設(shè)計、棗強網(wǎng)站維護等服務(wù),公司將堅持客戶導(dǎo)向、應(yīng)用為本的策略,正道將秉承"和諧、參與、激情"的文化,與客戶和合作伙伴齊心協(xié)力一起成長,共同發(fā)展。
client.html:
Document
只能說界面丑陋忽略它。
server.js:
var ws = require("nodejs-websocket"); console.log("開始建立連接..."); var str1 = null, str2 = null, clientReady = false, serverReady = false; var a = []; var server = ws.createServer(function (conn) { conn.on('text', function (str) { a.push(str); if (!clientReady) { if (a[0] === str) { str1 = conn; clientReady = true; str1.sendText("歡迎你" + str); } } else if (!serverReady) { if (str.indexOf('close') >= 0) { a.splice(2, 1); clientReady = false; str1 = null; return; } if (a[1] === str) { str2 = conn; serverReady = true; str2.sendText("歡迎你" + str); str1.sendText(str + "在線啦,你們可以聊天啦"); return; } } else if (clientReady && serverReady) { str2.sendText(str); str1.sendText(str); if (str.indexOf('close') >= 0) { a.splice(2, a.length); var len = a.length; for (var i = 0; i < len; i++) { // 定位該元素位置 if (str.indexOf(a[i]) >= 0) { a.splice(i, 1); if (i == 0) { str1 = str2; } serverReady = false; str2 = null; return; } } } } }) conn.on("close", function (code, reason) { console.log("關(guān)閉連接"); clientReady = false; serverReady = false; }) conn.on("error", function (code, reason) { console.log("異常關(guān)閉"); }); }).listen(8082); console.log("websocket連接完畢")
簡單的截圖說明一下:
開啟服務(wù),相同頁面執(zhí)行兩遍,就可以聊天啦。反正過程就是這樣。就是還有一個大的問題。比如我a斷開連接了,只有b一個人在連接巨人b還能發(fā)信息,可以發(fā)信息算可以吧。居然b自己接收自己的信息。那就不能忍了。
看完上述內(nèi)容,你們掌握nodejs中怎么利用websocket實現(xiàn)一個實時聊天系統(tǒng)的方法了嗎?如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道,感謝各位的閱讀!