この記事は、nodejs+websocket リアルタイム チャット システムの改良版を主に紹介します。興味のある方は参考にしてください。
この記事は、nodejs+websocket リアルタイム チャット システムの改良版に属します。具体的な内容は以下の通りです
私も何日もかけて簡単なWebSocketチャットシステムに取り組んできました。
今後もまだまだコードを書かないといけないようです。
client.html:
<!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width, initial-scale=1.0"> <meta http-equiv="X-UA-Compatible" content="ie=edge"> <title>Document</title> <style> .kuang { width: 600px; min-height: 50px; max-height: 296px; border: 1px solid; float: left; display: block; position: relative; overflow-y: scroll; } .value { width: 200px; } .input { display: block; position: absolute; left: 0; margin-top: 300px; } </style> </head> <body> <label>连接用户:</label> <input type="text" id="name" /> <button id="conn">连接</button> <button id="close">断开</button><br/><br/> <p class="kuang" id="mess"></p> <p class="input"> <input type="text" class="value" id="value1" /> <button id="send">发送</button> </p> <script> var input = document.getElementById("name"); var conn = document.getElementById("conn"); var close = document.getElementById("close"); var mess = document.getElementById("mess"); var value1 = document.getElementById("value1"); var pattern = /^[\u4e00-\u9fa5]{2,10}$/; close.disabled = true; if (window.WebSocket) { conn.onclick = function () { if (!pattern.test(input.value)) { alert("名称不能为空且必须为中文"); return; } var ws = new WebSocket('ws://127.0.0.1:8082'); conn.disabled = true; close.disabled = false; ws.onopen = function (e) { console.log("连接服务器成功"); ws.send(input.value); input.setAttribute("readOnly", 'true'); value1.setAttribute("readOnly", 'true'); } ws.onmessage = function (e) { value1.removeAttribute("readOnly"); var time = new Date(); mess.innerHTML += time.toUTCString() + ":" + e.data + "<br>"; document.getElementById("send").onclick = function (e) { ws.send(input.value + "说:" + value1.value); value1.value = " "; } document.onkeydown = function (e) { e = e || window.event; if (e.keyCode == 13) { document.getElementById("send").onclick(); return false; } } } ws.onclose = function (e) { console.log("服务器关闭"); } ws.onerror = function () { console.log("连接出错"); } /** * 客户端主动断开连接 * * **/ close.onclick = function () { ws.onclose(); ws.send(input.value + 'close' + "了连接"); input.removeAttribute("readOnly"); conn.disabled = false; close.disabled = true; } } } </script> </body> </html>
インターフェイスが醜いので無視するとしか言えません。
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("关闭连接"); clientReady = false; serverReady = false; }) conn.on("error", function (code, reason) { console.log("异常关闭"); }); }).listen(8082); console.log("websocket连接完毕")
説明する簡単なスクリーンショット:
サービスを有効にし、同じページを 2 回実行すると、チャットできるようになります。とにかく、それがプロセスです。ただもう一つ大きな問題があります。たとえば、私は A から切断されていますが、B のみがメッセージを送信できる場合は、B のみが巨人に接続されています。実際には、b は自分自身の情報を受け取ります。そうすると、我慢できないんです。
そうです、論理がめちゃくちゃで、論理を明確にするのは頭を使う作業です。知っているクラスメートはいますか?対処方法
[関連する推奨事項]
以上がnodejs+websocket でチャット システム機能が完成の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。