1.前端启动websocket 客户端
if('WebSocket' in window) {
let ws= new WebSocket('ws://127.0.0.1:8001');
//建立链接 向后端发送消息
ws.onopen = function (event) {
console.log('建立连接');
}
//监听链接关闭
ws.onclose = function (event) {
console.log('连接关闭');
}
//接收后端给前端发送的消息
ws.onmessage = function (event) {
console.log('收到消息:' + event.data)
//所要执行的操作
}
//通讯发生错误
ws.onerror = function () {
alert('websocket通信发生错误!');
}
}else {
alert('该浏览器不支持websocket!');
}
2.node.js启动服务端 (前提 已经下载了nodejs-websocket)
var ws = require('nodejs-websocket');
console.log('开始建立连接...')
//创建websocket
ws.createServer(function (conn) {
conn.on('connection', function (ws) {
console.log('服务端:客户端已连接');
ws.on('message', function (message) {
//打印客户端监听的消息
console.log(message);
});
});
//接收前端发送的消息
conn.on('text', function (str) {
console.log('收到的信息为:' + str)
// conn.sendText(str)
})
//关闭时
conn.on('close', function (code, reason) {
console.log('关闭连接', code, reason)
});
//异常关闭时
conn.on('error', function (code, reason) {
console.log('异常关闭', code, reason)
});
//后端给前端发消息
setInterval(() => {
conn.sendText('后台发给前台')
}, 2000)
}).listen(8001)
console.log('WebSocket建立完毕');
启动node.js
node websocket.js