webSocket基于面向对象二次封装

今天不睡,熬夜赶了个WebSocket 二次封装,也对这几天文章摸鱼感到抱歉,所以我出了一个注释非常非常全的代码

思路如下
首先,需要通过调用connect方法来建立WebSocket连接。当连接成功时,会调用我提供的回调函数,并将连接成功的消息帧作为参数传递给它。在回调函数中,我们可以打印消息帧到控制台中。如果连接失败,则会执行catch回调函数,并打印错误信息到控制台中。

一旦连接成功,可以继续执行订阅主题的操作。通过调用subscribe方法,可以订阅一个特定的主题。当接收到消息时,会调用提供的回调函数,并将解析后的数据作为参数传递给它。在回调函数中,可以打印收到的数据到控制台中。如果订阅失败,则会执行catch回调函数,并打印错误信息到控制台中。

看在这么全的份上,请点个赞,不懂得可以问博主,看到会回

// 定义一个名为WebSocketClient的类  
class WebSocketClient {  // 构造函数,接收一个url作为参数,用于初始化WebSocketClient对象  constructor(url: string) {  // 将传入的url赋值给this.url,保存url的信息  this.url = url;  // 初始化socket属性为null,表示尚未建立WebSocket连接  this.socket = null;  // 初始化stompClient属性为null,表示尚未建立Stomp客户端连接  this.stompClient = null;  }  // 定义一个名为connect的方法,用于建立WebSocket连接并返回Promise对象  connect() {  // 返回一个新的Promise对象,Promise的参数是一个函数,该函数接收resolve和reject两个参数  return new Promise<void, Error>((resolve, reject) => {  try {  // 创建一个新的SockJS实例,使用this.url作为参数,尝试建立WebSocket连接  this.socket = new SockJS(this.url);  // 使用已建立的WebSocket连接创建一个Stomp客户端,stompClient属性保存这个客户端的引用  this.stompClient = Stomp.over(this.socket);  // 设置stompClient的debug属性为null,关闭日志输出    this.stompClient.debug = null; // 关闭日志      // 使用stompClient的connect方法进行连接,传入空回调函数和错误回调函数  this.stompClient.connect({}, (frame: { [key: string]: any }) => { // 当连接成功时,回调空回调函数,并将连接成功的消息帧传递给resolve参数  resolve(frame);  }, function (error) {  // 当连接失败时,回调错误回调函数,并将错误信息传递给reject参数  reject(error);  });  } catch (error) {  // 如果在尝试建立WebSocket连接或Stomp客户端的过程中抛出错误,将错误信息传递给reject参数  reject(error);  }  });  }  // 定义一个名为subscribe的方法,用于在已建立的连接上订阅主题并返回Promise对象  subscribe(topic: string) {  // 返回一个新的Promise对象,Promise的参数是一个函数,该函数接收resolve和reject两个参数  return new Promise<any, Error>((resolve, reject) => {  try {  // 使用已建立的stompClient和给定的主题进行订阅,传入一个回调函数和错误回调函数  this.stompClient.subscribe(topic, (data: any) => {  // 当接收到消息时,回调回调函数,并解析消息体为JSON格式的数据,然后打印到控制台中  var dataGm = JSON.parse(data.body);  console.log('数据', dataGm);  // 将解析后的数据传递给resolve参数,表示订阅成功完成  resolve(dataGm);  });  } catch (error) {  // 如果在尝试订阅主题的过程中抛出错误,将错误信息传递给reject参数  reject(error);  }  });  }  
}  

调用就像下面这样调用就好了

	// 使用示例:    let socketUrl: string = "http://192.168.1.38:8080/gs-guide-websocket";  let client: WebSocketClient = new WebSocketClient(socketUrl);  client.connect().then((frame: { [key: string]: any }) => {  console.log('连接成功', frame);  }).catch((error: Error) => {  console.error('连接失败', error);  });  client.subscribe('/topic').then((dataGm: any) => {  console.log('订阅成功', dataGm);  }).catch((error: Error) => {  console.error('订阅失败', error);  });

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/151929.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【Java 进阶篇】Ajax 入门:打开前端异步交互的大门

