后端node代码:

var ws = require("nodejs-websocket")

var port=3000;

// Scream server example: "hi" -> "HI!!!"

var server = ws.createServer(function (conn) {

console.log("New connection")

conn.on("text", function (str) {

console.log(str)

conn.sendText(str.toUpperCase()+"!!!")

})

conn.on("close", function (code, reason) {

console.log("Connection closed")

})

conn.on("error", function (err) {

console.log("handdle error");

console.log(err);

})

// setInterval(() => {

//     conn.sendText('123')

// }, 2000);

}).listen(port);

console.log("websocket server listening on port "+port);

前端html代码：

websocket

echo test

发送

var websocket=new WebSocket("ws://localhost:3000");

websocket.onopen=function(){

document.getElementById("recv").innerHTML="connected";

}

websocket.onclose=function(){

console.log("websocket close");

}

websocket.onmessage=function(e){

console.log(e.data);

document.getElementById("recv").innerHTML=e.data;

}

document.getElementById("sendBtn").onclick=function(){

var txt=document.getElementById("sendText").value;

websocket.send(txt);

}

node先下载一个nodejs-websocket包，然后运行js文件，

然后前端文件点击发送消息，后端就可以接收实时返回