SpringBoot 使用WebSocket功能
实现步骤：
1.导入WebSocket坐标。
在pom.xml中增加依赖项：
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
2.编写WebSocket配置类，用于注册WebSocket的Bean。
package com.rc114.config;import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.server.standard.ServerEndpointExporter;/*** WebSocket配置类，用于注册WebSocket的Bean* @author Administrator*/
@Configuration
public class WebSocketConfiguration {@Beanpublic ServerEndpointExporter serverEndpointExporter() {return new ServerEndpointExporter();}}
3.编写WebSocketServer类。
package com.rc114.websocket;import jakarta.websocket.OnClose;
import jakarta.websocket.OnMessage;
import jakarta.websocket.OnOpen;
import jakarta.websocket.Session;
import jakarta.websocket.server.PathParam;
import jakarta.websocket.server.ServerEndpoint;
import org.springframework.stereotype.Component;
import java.util.Collection;
import java.util.HashMap;
import java.util.Map;/*** WebSocket服务* @author Administrator*/
@Component // 交给spring容器管理
@ServerEndpoint("/ws/{sid}") // 路径请求
public class WebSocketServer {//存放会话对象private static Map<String, Session> sessionMap = new HashMap();/*** 连接建立成功调用的方法*/@OnOpenpublic void onOpen(Session session, @PathParam("sid") String sid) {System.out.println("客户端：" + sid + "建立连接");sessionMap.put(sid, session);}/*** 收到客户端消息后调用的方法** @param message 客户端发送过来的消息*/@OnMessagepublic void onMessage(String message, @PathParam("sid") String sid) {System.out.println("收到来自客户端：" + sid + "的信息:" + message);}/*** 连接关闭调用的方法** @param sid*/@OnClosepublic void onClose(@PathParam("sid") String sid) {System.out.println("连接断开:" + sid);sessionMap.remove(sid);}/*** 群发** @param message*/public void sendToAllClient(String message) {Collection<Session> sessions = sessionMap.values();for (Session session : sessions) {try {//服务器向客户端发送消息session.getBasicRemote().sendText(message);} catch (Exception e) {e.printStackTrace();}}}}
4.测试WebSocket
编写一个测试WebSocket的html页面：
<html><head><title>WebSocket测试页面</title><style type="text/css">* {font-size: 14px;line-height: 22px;}.main {border: 0px solid #ccc;width: 60%;margin: 0 auto;padding: 10px;}.main-table {width: 100%;border: 1px solid #ccc;border-collapse: collapse;}.main-table td {border: 1px solid #ccc;padding: 5px;}.td-left {text-align: right;}input[type="text"] {border: 1px solid #ccc;padding: 5px;outline: none;width: 200px;}input[type="button"] {border: 1px solid #ccc;padding: 3px 10px;outline: none;}.green {color: green;}.red {color: red;}#msg {font-size: 12px;line-height: 22px;}</style>
</head><body><div class="main"><table class="main-table"><tr><td colspan="2" style=" text-align: center;font-weight: bold;">WebSocket测试</td></tr><tr><td style="width: 100px;" class="td-left">服务器地址</td><td><input type="text" id="server" value="ws://localhost:8080/ws/"></td></tr><tr><td class="td-left">客户端名称</td><td><input type="text" id="clientId"><input type="button" value="随机生成" onclick="GenerateClientId()" /></td></tr><tr><td> </td><td><input type="button" value="连接" onclick="ConnectServer()" /></td></tr><tr><td class="td-left">连接状态</td><td> <span id="status"><span class='red'>未连接</span></span></td></tr><tr><td class="td-left">发送消息</td><td><input type="text" id="txt"></td></tr><tr><td> </td><td><input type="button" value="发送" onclick="SendMsg()" /><input type="button" value="清空" onclick="ClearLog()" /></td></tr><tr><td class="td-left">日志</td><td><div id="msg"></div></td></tr></table><script type="text/javascript">var websocket = null;var clientId = "";//随机生成客户端编号function GenerateClientId() {clientId = Math.random().toString().substr(2);document.getElementById("clientId").value = clientId;}GenerateClientId();//连接到服务器function ConnectServer() {var clientId = document.getElementById("clientId").value;if (clientId == "") {alert("客户端编号不能为空!");} else {if ("WebSocket" in window) {websocket = new WebSocket("ws://localhost:8080/ws/" + clientId);websocket.onerror = function () {ShowMsg("<span class='red'>ERROR</span>");}websocket.onopen = function () {document.getElementById("status").innerHTML = "<span class='green'>已连接</span>";ShowMsg("<span class='green'>连接成功！</span>");}websocket.onmessage = function (event) {ShowMsg(event.data);}websocket.onclose = function () {ShowMsg("<span class='red'>断开连接</span>");}}else {alert("NOT SUPPORT WEBSOCKET!");}}}//网页关闭时，断开链接window.onbeforeunload = function () {websocket.close();}//显示日志function ShowMsg(msg) {document.getElementById("msg").innerHTML += Now() + " " + msg + "<br/>";}//发送消息function SendMsg() {var txt = document.getElementById("txt").value;websocket.send(txt);ShowMsg("<span class='green'>发送消息：" + txt + "</span>");}//断开链接function closeWebSocket() {websocket.close();}function Now() {const date = new Date();const year = date.getFullYear();const month = (date.getMonth() + 1).toString().padStart(2, '0');const day = date.getDate().toString().padStart(2, '0');const hour = date.getHours().toString().padStart(2, '0');const minute = date.getMinutes().toString().padStart(2, '0');const second = date.getSeconds().toString().padStart(2, '0');const format = year + "-" + month + "-" + day + " " + hour + ":" + minute + ":" + second;return format;}//清空日志function ClearLog() {document.getElementById("msg").innerHTML = "";}</script></div>
</body></html>运行效果：
注意：
如果使用了Nginx转发请求的，需在Nginx配置WebSocket的转发规则。
相关文章：
SpringBoot 使用WebSocket功能
实现步骤： 1.导入WebSocket坐标。 在pom.xml中增加依赖项： <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-websocket</artifactId> </dependency>2.编写WebSocket配…...
HTML5的新特性
目录 一，新增语义化标签 二，新增的多媒体标签 三，新增input表单 四，新增的表单属性 一，新增语义化标签 二，新增的多媒体标签 1，音频：<audio>.。。用MP3 <audio src…...
Filter过滤器学习使用
验证token 对外API过滤器 public class APIFilter implements Filter {private static Logger logger LogManager.getLogger(APIFilter.class);private ICachedTokenService tokenService;public APIFilter(ICachedTokenService tokenService) {super();this.tokenService …...
关于修改数据库服务器时间导致达梦数据库集群裂开
故障原因： 因为每天数据库服务器时间都不一致，想要给数据库服务器配置个NTP服务器。结果导致达梦数据库裂库。后面查看了达梦系统管理员手册了解了达梦集群的机制，知道数据库服务器时间需要先关闭数据库服务之后才可以修改数据库服务器时间。…...
自定义包的设计与实现
这是一个 CPacket 类，用于解析包含固定格式的数据。该类的成员变量包括固定包头 sHead、包长度 nLength、控制命令 sCmd、包数据 strData 和和校验 sSum。 构造函数： CPacket()：默认构造函数，初始化成员变量。 CPacket(const B…...
时机成熟了
时机成熟了。 有一个老乡群，一到年底就各种人找车、车找人的消息。这些消息如果能直接爬取到一个小的网页里面去，则可以极大地便利大家做检索。如何把非结构化的内容转成结构化的 json，在以前是一个难题，但是有了 ChatGPT&#x…...
Linux 驱动开发基础知识——总线设备驱动模型（八）
个人名片： 🦁作者简介：学生 🐯个人主页：妄北y 🐧个人QQ：2061314755 🐻个人邮箱：2061314755qq.com 🦉个人WeChat：Vir2021GKBS 🐼本文由…...
SpringBoot+BCrypt算法加密
BCrypt是一种密码哈希函数，BCrypt算法使用“盐”来加密密码，这是一种随机生成的字符串，可以在密码加密过程中使用，以确保每次加密结果都不同。盐的使用增强了安全性，因为攻击者需要花费更多的时间来破解密码。 下图为…...
更新至2023年，2002-2023年3月中国国债发行数据
更新至2023年，2002-2023年3月中国国债发行数据 1、时间：2002-2023年3月 2、指标：序号、代码、发行日期、发行总额(亿元)、期限(年)、发行价格、票面利率(发行参考利率)(%)、票面利率说明、息票品种、附息利率类型、付息频率、起息日期、付息…...
2024最新版TypeScript安装使用指南
2024最新版TypeScript安装使用指南 Installation and Development Guide to the Latest TypeScript in 2024 By JacksonML 1. 什么是TypeScript? TypeScript is JavaScript with syntax for types. – typescriptlang.org TypeScript 是 JavaScript 的一个超集，…...
国外知名的农业机器人公司
从高科技温室到云播种，农业机器人如何帮助农民填补劳动力短缺以及超市货架的短缺。 概要 “高科技农业”并不矛盾。当代农业经营更像是硅谷，而不是美国哥特式，拥有控制灌溉的应用程序、驾驶拖拉机的 GPS 系统和监控牲畜的带有 RFID 芯片的耳…...
【EI会议征稿中|ACM出版】#先投稿，先送审#第三届网络安全、人工智能与数字经济国际学术会议（CSAIDE 2024）
#先投稿，先送审#ACM出版#第三届网络安全、人工智能与数字经济国际学术会议（CSAIDE 2024） 2024 3rd International Conference on Cyber Security, Artificial Intelligence and Digital Economy 2024年3月8日-10日 | 中国济南 会议官网&…...
【笔试常见易错选择题01】else、表达式、二维数组、%m.ns、%m.nf、常量指针和指针常量、宏定义、传参、数组越界、位段
1. 下列main()函数执行后的结果为（） int func(){ int i, j, k 0; for(i 0, j -1;j 0;i, j){ k; } return k; } int main(){cout << (func());return 0; }A. -1 B. 0 C. 1 D. 2 判断为赋值语句，j等于0 0为假不进循环 选B. 2. 下面程…...
Unity中常见的单词
前言 unity中常见的单词学习积累 一.常用的基础词。 new:新建; as:像。。一样; null:对象空值; void:函数返回空值; switch:开关; abstract:抽象的; event:事件； return:返回; class:类; …...
【仅需一步，1分钟极速开服】幻兽帕鲁保姆级教程
本教程分为两部分。一、开服教程。二、如何登录游戏（第一次接触游戏，如何玩） 一、开服教程。 1、通过 游戏服务器专属优惠页，选择以下应用模板并点击立即购买。 - 【服务器套餐配置推荐】* 1、入门配置（2～…...
Zoho Mail 2023：回顾过去，展望未来：不断进化的企业级邮箱解决方案
当我们告别又一个非凡的一年时，我们想回顾一下Zoho Mail如何融合传统与创新。我们迎来了成立15周年，这是一个由客户、合作伙伴和我们的敬业团队共同庆祝的里程碑。与我们一起回顾这段旅程，探索定义Zoho Mail历史篇章的敏捷性、精确性和创新性…...
python执行linux系统命令的三种方式
前言 这是我在这个网站整理的笔记,有错误的地方请指出，关注我，接下来还会持续更新。 作者：神的孩子都在歌唱 1. 使用os.system 无法获取命令执行后的返回信息 import osos.system(ls)2. 使用os.popen 能够获取命令执行后的返回信息 impor…...
协会认证！百望云荣获信创工委会年度“卓越贡献成员单位”称号
当前，新一轮科技革命和产业变革正加速重塑全球经济结构，强化企业科技创新的主体地位，推动创新链、产业链、人才链深度融合，加快科技成果产业化进程至关重要。 近日，中国电子工业标准化技术协会信息技术应用创新工作委员…...
神经网络激活函数到底是什么？
激活函数 其实不是很难啦，归结一下就是大概这样几个分类，详情请参考【神经网络】大白话直观理解！_哔哩哔哩_bilibili神经网络就是干这个事的~ 如果队伍不长，一个ykxb就可以了，如果 如果 队伍太长 就加一个激活函数也…...
【智慧工业】东胜物联定位与跟踪解决方案，为方案商提供蓝牙网关、信标等物联网智能硬件设备
利用东胜物联的蓝牙网关我们的合作伙伴在德国的建筑工地成功实施了基于物联网蓝牙的员工出勤和跟踪管理解决方案，该解决方案简化了员工时间表并增强了工作流程，为经理和主管提供了更多时间来专注于项目洞察，并提高了员工的效率、绩效和生产力…...
Qwen2-VL-2B-Instruct环境配置详解：Anaconda虚拟环境管理与依赖冲突解决
Qwen2-VL-2B-Instruct环境配置详解：Anaconda虚拟环境管理与依赖冲突解决 每次准备跑一个新的大模型，最头疼的往往不是模型本身，而是环境配置。特别是像Qwen2-VL-2B-Instruct这种多模态模型，它需要PyTorch、Transformers、CUDA&am…...
Crypto-JS实战指南：如何构建可靠的浏览器端加密验证体系
Crypto-JS实战指南：如何构建可靠的浏览器端加密验证体系 【免费下载链接】crypto-js JavaScript library of crypto standards. 项目地址: https://gitcode.com/gh_mirrors/cr/crypto-js 在Web应用开发中，加密功能的正确性直接关系到用户数据安全…...
SSCOM串口助手5个隐藏技巧：多窗口同步调试效率翻倍（附配置截图）
SSCOM串口助手5个隐藏技巧：多窗口同步调试效率翻倍（附配置截图） 在嵌入式开发和硬件调试领域，串口通信工具的效率直接影响着工程师的工作节奏。SSCOM作为一款广受欢迎的串口调试助手，其简洁界面背后隐藏着许多能显著提…...
比迪丽LoRA模型Mathtype式交互：设计公式化提示词编辑器提升创作精度
比迪丽LoRA模型Mathtype式交互：设计公式化提示词编辑器提升创作精度 不知道你有没有过这样的经历：面对一个功能强大的AI绘画模型，比如集成了各种LoRA的比迪丽，脑子里明明有非常具体的画面，但就是不知道该怎么用文字描…...
用Cursor+LocalStorage实现无后端项目管理：前端开发者的轻量级解决方案
用CursorLocalStorage实现无后端项目管理：前端开发者的轻量级解决方案 在当今快节奏的开发环境中，前端开发者常常需要快速搭建小型项目管理工具来跟踪个人或团队的工作进度。传统方案往往需要配置数据库、搭建后端API，这对于简单需求来说显得…...
FlowState Lab跨周期波动模式提取效果：从秒级到年度的规律发现
FlowState Lab跨周期波动模式提取效果：从秒级到年度的规律发现 1. 时间序列分析的革命性突破 时间序列分析领域最近迎来了一项重要突破。传统方法往往只能聚焦单一时间尺度，要么分析高频交易数据，要么研究季节性规律，很难同时捕…...
Windows平台APK安装架构革命：从模拟器到原生集成的技术演进
Windows平台APK安装架构革命：从模拟器到原生集成的技术演进 【免费下载链接】APK-Installer An Android Application Installer for Windows 项目地址: https://gitcode.com/GitHub_Trending/ap/APK-Installer 当移动生态与桌面系统相遇，技术融合…...
Linux 内核中的调试技术进阶：从 ftrace 到 BPF
Linux 内核中的调试技术进阶：从 ftrace 到 BPF 引言 作为一名深耕操作系统和嵌入式开发的工程师，我深知调试的重要性。在系统开发中，良好的调试能力可以快速定位和解决问题，提高系统的可靠性。在 Linux 内核中，调试技术…...
RCE漏洞小结
RCE漏洞简介 所谓RCE漏洞，即Remote Code/Command Execution，远程代码执行和远程命令执行漏洞。在很多Web应⽤中，开发⼈员会使⽤⼀些函数，这些函数以⼀些字符串作为输⼊，功能是将输⼊的字符串当作代码或者命令来进⾏执…...
Java实现Redis延迟队列：从原理到高可用架构
在现代分布式系统中，延迟队列是一种至关重要的组件。它允许我们将消息或任务放入队列，直到指定的延迟时间到达后才被消费。这种机制广泛应用于订单超时自动取消、支付后定时发送通知、任务重试等场景。 虽然RabbitMQ和RocketMQ等专业消息中间件都支持延迟…...