<input type="text" placeholder="请输入聊天内容" id="msgInput">
<button onclick="sendMsg()">发送</button>
<ul id="msgUl"></ul>
 <script>
        //1. 客户端发起请求  协议://ip:端口
        //    localhost  就是 127.0.0.1 本机
        var clientWS = new WebSocket("ws://localhost:3000")
        //  2. 监听服务是否建立 链接成功
        clientWS.onopen = function () {
            console.log("链接成功");
        }
        // 3. 监听服务端 是否给消息
        clientWS.onmessage = function (e) {
            console.log("服务端发来的消息:", e.data);
            showMsg("TA:"+e.data)
        }
        // 4.监听是否关闭
        clientWS.onclose = function () {
            console.log("服务已断开");
        }
        // 5.  客户端向服务端发送消息
        function sendMsg(){
            clientWS.send(inpuMsg.value)
            showMsg("我:"+inpuMsg.value)
            inpuMsg.value = ""
        }
        function showMsg(msg){
            let li = document.createElement("li")
            li.innerHTML = msg
            msgUl.appendChild(li)
        }
    </script>

const readline = require('readline');
var ws = require('ws')
wss = new ws.Server({ port: 3000 },function(){
console.log("3000 server  start")
});//服务端口3000
wss.on('connection', function (ws) {
    console.log('服务端：客户端已连接');
    ws.on('message', function (message) {
        console.log("服务端接收客户端的消息:", message);
        //创建readline接口实例
        const rl = readline.createInterface({
            input: process.stdin, //设置标准的输入流
            output: process.stdout //设置标准输出流
        });
        rl.question('请输入: ', function (answer) {
            ws.send(answer)
            // 不加close，则不会结束
            rl.close();
        });
    });
});