当前位置: 首页 > news >正文

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

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博客

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

相关文章:

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

1. 前言 本篇将结合Promise、WebSocket、EventEmitter和Queue&#xff0c;做一次实践&#xff1a;用WebSocket来模拟HTTP的功能。先不用关心它的用处&#xff0c;就当一次对知识点的整合吧。 2. MockHTTP 方法说明request(params, callback?) 功能&#xff1a;发起请求&…...

Linux 软raid - - Barrier

什么是Barriers 在linux软raid中&#xff0c;用来处理正常IO和同步IO的并发问题&#xff0c;可以简单理解为专用于软raid的锁。 软raid在做resync/recovery&#xff0c;或者配置操作时需要raise 屏障&#xff0c;于此同时必须暂停正常IO。 barrier是可以被多次raise的一个计数…...

航空公司管理系统(迷你版12306)

要求 今天分享一个之前辅导留学生的作业&#xff0c;作业要求如下&#xff1a; Project E: Airways Management System Overall description: Your team is employed by an Airways company for the implementation of a computer system responsible for a large part of th…...

嵌入式硬件电路原理图之跟随电路

描述 电压跟随电路 电压跟随器是共集电极电路&#xff0c;信号从基极输入&#xff0c;射极输出&#xff0c;故又称射极输出器。基极电压与集电极电压相位相同&#xff0c;即输入电压与输出电压同相。这一电路的主要特点是&#xff1a;高输入电阻、低输出电阻、电压增益近似为…...

学习录

概述 这几年在迷茫中看了不少资料&#xff0c;有觉得写得很棒的&#xff0c;也有写的很糟糕的。所以一直想写这块的总结来进行归纳&#xff0c;同时也希望能给其他处于迷茫中的朋友提供一份高质量的资料列表(也许一个读者也没有)&#xff0c;以下清单个人觉得值得反复看以及思…...

MongoDB索引详解

概述 索引是一种用来快速查询数据的数据结构。BTree 就是一种常用的数据库索引数据结构&#xff0c;MongoDB 采用 BTree 做索引&#xff0c;索引创建 colletions 上。MongoDB 不使用索引的查询&#xff0c;先扫描所有的文档&#xff0c;再匹配符合条件的文档。使用索引的查询&…...

一文搞定JVM内存模型

鲁大猿&#xff0c;寻精品资料&#xff0c;帮你构建Java全栈知识体系 www.jiagoujishu.cn 运行时数据区 内存是非常重要的系统资源&#xff0c;是硬盘和 CPU 的中间仓库及桥梁&#xff0c;承载着操作系统和应用程序的实时运行。JVM 内存布局规定了 Java 在运行过程中内存申请、…...

月报总结|Moonbeam 12月份大事一览

一转眼已经到年底啦。本月&#xff0c;Moonbeam基金会发布四个最新战略重点&#xff1a;跨链解决方案、游戏、真实世界资产&#xff08;RWA&#xff09;、新兴市场。其中在新兴市场方面&#xff0c;紧锣密鼓地推出与巴西公司Grupo RO的战略合作。 用户教育方面&#xff0c;为了…...

现有网络模型的使用及修改(VGG16为例)

VGG16 修改默认路径 import os os.environ[TORCH_HOME] rD:\Pytorch\pythonProject\vgg16 # 下载位置太大了&#xff08;140多G&#xff09;不提供直接下载 train_set torchvision.datasets.ImageNet(root./data_image_net, splittrain, downloadTrue, transformtorchvis…...

MacOS M1/M2 Go Debug 配置

前言 换电脑&#xff0c;Go 环境带来一些麻烦&#xff0c;耽误很多时间&#xff0c;稍作记录。 原始电脑是 Mac 旧款&#xff0c;CPU x86 构型&#xff0c;新电脑 M2&#xff0c;因为旧电脑里本地文件很多&#xff0c;为了简化搬迁&#xff0c;还是用了 Mac 自带的迁移&#x…...

paddlehub 文本检测使用

PaddleHub负责模型的管理、获取和预训练模型的使用。 参考&#xff1a;https://github.com/PaddlePaddle/PaddleHub/tree/develop/modules/image/text_recognition/chinese_text_detection_db_server import paddlehub as hub import cv2 # from utils import cv_show import…...

