WebSocket 协议
原文地址：xupengboo
WebSocket
WebSocket 是 HTML5 开始提供的一种在单个 TCP 连接上进行全双工通讯的协议。
在 WebSocket API 中，浏览器和服务器只需要完成一次握手，两者之间就直接可以创建持久性的连接，并进行双向数据传输。
传统的一些网站推送技术，使用的技术是Ajax轮询。这种传统的模式带来很明显的缺点，即浏览器需要不断的向服务器发出请求，然而HTTP请求可能包含较长的头部，其中真正有效的数据可能只是很小的一部分，显然这样会浪费很多的带宽等资源。HTML5 定义的 WebSocket 协议，能更好的节省服务器资源和带宽，并且能够更实时地进行通讯。
聊天室案例，index.html ：
<!DOCTYPE html>
<html lang="en">
<head><meta charset="UTF-8"><meta name="viewport" content="width=device-width, initial-scale=1.0"><title>WebSocket 聊天室</title>
</head>
<body><h1>WebSocket 聊天室</h1><div><input id="messageInput" type="text" placeholder="输入消息..." /><button onclick="sendMessage()">发送</button></div><div><h2>聊天记录：</h2><pre id="chatLog"></pre></div><script>// 连接到 WebSocket 服务器const ws = new WebSocket('ws://localhost:8080/chat');// 监听 WebSocket 打开事件ws.onopen = function() {console.log('WebSocket 连接已打开');};// 监听 WebSocket 消息事件ws.onmessage = function(event) {console.log('收到服务器消息:', event.data);document.getElementById('chatLog').textContent += event.data + '\n';};// 发送消息到服务器function sendMessage() {const message = document.getElementById('messageInput').value;ws.send(message);}// 监听 WebSocket 错误事件ws.onerror = function(error) {console.error('WebSocket 错误:', error);};// 监听 WebSocket 关闭事件ws.onclose = function() {console.log('WebSocket 连接已关闭');};</script>
</body>
</html>
通过 SpringBoot 实现后台，WebSocket 通信服务：
- 引入
WebSocket依赖：
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
- 定义一个
WebSocket Handler继承类：
package com.itholmes.demo.websocket;import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketSession;
import org.springframework.web.socket.handler.TextWebSocketHandler;import java.util.Collections;
import java.util.HashSet;
import java.util.Set;/*** @Author xupengboo* @Date 2024/9/12 9:25* @Describe*/
public class ChatWebSocketHandler extends TextWebSocketHandler {// 用于存储所有客户端连接private final Set<WebSocketSession> sessions = Collections.synchronizedSet(new HashSet<>());// 当客户端连接时触发@Overridepublic void afterConnectionEstablished(WebSocketSession session) throws Exception {sessions.add(session);System.out.println("新连接：" + session.getId());}// 当收到客户端消息时触发@Overrideprotected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {String payload = message.getPayload();System.out.println("收到消息：" + payload);// 将消息广播给所有连接的客户端for (WebSocketSession webSocketSession : sessions) {if (webSocketSession.isOpen()) {webSocketSession.sendMessage(new TextMessage("客户端 " + session.getId() + " 说：" + payload));}}}// 当连接关闭时触发@Overridepublic void afterConnectionClosed(WebSocketSession session, org.springframework.web.socket.CloseStatus status) throws Exception {sessions.remove(session);System.out.println("连接关闭：" + session.getId());}}
- 配置
WebSocketConfigurer类：
package com.itholmes.demo.websocket;import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.config.annotation.EnableWebSocket;
import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;/*** @Author xupengboo* @Date 2024/9/12 9:26* @Describe*/
@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {@Overridepublic void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {// 注册 WebSocket 处理器和路径registry.addHandler(new ChatWebSocketHandler(), "/chat").setAllowedOrigins("*"); // 允许跨域}}
- 启动服务，配合前端测试即可。
相关文章：
WebSocket 协议
原文地址：xupengboo WebSocket WebSocket 是 HTML5 开始提供的一种在单个 TCP 连接上进行全双工通讯的协议。 在 WebSocket API 中，浏览器和服务器只需要完成一次握手，两者之间就直接可以创建持久性的连接，并进行双向数据传输。…...
[mysql]mysql排序和分页
#排序和分页本身是两块内容,因为都比较简单,我们就把它分到通一个内容里. #1排序: SELECT * FROM employees #我们会发现,我们没有做排序操作,但是最后出来的107条结果还是会按顺序发出,而且是每次都一样.这我们就有一个疑惑了,现在我们的数据库是根据什么来排序的,在我们没有进…...
开源 AI 智能名片 S2B2C 商城小程序中的全渠道供应策略
摘要：本文深入探讨在开源 AI 智能名片 S2B2C 商城小程序的情境下，全渠道供应的运行机制。阐述各环节企业相互配合的重要性，重点分析零售企业在其中的关键作用，包括协调工作、信息传递、需求把握等方面，旨在实现高效的全…...
一次渲染十万条数据：前端技术优化（上）
今天看了一篇文章，写的是一次性渲染十万条数据的方法，本文内容是对这篇文章的学习总结，以及知识点补充。 在现代Web应用中，前端经常需要处理大量的数据展示，例如用户评论、商品列表等。直接渲染大量数据会导致浏览器性…...
springboot实训学习笔记（5）(用户登录接口的主逻辑)
接着上篇博客学习。上篇博客是已经基本完成用户模块的注册接口的开发以及注册时的参数合法性校验。具体往回看了解的链接如下。 springboot实训学习笔记（4）(Spring Validation参数校验框架、全局异常处理器)-CSDN博客文章浏览阅读576次，点赞7…...
python中网络爬虫框架
Python 中有许多强大的网络爬虫框架，它们帮助开发者轻松地抓取和处理网页数据。最常用的 Python 网络爬虫框架有以下几个： 1. Scrapy Scrapy 是 Python 中最受欢迎的网络爬虫框架之一，专为大规模网络爬取和数据提取任务而设计。它功能强大、…...
GEC6818初次连接使用
目录 1.开发板资源接口编辑编辑 2.安装 SecureCRT工具 2.1SecureCRT相关问题 3.连接开发板 4.开发板文件传输 4.1串口传输 rx 从电脑下载文件到开发板 sz 从开发板把文件发送到电脑 4.2U盘/SD卡传输 4.3网络传输[重点] 5.运行传到开发板的可执行文件 6.开发板网络…...
解释下不同Gan模型之间的异同点
生成对抗网络（GAN, Generative Adversarial Network）是一类强大的生成模型。随着时间的推移，研究人员提出了许多不同的 GAN 变体来改善原始模型的性能或针对特定任务进行优化。下面将解释一些常见的 GAN 变体，并讨论它们的异同点。…...
Hadoop的一些高频面试题 --- hdfs、mapreduce以及yarn的面试题
文章目录 一、HDFS1、Hadoop的三大组成部分2、本地模式和伪分布模式的区别是什么3、什么是HDFS4、如何单独启动namenode5、hdfs的写入流程6、hdfs的读取流程7、hdfs为什么不能存储小文件8、secondaryNameNode的运行原理9、hadoop集群启动后离开安全模式的条件10、hdfs集群的开机…...
Day99 代码随想录打卡|动态规划篇--- 01背包问题
题目（卡玛网T46）： 小明是一位科学家，他需要参加一场重要的国际科学大会，以展示自己的最新研究成果。他需要带一些研究材料，但是他的行李箱空间有限。这些研究材料包括实验设备、文献资料和实验样本等等&am…...
往证是什么意思
“往证”通常是在数学证明中使用的一种方法，尤其是在证明某个结论的相反（即否定）是错误的情况下。具体来说，就是假设结论不成立，然后通过逻辑推理展示出这种假设导致矛盾，从而得出原结论必然成立。 举例说…...
Camunda流程引擎并发性能优化
文章目录 Camunda流程引擎一、JobExecutor1、工作流程2、主要作用 二、性能问题1、实际场景：2、性能问题描述3、总结 三、优化方案方案一：修改 Camunda JobExecutor 源码以实现租户 ID 隔离方案二：使用 max-jobs-per-acquisition 参数控制上锁…...
spring springboot 日志框架
一、常见的日志框架 JUL、JCL、Jboss-logging、logback、log4j、log4j2、slf4j.... 注意：SLF4j 类似于接口 Log4j ，Logback 都是出自同一作者之手 JUL 为apache 公司产品 Spring（commons-logging）、Hibernate（jboss…...
【D3.js in Action 3 精译_022】3.2 使用 D3 完成数据准备工作
当前内容所在位置 第一部分 D3.js 基础知识 第一章 D3.js 简介（已完结） 1.1 何为 D3.js？1.2 D3 生态系统——入门须知1.3 数据可视化最佳实践（上）1.3 数据可视化最佳实践（下）1.4 本章小结 第二章…...
电脑怎么禁用软件?5个方法速成，小白必入！
电脑禁用软件的方法多种多样，以下是五种简单易行的方法. 适合不同需求的用户，特别是电脑小白。 1. 使用任务管理器禁用启动项 操作步骤：按下“Ctrl Shift Esc”组合键，打开任务管理器。 切换到“启动”选项卡，找到…...
力扣之181.超过经理收入的员工
文章目录 1. 181.超过经理收入的员工1.1 题干1.2 准备数据1.3 题解1.4 结果截图 1. 181.超过经理收入的员工 1.1 题干 表：Employee -------------------- | Column Name | Type | -------------------- | id | int | | name | varchar | | salary | int | | mana…...
C++语法应用：从return机制看返回指针，返回引用
前言 编程是极其注重实践的工作,学习的同时要伴随代码 引入 此前对返回指针和引用有一些纠结，从return角度来观察发生了什么。 return机制 函数中return表示代码结束，如果return后面有其他代码将不被执行。 return发生了值转移，return后面的…...
Linux5-echo,＞,tail
1.echo命令 echo是输出命令，类似printf 例如：echo "hello world"，输出hello world echo pwd，输出pwd的位置。是键盘上~ 2.重定向符> >> >指把左边内容覆盖到右边 echo hello world>test.txt >…...
sqlgun靶场训练
1.看到php？id ，然后刚好有个框，直接测试sql注入 2.发现输入1 union select 1,2,3#的时候在2处有回显 3.查看表名 -1 union select 1,group_concat(table_name),3 from information_schema.tables where table_schemadatabase()# 4.查看列名…...
简化登录流程，助力应用建立用户体系
随着智能手机和移动应用的普及，用户需要在不同的应用中注册和登录账号，传统的账号注册和登录流程需要用户输入用户名和密码，这不仅繁琐而且容易造成用户流失。 华为账号服务(Account Kit)提供简单、快速、安全的登录功能，让用户快…...
【研发日记】嵌入式处理器技能解锁(六)——ARM的Cortex-M4内核
文章目录 前言 背景介绍 指令集架构 ARM起源 ARM分类 Cortex-M4 内核框架 指令流水线 实践应用 总结 参考资料 前言 见《【研发日记】嵌入式处理器技能解锁(一)——多任务异步执行调度的三种方法》 见《【研发日记】嵌入式处理器技能解锁(二)——TI C2000 DSP的SCI(…...
深度学习经典模型之T5
T5(Text-to-Text Transfer Transformer) 是继BERT之后Google的又外力作，它是一个文本到文本迁移的基于Transformer的NLP模型，通过将 所有任务统一视为一个输入文本并输出到文本(Text-to-Text)中，即将任务嵌入在输入文本中，用文本的…...
10.第二阶段x86游戏实战2-反编译自己的程序加深堆栈的理解
免责声明：内容仅供学习参考，请合法利用知识，禁止进行违法犯罪活动！ 本次游戏没法给 内容参考于：微尘网络安全 工具下载： 链接：https://pan.baidu.com/s/1rEEJnt85npn7N38Ai0_F2Q?pwd6tw3 提…...
ARM总复习
1.计算机的组成 输入设备 输出设备 存储设备 运算器 控制器、总线 2.指令和指令集 2.1 机器指令 机器指令又叫机器码，在运算器内部存在各种运算电路，当处理器从内存中获取一条机器指令，就可以按照指令让运算器内部的指定的运算电路进行运…...
使用ENVI之大气校正（下）
再根据遥感影像的拍摄时间将Flight ate与Flight Time GMT (H:M:SS)填写，如要查询按如下方法 这里按照表中的内容修改 根据影像范围的经纬度与拍摄时间更改Atmospheric Model，更改完成后点击Multispectral Settings...在跳出的界面中选择GUI再点击Default…...
C++（学习）2024.9.18
目录 C基础介绍 C特点 面向对象的三大特征 面向对象与面向过程的区别 C拓展的非面向对象的功能 引用 引用的性质 引用的参数 指针和引用的区别 赋值 键盘输入 string字符串类 遍历方式 字符串与数字转换 函数 内联函数 函数重载overload 哑元函数 面向对象基…...
认知小文2《成功之路：习惯、学习与实践》
内容摘要： 在这个充满机遇的时代，成功不再是偶然，而是可以通过培养良好习惯、持续学习和实践来实现的目标。 一、肌肉记忆：技能的基石 成功往往需要像运动员一样，通过日复一日的练习来形成肌肉记忆。无论是健身…...
【数据仓库】数据仓库层次化设计
一、基本概念 **1. RDS（RAW DATA STORES，原始数据存储）** RDS作为原始数据存储层，用于存储来自各种源头的未经处理的数据。这些数据可能来自企业内部的业务系统、外部数据源或各种传感器等。RDS确保原始数据的完整性和可访问性&…...
【DAY20240918】03教你轻松配置 Git 远程仓库并高效推送代码！
文章目录 前言 git diff一、远程仓库？1、在 Gitee 上新建仓库：2、Git 全局设置：3、添加远程仓库：4、推送本地代码到远程仓库：5、输入用户名和密码：6、后续推送： 二、全情回顾三、参考 前言 git …...
从IPC摄像机读取视频帧解码并转化为YUV数据到转化为Bitmap
前言 本文主要介绍根据IPC的RTSP视频流地址，连接摄像机，并持续读取相机视频流，进一步进行播放实时画面，或者处理视频帧，将每一帧数据转化为安卓相机同格式数据，并保存为bitmap。 示例 val rtspClientListener = object: RtspClient.RtspClientListener {override fun …...