【ECMAScript】WebSocket模拟HTTP功能的实践:Promise+WebSocket+EventEmitter+Queue

news/2025/2/12 8:54:26/
1. 前言

        本篇将结合Promise、WebSocket、EventEmitter和Queue,做一次实践:用WebSocket来模拟HTTP的功能。先不用关心它的用处,就当一次对知识点的整合吧。

2. MockHTTP
方法说明
request(params, callback?)

功能:发起请求,生成uuid标记数据params,将回调逻辑once到事件发射器中,返回一个Promise对象,等待receive触发emit,执行回调逻辑

输入

params - 发送给服务端的数据

callback? - 可选,采用回调函数方式接收数据

输出:Promise<any>

send(params)

功能:将数据推入队列中,待loop取出

输入:params

loop()功能:定时从队列队头取出数据,发给服务端
receive(e)

功能:接收响应数据,触发事件发射器emit方法

输入:e - 事件对象

close()功能:关闭WebSocket连接

import EventEmitter from './EventEmiter';
import Queue from './Queue';export default class MockHTTP {constructor(url) {this.ws = new WebSocket(url);this.eventEmitter = new EventEmitter();this.queue = new Queue();this.ws.onmessage = this.receive;}loop() {if(this.queue.size() && this.ws.readyState === this.ws.OPEN) {// 发起请求const params = this.queue.dequeue();this.ws.send(JSON.stringify(params));}requestAnimationFrame(this.loop);}// 接收数据receive(e) {const data = e.data;const uuid = data.uuid;if(uuid) {this.eventEmitter.emit(uuid);}}send(params) {// 发起的请求放到队列中this.queue.enqueue(params);}// 请求request(params, callback) {return new Promise((resolve, reject) => {// 生成uuid,用来匹配发起的ws请求 和 ws响应const uuid = `${new Date().valueOf()}${Math.round(Math.random() * 1000)}`;// 将回调函数放入事件发射器this.eventEmitter.once(uuid, (data) => {// 采用回调函数接收响应数据if(callback) {callback(data);}// resolveresolve(data);});params.uuid = uuid;this.send(params);});}// 关闭websocket连接close() {this.ws.close();}
}

注:本篇未考虑WebSocket创建失败或连接异常的情况。

3. request执行周期

        从第1步发起请求,最第8步最终响应,经历的过程如下图所示。

其中,

  • 第2步订阅和第7步发布,是事件发射器EventEmitter的订阅/发布功能;
  • 第3步入队和第4步出队,是队列Queue的入队/出队功能;
  • 第5步发送消息和第6步监听响应,是WebSocket的发送send/接收onmessage的功能;
  • 第1步发起请求和第8步执行回调,是用于构建Promise的函数的功能,第8步会使得Promise状态从pending转成fulfilled。
4. Demo源码
const HTTP = new MockHTTP('http://localhost:8080/ws');
const params = {method: 'add',data: {name: '小明',sex: '男',age: 13}
};HTTP.request(params).then((data) => {console.dir(data);
});

有兴趣的同学,可参考我的博文。

【ECMAScript】自己动手实现ES6的Promise-CSDN博客

【网络协议】WebSocket知识点梳理和总结-CSDN博客

【ECMAScript】基于Map和Set手写一个简单EventEmitter实现事件的发布和订阅-CSDN博客

【数据结构】自己动手使用JavaScript实现栈、队列、双端队列(第一篇)-CSDN博客

注:以上,如有不合理之处,还请帮忙指出,大家一起交流学习~   


http://www.ppmy.cn/news/1295544.html

相关文章

【Python排序算法系列】—— 希尔排序

&#x1f308;个人主页: Aileen_0v0 &#x1f525;热门专栏: 华为鸿蒙系统学习|计算机网络|数据结构与算法 &#x1f4ab;个人格言:"没有罗马,那就自己创造罗马~" 目录 希尔排序 &#xff08;ShellSort&#xff09; 由来和特点 理解 过程演示 Step1&#xff1a;…

【前端】JavaScript的基本用法

JavaScript的基本用法 1.如何使用Js脚本 1).引入Js文件 在头部标签中导入脚本标签并指明脚本文件路径 <head><script src="XXX.js"></script></head> 1. 2).标签中使用 <body><script >javascript 语句</script></b…

区间预测 | Matlab实现CNN-LSTM-KDE的卷积长短期神经网络结合核密度估计多变量时序区间预测

区间预测 | Matlab实现CNN-LSTM-KDE的卷积长短期神经网络结合核密度估计多变量时序区间预测 目录 区间预测 | Matlab实现CNN-LSTM-KDE的卷积长短期神经网络结合核密度估计多变量时序区间预测效果一览基本介绍程序设计参考资料 效果一览 基本介绍 1.CNN-LSTM-KDE多变量时间序列区…

kafka 偏移量的类型与提交方式

kafka checkpoint 在流处理中,“checkpoint” 通常指的是将应用程序的状态保存到可靠的存储系统中,以便在发生故障或应用程序需要重启时能够从先前的状态中恢复。这包括保存处理过的事件、中间结果以及任何其他状态信息。“Checkpointing” 可以确保系统的一致性,并提供容错…

RabbitMQ路由模式

package com.java1234.producer.config;import org.springframework.amqp.core.*; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration;Configuration public class RabbitMQConfig {/*** direct交换机名称*/p…

Android 实现动态申请各项权限

在Android应用中&#xff0c;如果需要使用一些敏感的权限&#xff08;例如相机、位置等&#xff09;&#xff0c;需要经过用户的授权才能访问。在Android 6.0&#xff08;API级别23&#xff09;及以上的版本中&#xff0c;引入了动态权限申请机制。以下是在Android应用中实现动…

【设计模式之美】理论一:怎么才算是单一原则、如何取舍单一原则

文章目录 一. 如何判断类的职责是否足够单一&#xff1f;二. 类的职责是否设计得越单一越好&#xff1f; 开始学习一些经典的设计原则&#xff0c;其中包括&#xff0c;SOLID、KISS、YAGNI、DRY、LOD 等。 本文主要学习单一职责原则的相关内容。 单一职责原则的定义&#xff1a…

SpringBoot实用开发(十二)-- MongoDB语句的简单使用

目录 1.新增文档 2.删除文档 3.修改文档 4.查询文档 4.1 基础查询 4.2 条件