欢迎来到前端异步交互的世界&#xff01;在这篇博客中&#xff0c;我们将深入探讨 Ajax&#xff08;Asynchronous JavaScript and XML&#xff09;&#xff0c;这是一项能够让你的网页在不刷新的情况下与服务器进行数据交互的技术。无论你是刚刚踏入前端开发的小白&#xff0c;…

多视图聚类论文阅读(二)

Deep multi-view semi-supervised clustering with sample pairwise constraints Neuro Compucting 基于样本对约束的深度多视图半监督聚类 1.1 聚类的相关工作 典型相关分析(CCA)[13]寻求两个投影&#xff0c;将两个视图映射到一个低维公共子空间&#xff0c;其中两个视图…

pycharm2023 实现鼠标点击某行,调试时代码运行至相应行

按下图取消 Breakpoints Over Line Numbers即可&#xff0c;然后调试时点击某行&#xff0c;代码就会运行至某行

图的基础知识(数据结构)

&#xff08;1&#xff09;已知无向图G各边的权值均为1&#xff0c;下列算法中一定能够求出G中从某个顶点到其余各个顶点的最短路径的是&#xff08;III&#xff09; I 普利姆算法 II 克鲁斯卡尔算法 III 图的广度优先搜索 &#xff08;2&#xff09;已知无向图中含有16…

【鸿蒙应用ArkTS开发系列】- 云开发入门简介

目录 概述开发流程工程概览工程模板工程结构 工程创建与配置 概述 HarmonyOS云开发是DevEco Studio新推出的功能&#xff0c;可以让您在一个项目工程中&#xff0c;使用一种语言完成端侧和云侧功能的开发。 基于AppGallery Connect Serverless构建的云侧能力&#xff0c;开发…

C#具名参数(Named Parameters)

在 C# 中&#xff0c;具名参数&#xff08;Named Parameters&#xff09;是一种在方法调用中使用参数名称来指定参数值的技术。通常情况下&#xff0c;我们使用位置参数&#xff08;Positional Parameters&#xff09;来按照方法参数的顺序传递参数值。但是&#xff0c;使用具名…

windows Oracle Database 19c 卸载教程

目录 打开任务管理器 停止数据库服务 Universal Installer 卸载Oracle数据库程序 使用Oracle Installer卸载 删除注册表项 重新启动系统 打开任务管理器 ctrlShiftEsc可以快速打开任务管理器&#xff0c;找到oracle所有服务然后停止。 停止数据库服务 在开始卸载之前&a…

golang学习笔记——多态

接口体现多态的两种形式 多态参数 在前面的Usb接口案例&#xff0c;Usb usb&#xff0c;即可以接收手机变量&#xff0c;又可以接收相机变量&#xff0c;就体现了Usb接口多态 多态数组 演示一个案例&#xff1a;给Usb数组中&#xff0c;存放Phone结构体和Camera结构体变量&…

C++数据结构:并查集

目录 一. 并查集的概念 二. 并查集的模拟实现 2.1 并查集类的声明 2.2 并查集的实现 三. 路径压缩 四. 总结 一. 并查集的概念 在生活中&#xff0c;我们经常需要对某一些事物进行归类处理&#xff0c;即&#xff1a;将N个不同的元素划分为几个互不相交的集合。在初始状态…

镭速,克服UDP传输缺点的百倍提速传输软件工具

在网络传输中&#xff0c;我们经常会面临这样的困难&#xff1a;文件太大&#xff0c;传输速度太慢&#xff0c;浪费时间和流量&#xff1b;文件太小&#xff0c;传输速度太快&#xff0c;容易出现丢包和乱序&#xff0c;损害数据的完整性和正确性。这些困难的根本在于传输层协…

var log逃逸

