WebSocket(简单体验版)

WebSocket(简单体验版)

简介

Web Socket(套接字):就是通过一个长时连接实现与服务器全双工、双向的通信。

Web Socket使用的并不是HTTP协议而是自定义的Web Socket协议,所以如果我们使用Web Socket的时候,URL不再是http://https://,而是ws://wss://(但是,实际上是看红宝书才想着玩一下下,在开发中还没试过用这个来开发的)

主要特点:服务器可以主动向客户端推送信息,客户端也可以主动向服务器发送信息。

使用

实例化

要创建一个新的Web Socket,首先需要实例化一个WebSocket对象。

我们实例化WebSocket对象时,传的参数应该是一个绝对URL同源策略不适用于WebSocket

const socket = new WebSocket("ws://localhost:8088/mysocket");
WebSocket(简单体验版)
image-20220529170446392

http请求会有跨域,但是WebSocket不会跨域

后端express

主要部分都注释了(需要安装 express-ws)

const express = require('express')
const expressWs = require('express-ws')

const app = express()

// 将WebSocket服务加到app里,简单来说就是让app添加了ws方法
expressWs(app)

// 建立WebSocket服务
app.ws('/mysocket'function (ws{
  // ws:建立WebSocket的实例
    
  // 向客户端发送信息
  ws.send('你连接成功啦')
})

app.listen(8088, () => {
  console.log('ws://localhost:8088')
})
WebSocket(简单体验版)
image-20220529172415750

如果连接上了,那么http状态码会是101,因为要切换成ws协议

绑定事件

如果我们,在实例化后就开始发送信息,那就会导致信息发不出,因为还没连接上。这时候我们就得了解一下什么时候能发,进而得了解一下WebSocket的相关事件。

  • open:在连接成功建立时触发
  • error:在连接发生错误时触发(此时已经不能再发信息了)
  • close:在连接关闭时触发(此时已经不能再发信息了)
  • message:收到消息后触发(收到的消息在事件对象中的data里)
const socket = new WebSocket("ws://localhost:8088/mysocket");
socket.onopen = function ({
    console.log("连接建立");
    socket.send('hello');
    // socket.close()
};
socket.onerror = function ({
    console.log("连接发生错误");
};
socket.onclose = function ({
    console.log("连接关闭");
};

socket.onmessage = function (e{
    console.log(e)
}
WebSocket(简单体验版)
image-20220529173743731
WebSocket(简单体验版)
image-20220529174046932

模拟两人对话

上面已经说了,收到消息会触发message事件,所以我们可以在message事件里根据收到的信息发送对应的信息。

客户端:

const socket = new WebSocket("ws://localhost:8088/mysocket");
socket.onopen = function ({
    console.log("连接建立");
    socket.send('hello');
    // socket.close()
};
socket.onerror = function ({
    console.log("连接发生错误");
};
socket.onclose = function ({
    console.log("连接关闭");
};

socket.onmessage = function ({ data }{
    if (data.includes('你好')) {
        socket.send('再见,服务端DDD')
    } else if (data.includes('再见')) {
        // 调用close()方法关闭WebSocket连接
        socket.close()
    } else {
        socket.send('你好,我是客户端ccc')
    }
}

服务器:

const express = require('express')
const expressWs = require('express-ws')

const app = express()

// 将WebSocket服务加到app里,简单来说就是让app添加了ws方法
expressWs(app)

// 建立WebSocket服务
app.ws('/mysocket'function (ws{
  // ws:建立WebSocket的实例
  ws.send('你连接成功啦')

  ws.onmessage = function ({ data }{
    if (data.includes('你好')) {
      ws.send('你好,我是服务器ddd')
    } else if (data.includes('再见')) {
      ws.send('再见,客户端ccc')
    }
  }
})

app.listen(8088, () => {
  console.log('ws://localhost:8088')
})
WebSocket(简单体验版)
image-20220529175742257

注意:如果收发部分处理,需要注意一下,如果没有处理好,可能会出现循环卡住的情况。

比如,服务器和客户端的message事件回调都是:

socket.onmessage = function ({ data }{
    socket.send('hello')
}
WebSocket(简单体验版)
image-20220529180303794


原文始发于微信公众号(赤蓝紫):WebSocket(简单体验版)

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

文章由极客之音整理,本文链接:https://www.bmabk.com/index.php/post/45288.html

(0)
小半的头像小半

相关推荐

发表回复

登录后才能评论
极客之音——专业性很强的中文编程技术网站,欢迎收藏到浏览器,订阅我们!