负载均衡概述

负载均衡 负载均衡 建立在现有网络结构之上&#xff0c;它提供了一种廉价有效透明的方法扩展网络设备和服务器的带宽、增加吞吐量、加强网络数据处理能力、提高网络的灵活性和可用性。 四层负载均衡 vs 七层负载均衡 四层负载均衡&#xff08;目标地址和端口交换&#xff09;…...

C# WinForm MessageBox自定义按键文本 COM组件版

c# 更改弹窗MessageBox按钮文字_c# messagebox.show 字体-CSDN博客 需要用到大佬上传到百度云盘的Hook类&#xff0c;在大佬给的例子的基础上改动了点。 应用时自己加GUID和ProgID。 组件实现&#xff1a; using System; using System.Collections.Generic; using System.L…...

基于SpringBoot微信小程序的宠物美容预约系统设计与实现

博主介绍&#xff1a;✌全网粉丝30W,csdn特邀作者、博客专家、CSDN新星计划导师、Java领域优质创作者,博客之星、掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java技术领域和学生毕业项目实战,高校老师/讲师/同行交流合作✌ 主要内容&#xff1a;SpringBoot、Vue、SSM、HLM…...

在 docker 容器中配置双网卡,解决通讯的问题

目录 1. 查看当前网络信息 2. 创建自定义网络桥 3. 创建双网卡模式 4. 删除默认网卡 已经创建好了的 Docker 容器&#xff0c;要修改它的IP比较麻烦&#xff0c;网上找了几种不同的方法&#xff0c;经过试验都没有成功&#xff0c;下面通过配置双网上来解决 IP 的问题。…...

uniapp中uview组件库CircleProgress 圆形进度条丰富的使用方法

目录 #内部实现 #平台差异说明 #基本使用 #设置圆环的动画时间 #API #Props 展示操作或任务的当前进度&#xff0c;比如上传文件&#xff0c;是一个圆形的进度环。 #内部实现 组件内部通过canvas实现&#xff0c;有更好的性能和通用性。 #平台差异说明 AppH5微信小程…...

Linux操作系统基础(12):Linux的Shell解释器

1. Shell的介绍 在Linux中&#xff0c;Shell 是一种命令行解释器&#xff0c;它是用户与操作系统内核之间的接口&#xff0c;它负责解释用户输入的命令&#xff0c;并将其转换成系统调用或其他操作系统能够执行的指令。 Shell 提供了一种交互式的方式来与操作系统进行通信&am…...

Android开发编程从入门到精通,安卓技术从初级到高级全套教学

一、教程描述 本套教程基于JDK1.8版本&#xff0c;教学内容主要有&#xff0c;1、环境搭建&#xff0c;UI布局&#xff0c;基础UI组件&#xff0c;高级UI组件&#xff0c;通知&#xff0c;自定义组件&#xff0c;样式主题&#xff1b;2、四大组件&#xff0c;Intent&#xff0…...

HackTheBox - Medium - Linux - BroScience

BroScience BroScience 是一款中等难度的 Linux 机器&#xff0c;其特点是 Web 应用程序容易受到“LFI”的攻击。通过读取目标上的任意文件的能力&#xff0c;攻击者可以深入了解帐户激活码的生成方式&#xff0c;从而能够创建一组可能有效的令牌来激活新创建的帐户。登录后&a…...

`nginx/conf/nginx.conf`最简配置说明

nginx/conf/nginx.conf最简配置说明 代码 nginx/conf/nginx.conf worker_processes 1; #工作进程个数;一般对应CPU内核对应一个worker_processes;太多反而让效率变差;# 事件驱动模块; events {worker_connections 1024;#设置每个worker_processes对应多少个联接; }# 网络请…...

不止于解题:用玄机靶场案例,打造你的自动化安全日志监控脚本

不止于解题&#xff1a;用玄机靶场案例打造自动化安全日志监控脚本 在网络安全领域&#xff0c;日志分析往往是防御的第一道防线。当我们在玄机靶场中完成SSH爆破日志分析的解题后&#xff0c;是否想过将这些手动操作转化为自动化工具&#xff1f;本文将带你从单次解题跃升到持…...