利用前置 1.root用户 2.有serviceaccount读取log 3. 挂载var log目录 apiVersion: v1 kind: ServiceAccount metadata:name: logger --- apiVersion: rbac.authorization.k8s.io/v1 kind: ClusterRole metadata:name: user-log-reader rules: - apiGroups: [""]r…

单图像3D重建AI算法综述【2023】

计算机视觉是人工智能的一个快速发展的领域&#xff0c;特别是在 3D 领域。 本概述将考虑一个应用任务&#xff1a;2D 和 3D 环境之间的转换。 在线工具推荐&#xff1a; Three.js AI纹理开发包 - YOLO合成数据生成器 - GLTF/GLB在线编辑 - 3D模型格式在线转换 - 可编程3D场景编…

小红书为什么没人看,小红书爆款标题怎么写?

作为快节奏的社会&#xff0c;人们追求的是不仅仅是高价值更是高性价比&#xff0c;和吸引度。而标题类似于门面&#xff0c;吸引程度自然作为重中之重。今天我们和大家分享下小红书为什么没人看&#xff0c;小红书爆款标题怎么写&#xff1f; 以母婴类型为例子&#xff0c;母婴…

《云计算:云端协同,智慧互联》

《云计算&#xff1a;云端协同&#xff0c;智慧互联》 云计算&#xff0c;这个科技领域中的热门词汇&#xff0c;正在逐渐改变我们的生活方式。它像一座座无形的桥梁&#xff0c;将世界各地的设备、数据、应用紧密连接在一起&#xff0c;实现了云端协同&#xff0c;智慧互联的愿…

网络参考模型与标准协议(二)-TCP/IP对等模型详细介绍

应用层 应用层为应用软件提供接口&#xff0c;使应用程序能够使用网络服务。应用层协议会指定使用相应的传输层协议&#xff0c;以及传输层所使用的端口等。TCP/IP每一层都让数据得以通过网络进行传输&#xff0c;这些层之间使用PDU ( Paket Data Unit,协议数据单元)彼此交换信…

Ubuntu(Linux)的基本操作

基本操作三步走 1、输入vim code.c点击i&#xff08;出现insert&#xff09;表示可以编辑代码编辑代码之后按下esc&#xff08;退出编辑模式&#xff09;按下shift:&#xff08;冒号&#xff09;wq&#xff08;退出文件&#xff09;2、输入gcc code.c&#xff08;进行编译代码…

【知识增强】A Survey of Knowledge-Enhanced Pre-trained LM 论文笔记

A Survey of Knowledge-Enhanced Pre-trained Language Models Linmei Hu, Zeyi Liu, Ziwang Zhao, Lei Hou, Liqiang Nie, Senior Member, IEEE and Juanzi Li 2023年8月的一篇关于知识增强预训练模型的文献综述 论文思维导图 思维导图网页上看不清的话&#xff0c;可以存…

软件测试:测试分类

一. 按照测试对象划分 1.1 界面测试 界面测试(简称UI测试),按照界面的需求(UI设计稿)和界面的设计规则,对我们软件界面所展示的全部内容进行测试和检查,一般包括如下内容: • 验证界面内容的完整性,一致性,准确性,友好性,兼容性.比如页面内容对屏幕大小的自适应,换行,内容是否…

GNU Radio 教程

初学者教程 GNU 无线电简介 什么是 GNU 无线电&#xff1f;安装 GNU 无线电你的第一个流程图 流程图基础知识 GRC 中的 Python 变量流程图中的变量运行时更新变量信号数据类型转换数据类型包装位流和向量层次块和参数 创建和修改 Python 块 创建你的第一个块带向量的 Pyt…

Leetcode_45:跳跃游戏 II

题目描述&#xff1a; 给定一个长度为 n 的 0 索引整数数组 nums。初始位置为 nums[0]。 每个元素 nums[i] 表示从索引 i 向前跳转的最大长度。换句话说&#xff0c;如果你在 nums[i] 处&#xff0c;你可以跳转到任意 nums[i j] 处: 0 < j < nums[i] i j < n 返…