DanKoe 视频笔记:数字时代财富创造指南:思想是新石油

在本节课中&#xff0c;我们将探讨在数字时代创造财富的新范式。我们将分析传统投资和房地产的局限性&#xff0c;并揭示“思想”如何成为这个时代最宝贵的、可无限开采的资源。通过理解并构建“数字房地产”&#xff0c;任何人都可以踏上一条全新的致富之路。 概述&#xff1…...

企业级大数据产品架构设计指南

企业级大数据产品架构设计指南&#xff1a;从概念到落地的完整方案 标题选项 企业级大数据架构设计全攻略&#xff1a;从0到1构建可扩展的数据平台大数据产品架构设计指南&#xff1a;如何打造高性能、高可用的企业级解决方案从理论到实践&#xff1a;企业级大数据产品架构设计…...

别再只画流程图了!用AntV G6-Editor在Angular里搭建一个可交互的作业调度系统

用AntV G6-Editor在Angular中构建企业级作业调度可视化平台 当我们需要在Angular项目中实现复杂的作业调度系统时&#xff0c;传统的流程图工具往往难以满足业务需求。AntV G6-Editor作为专业级可视化编辑框架&#xff0c;提供了从基础绘图到深度定制的完整解决方案。本文将带你…...

ESP8266红外TCP服务框架:轻量级协议网关设计

1. 项目概述IrServiceBase是专为 ESP8266 系列微控制器&#xff08;包括 ESP-01、NodeMCU、Wemos D1 Mini 等&#xff09;设计的 Arduino C 库&#xff0c;其核心定位并非直接驱动红外发射/接收硬件&#xff0c;而是构建一个可复用、可扩展的 TCP/IP 红外服务框架。该库不实现底…...

NSLogger高级过滤技巧:正则表达式实战指南

NSLogger高级过滤技巧&#xff1a;正则表达式实战指南 【免费下载链接】NSLogger A modern, flexible logging tool 项目地址: https://gitcode.com/gh_mirrors/ns/NSLogger NSLogger是一款现代、灵活的日志记录工具&#xff0c;专为macOS、iOS和Android平台设计。它取代…...

多语言支持测试:OpenClaw对接Qwen3-32B镜像处理非英语任务

多语言支持测试&#xff1a;OpenClaw对接Qwen3-32B镜像处理非英语任务 1. 测试背景与实验设计 最近在探索如何用本地化AI工具处理多语言工作流时&#xff0c;我注意到OpenClaw框架的灵活性——它不仅能对接各类大模型&#xff0c;还能通过技能扩展实现跨语言自动化。这次我决…...

2026年3月26隔夜暗盘挂单排行榜

推荐好文:每年节约五六千交易费不香吗如何获取龙虎榜是否有量化参与如何获取股东减持信息大A有5400多只股票, 这里面只有不到10%, 约500只由资金投票, 剩余的都是杂毛, 炒股看龙头找主线. 从隔夜挂单里选择, 再叠加我们之前分享的如何判断是否有大股东减持, 是否有融资融券参与…...

相场法在水力压裂仿真中越来越火,它能用连续函数描述裂缝边界,比传统方法更适合处理复杂裂缝网络。今天咱们拿COMSOL 6.0开刀,看看四个实战模型的实现门道

相场法水力压裂&#xff0c;共四个模型&#xff0c;comsol6.0版本及以上&#xff0c;附赠参考文献 模型一&#xff1a;对称三簇压裂&#xff1b;模型二&#xff1a;水力裂缝与天然裂缝相交&#xff1b;模型三&#xff1a;单水平裂缝扩展&#xff1b;模型四&#xff1a;水平裂缝…...

iMeta 5卷1期封底:肠・太极

点击蓝字 关注我们肠・太极。本封面设计灵感来自盘龙、太极阴阳等中国传统文化元素。外周盘龙形若肠道&#xff0c;象征完整的肠道屏障结构&#xff1b;中心太极图寓意肠道微环境的动态平衡。太极两仪分别对应肠上皮细胞线粒体与肠道菌群这两大核心调控者&#xff0c;诠释了唯有…...