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

Springboot集成websocket实现消息推送

news 来源：原创 2025/7/22 13:16:23

假设有个需求需要多个用户同时在对应的消息面板实时查看相关接口的执行流程进度，此时可以可考虑使用websocket来实现结果进度推送

一、引入websocket依赖，并编写WebSocket配置类

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId>
</dependency>

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.server.standard.ServerEndpointExporter;/*** WebSocket配置类*/
@Configuration
public class WebSocketConfig {/*** 注入ServerEndpointExporter,该Bean会自动注册使用@ServerEndpoint注解申明的websocket endpoint*/@Beanpublic ServerEndpointExporter serverEndpointExporter() {return new ServerEndpointExporter();}
}

二、编写WebSocket服务类，用户和客户端进行交互

import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicInteger;/*** WebSocket服务*/
@ServerEndpoint("/ws/{uid}")
@Component
@Slf4j
public class WebSocketServer {/*** 当前在线连接数*/private static final AtomicInteger onlineNum = new AtomicInteger(0);/*** 存放每个客户端对应的Session*/private static final Map<String, Session> SESSION_POOLS = new ConcurrentHashMap<>();/*** 建立连接** @param session 当前会话* @param uid     用户id*/@OnOpenpublic void openConnection(Session session, @PathParam(value = "uid") String uid) {SESSION_POOLS.put(uid, session);onlineNum.incrementAndGet();log.info(uid + "建立连接! 当前连接数为: {}", onlineNum);}/*** 关闭连接** @param uid 用户id*/@OnClosepublic void closeConnection(@PathParam(value = "uid") String uid) {SESSION_POOLS.remove(uid);int cnt = onlineNum.decrementAndGet();log.info(uid + "断开连接, 当前连接数为：{}", cnt);}/*** 消息发送** @param session 当前会话* @param message 消息内容* @throws IOException IO异常*/public void sendMessage(Session session, String message) throws IOException {if (session != null && session.isOpen()) {synchronized (session) {session.getBasicRemote().sendText(message);}}}/*** 消息广播** @param message 消息内容*/public void broadCastMessage(String message) {SESSION_POOLS.forEach((k, v) -> {if (v.isOpen()) {try {sendMessage(v, message);} catch (IOException e) {throw new RuntimeException(e);}}});}/*** 发生错误** @param uid       用户id* @param throwable 错误信息*/@OnErrorpublic void errorConnection(@PathParam(value = "uid") String uid, Throwable throwable) {log.error("用户: " + uid + " 发生错误", throwable);}
}

三、编写controller模拟接口执行进度监控

import com.yx.analyze.demo.component.WebSocketServer;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.concurrent.TimeUnit;/*** WebSocket接口控制器*/
@RestController
@RequestMapping("/ws")
@Slf4j
public class WebSocketController {@Autowiredprivate WebSocketServer webSocketServer;/*** 管理员广播消息，模拟某个接口执行的进度消息推送** @param id      用户id* @param message 消息内容*/@PostMapping(value = "/broadCast")public void broadCast(String id, String message) {//模拟管理员身份判断if ("admin".equals(id)) {try {webSocketServer.broadCastMessage(id + ":" + "监控接口开始执行...");webSocketServer.broadCastMessage(id + ":" + "监控接口开始校验...");TimeUnit.SECONDS.sleep(1);webSocketServer.broadCastMessage(id + ":" + "监控接口开始取数: 获取到1024条记录");TimeUnit.SECONDS.sleep(1);webSocketServer.broadCastMessage(id + ":" + "监控接口开始处理数据...");TimeUnit.SECONDS.sleep(1);webSocketServer.broadCastMessage(id + ":" + message);webSocketServer.broadCastMessage(id + ":" + "数据处理完毕...");} catch (Exception e) {log.error("监控接口消息发生异常: ", e);}}}
}

四、使用在线websocket连接工具进行测试

Springboot集成websocket实现消息推送

假设有个需求需要多个用户同时在对应的消息面板实时查看相关接口的执行流程进度，此时可以可考虑使用websocket来实现结果进度推送一、引入websocket依赖，并编写WebSocket配置类 <dependency><groupId>org.springframework.boot</group…...

编程日记 2025/7/22 13:16:23

PostgreSQL 用户资源管理

PostgreSQL 用户资源管理 PostgreSQL 提供了多种机制来管理和限制用户对数据库资源的使用，以下是全面的资源管理方法： 1 连接限制 1.1 限制最大连接数 -- 在 postgresql.conf 中设置 max_connections 100 -- 全局最大连接数-- 为特定用户设置连接限…...

编程日记 2025/7/9 15:34:06

Uniapp：pages.json页面路由

目录一、pages二、style 一、pages uni-app 通过 pages 节点配置应用由哪些页面组成，pages 节点接收一个数组，数组每个项都是一个对象，其属性值如下： 属性类型默认值描述pathString配置页面路径styleObject配置页面窗口表现nee…...

编程日记 2025/7/22 13:12:21

使用open3d将pcd点云按照颜色等级分块显示并令其随颜色变化播放

👑主页：吾名招财 👓简介：工科学硕，研究方向机器视觉，爱好较广泛… 💫签名：面朝大海，春暖花开！使用open3d将pcd点云按照颜色等级分块显示并令其随颜色变化播放引言显示效果点云获取完整代码引言有很多时候我们需要更改pcd点云某些区域的颜色，可能是颜色随着点…...

编程日记 2025/7/19 13:13:14

玩转Docker | 使用Docker部署nullboard任务管理工具

玩转Docker | 使用Docker部署nullboard任务管理工具前言一、nullboard介绍简介主要特点二、系统要求环境要求环境检查Docker版本检查检查操作系统版本三、部署nullboard服务下载镜像创建容器创建容器检查容器状态检查服务端口安全设置四、访问nullboard服务访问nullboard首页五…...

编程日记 2025/7/4 19:24:45

如何避免流程形式化导致的效率低下？

要避免流程形式化导致的效率低下，核心在于：聚焦流程价值、保障执行灵活性、优化流程设计、建立反馈机制、提升执行感知。其中，聚焦流程价值是解决流程“空转”的首要原则。流程不应只是文档或制度的堆叠，而要服务于业务目标&…...

编程日记 2025/7/22 13:00:33

Java学习手册：HTTP 协议基础知识

一、HTTP 协议概述 HTTP（HyperText Transfer Protocol）即超文本传输协议，是用于从万维网（WWW：World Wide Web ）服务器传输超文本到本地浏览器的传输协议。它是一个应用层协议，基于请求-响应模型…...

编程日记 2025/7/22 13:04:50

基于多模态融合算法的航空武器毁伤评估技术方案

基于多模态融合算法的航空武器毁伤评估技术方案 1. 引言航空武器毁伤评估（Damage Assessment, DA）是现代战争中的关键环节，直接影响后续作战决策。传统的人工评估方式效率低、主观性强，且在高强度战场环境下难以实时完成。因此，本研究提出一种基于多模态融合算法的自动…...

编程日记 2025/7/19 9:58:01

欧拉-国产操作系统替代产品如何

欧拉（openEuler）国产操作系统是由华为发起并联合开源社区共同开发的企业级操作系统，旨在构建自主可控的数字基础设施生态底座。以下从开发背景、技术特点、应用场景、生态建设及市场表现等方面进行全面介绍：一、开发背景与战略定位国家需求驱动在中美技术竞争背景下，国…...

编程日记 2025/6/29 11:08:18

入门-C编程基础部分：16、预处理器

飞书文档https://x509p6c8to.feishu.cn/wiki/DzSJwsGiTiXkeCkyEYUcuXbKnbf C 预处理是编译过程中一个单独的步骤，是一个文本替换工具而已。所有的预处理命令都是以井号（#）开头。指令描述#define定义宏#ifdef如果宏已经定义，则返…...

编程日记 2025/7/22 11:39:49

Spark-SQL4

一 .Spark-SQL核心编程（六） Spark-SQL连接Hive Apache Hive 是 Hadoop 上的 SQL 引擎，Spark SQL 编译时可以包含 Hive 支持，也可以不包含。包含 Hive 支持的 Spark SQL 可以支持 Hive 表访问、UDF (用户自定义函数)、Hive 查询语…...

编程日记 2025/7/18 20:40:13

模数转换【1】AD7699

1.开发背景一款可以模数转换芯片，兼容通用 SPI 接口，支持最多支持 8 个通道和 500KSPS 的采样率。支持单个通道采集和扫描采集模式。同系列的芯片还有 AD7682 和 AD7689 等。 2.开发需求配置内部参考电压4.096V，实现单个通道采集和扫描采集…...

编程日记 2025/7/19 10:28:49

P5670 秘籍-反复异或 Solution

Description 给定序列 a ( a 1 , a 2 , ⋯ , a n ) a(a_1,a_2,\cdots,a_n) a(a1,a2,⋯,an) 和常数 m m m，有 q q q 个操作分两种： add ⁡ ( l , r , x ) \operatorname{add}(l,r,x) add(l,r,x)：对每个 i ∈ [ l , r ] i\in[l,r] …...

编程日记 2025/6/29 12:10:33

PID控制程序编写

目录一、C语言PID控制器示例代码二、代码解释三、重要注意事项一、C语言PID控制器示例代码 #include <stdio.h> #include <stdlib.h> #include <unistd.h> // For sleep function typedef struct { double Kp; // 比例增益 double…...

编程日记 2025/7/13 13:29:18

基于Python的施工图与竣工图对比小工具开发方案

基于Python的施工图与竣工图对比小工具开发方案一、引言在工程建设领域，施工图与竣工图的对比是项目验收的关键环节。传统人工对比方式效率低、易出错，本文基于Python开发一款自动化对比工具，支持快速检测图纸差异并生成可视化报告&#x…...

编程日记 2025/7/9 15:22:12

2025年世界职业院校技能大赛实施方案（意见稿）

为贯彻落实《教育强国建设规划纲要（2024—2035年）》，进一步提升世界职业院校技能大赛（以下简称“大赛”）内涵质量，发挥大赛引领作用，提升高技能人才培养质量，服务现代职业教育体系建…...

编程日记 2025/6/29 12:00:56

辛格迪客户案例 | 苏州富士莱医药GMP培训管理(TMS)项目

一、案例概述富士莱医药股份有限公司位于美丽的江南水乡常熟，前身为常熟富士莱医药化工有限公司，从建厂初期面积仅有10余亩，逐步扩展到100余亩。近年来公司飞速发展，以黑马姿态发展成为中国专业生产硫辛酸系列产品、肌肽系列产品…...

编程日记 2025/7/13 23:43:55

《网安面试指南》https://mp.weixin.qq.com/s/RIVYDmxI9g_TgGrpbdDKtA?token1860256701&langzh_CN 5000篇网安资料库https://mp.weixin.qq.com/s?__bizMzkwNjY1Mzc0Nw&mid2247486065&idx2&snb30ade8200e842743339d428f414475e&chksmc0e4732df793fa3bf39…...

编程日记 2025/6/29 9:41:05

【基于WSAAsyncSelec模型的通信程序设计】

文章目录一、实验背景与目的二、实验设计与实现思路1. 设计思想2. 核心代码实现总结一、实验背景与目的这次实验主要是为了让大家了解基于 WSAAsyncSelect 模型通信程序的编写、编译和执行过程。通过实践操作，深入掌握这种模型在实现计算机之间通信时的应用。 …...

编程日记 2025/6/29 11:56:47

Spring Boot+Mybatis设置sql日志打印

Spring BootMybatis设置sql日志打印在全局配置文件添加以下内容：logging.level.com.demo.mapperdebug，com.demo.mapper：src下的mapper路径，debug：设置日志打印级别为debug，亦可设置为：ERROR、…...

编程日记 2025/6/29 10:50:38

Java 性能优化：从硬件到软件的全方位思考

Java 性能优化：从硬件到软件的全方位思考在数字化飞速发展的当下，Java 作为广泛使用的编程语言，在各个应用领域发挥着关键作用。而 Java 性能优化作为提升系统运行效率、降低成本的核心环节，需要我们从硬件到软件进行全方位深入…...

编程日记 2025/6/29 11:00:08

ros2 humble moveit调试笔记

Overview — ROS2 Grasp Library Tutorials 0.5.0 documentation Robot Interface — ROS2 Grasp Library Tutorials 0.5.0 documentation 手动添加ompl_planning.yaml文件 planning_plugins:- ompl_interface/OMPLPlanner # To optionally use Ruckig for jerk-limited s…...

编程日记 2025/6/29 10:57:16

静态点亮数码管的某几段（STC89C52单片机）

#include <reg52.h> sbit ADDR0 P1^0; sbit ADDR1 P1^1; sbit ADDR2 P1^2; sbit ADDR3 P1^3; sbit ENLED P1^4; void main() { ENLED 0; //使能U3，选择数码管DS1 ADDR3 1; ADDR2 0; ADDR1 0; ADDR0 0; P0 0xF9; /…...

编程日记 2025/6/29 11:19:55

搭建哨兵架构

Redis大纲 3.1.sentinel环境准备： a.3个sentinel实例信息： 1.sentinel实例信息如下，sentinel只是起到监控作用，不存放数据！！2.为了节省资源，在同一台虚拟机开启3个实例，必须准备三…...

编程日记 2025/6/29 10:45:58

阿里云入门手册

阿里云入门手册一、付费方式二、云计算基础概念（一）云计算定义（二）云计算优势（三）云计算部署模式（四）专有网络 VPC 三、阿里云ECS实例（一）实例类型&#xff…...

编程日记 2025/6/29 10:50:47

AI日报 - 2024年04月22日

🌟 今日概览(60秒速览) ▎🤖 模型进展 | Google发布Gemini 2.5 Flash，强调低延迟与成本效益；Kling AI 2.0展示多轴运动视频生成；研究揭示SLM在知识图谱上优于LLM，RLHF在推理提升上存局限。 ▎💼…...

编程日记 2025/6/29 10:24:10

Windows BilibiliHistoryFetcher-v1.3.2-v1.2.1-开源B站历史记录管理工具[支持批量管理下载]

Windows BilibiliHistoryFetcher 链接：https://pan.xunlei.com/s/VOONAVJpANYPmzu1Zc3B0q1XA1?pwdnrjc# 使用说明： 以1.3.2与1.2.1版本为例需要下载 BiliBili-History-Frontend 前端程序，在下载 BilibiliHistoryAnalyzer 解压运行&#…...

编程日记 2025/7/20 20:46:44

CH585单片机的LCD外设怎么驱动段式LCD

1、首先这里只讲应用，不讲具体原理。要驱动段式LCD，这里就要知道占空比的调整，比如1/4为例就需要4个COM口。这4个COM口由单片机自行驱动，你不用管。就像硬件IIC和SPI，时序问题不用你去操心，你要做的就是向…...

编程日记 2025/6/29 11:52:18

包管理工具有哪些？主流软件分享

常见的包管理工具主要有：npm、Yarn、pnpm、Composer、Maven、pip、Conda 等，其中 npm 是目前全球使用最广泛的JavaScript包管理工具，以丰富的生态、便捷的使用体验以及强大的社区支持闻名。npm具备依赖管理、版本控制、脚本执行等强大功能&am…...

编程日记 2025/6/29 11:11:43

【网络安全】OWASP 十大漏洞

1. OWASP 十大漏洞为了应对未来的风险，安全专业人员需要随时掌握最新信息。之前，您了解了CVE 列表，这是一个公开的已知漏洞和暴露列表。CVE 列表是全球安全社区相互共享信息的重要信息来源。在本文中，您将了解安全专业人士参考…...

编程日记 2025/6/29 9:41:12

Fortran中FORALL的用法与性能分析

Fortran中FORALL的用法与性能分析 FORALL语句的基本用法 FORALL是Fortran 95引入的一种结构，用于表达并行数组操作。它的基本语法如下： FORALL (index start:end:stride, mask)array(index) expression END FORALL或者更复杂的多维度形式&#xff1…...

编程日记 2025/7/17 16:30:49

web组件和http协议

1.web组件 2.自定义元素 3.影子DOM 4.HTML模板 5.http协议 6.tcp ip协议...

编程日记 2025/7/4 8:55:56

论文笔记-arXiv2025-FilterLLM

论文笔记-arXiv2025-FilterLLM: Text-To-Distribution LLM for Billion-Scale Cold-Start Recommendation FilterLLM：面向十亿级冷启动推荐的文本到分布大语言模型摘要1.引言2.前言2.1符号说明2.2文本到判断2.2.1候选生成（从数十亿到数百）2.2…...

编程日记 2025/7/5 23:38:24

Anaconda Prompt 切换工作路径的方法

直接切换是不生效的： (base) C:\Users\96975>cd D:\weiban-tool-master\weiban-tool-master需要先回到根目录C盘，然后切换到目标文件夹盘符，进一步切换到目标文件夹 (base) C:\Users\96975>cd ..(base) C:\Users>cd ..(base) C:\&g…...

编程日记 2025/6/29 12:10:24

Synopsys：printvar命令和puts/echo命令的区别

相关阅读 Synopsyshttps://blog.csdn.net/weixin_45791458/category_12812219.html?spm1001.2014.3001.5482 Synopsys的EDA工具中存在一类变量，它们能控制工具的行为，被称为应用变量(application variable)，与之对应的是用户自定义变量(use…...

编程日记 2025/6/29 10:36:06

自注意力机制、多头自注意力机制、填充掩码 Python实现

原理讲解【Transformer系列（2）】注意力机制、自注意力机制、多头注意力机制、通道注意力机制、空间注意力机制超详细讲解自注意力机制 import torch import torch.nn as nn# 自注意力机制 class SelfAttention(nn.Module):def __init__(self, input…...

编程日记 2025/7/5 23:29:16

Cursor可视化大屏搭建__0420

主题：用Cursor怎么进行数据洞察，做AI预测化内容。 Python基础语法与AI python生态强大，代码简洁，相对其他语言Python更好上手，浙江高考将Python列为可选科目科学计算：Sklearn，Numpy，Pandas 人工智能：Tensorflow，Pytorch 网络爬虫：Scrapy…...

编程日记 2025/7/4 11:14:59

postman乘法计算，变量赋值

postman脚本怎么计算乘法在Postman中，你可以通过多种方式计算乘法，这取决于你的具体需求。例如，如果你想在发送请求前计算乘法结果，或者在测试标签中计算响应数据的乘法，下面是一些常见的方法。 1. 使用JavaScript代…...

编程日记 2025/6/29 11:17:33

计算机视觉——利用AI幻觉检测图像是否是生成式算生成的图像

概述俄罗斯的新研究提出了一种非常规方法，用于检测不真实的AI生成图像——不是通过提高大型视觉-语言模型（LVLMs）的准确性，而是故意利用它们的幻觉倾向。这种新方法使用LVLMs提取图像的多个“原子事实”，然后应用自…...

编程日记 2025/6/29 10:15:53

前端配置代理解决发送cookie问题

场景： 在开发任务管理系统时，我遇到了一个典型的身份认证问题：用户登录成功后，调获取当前用户信息接口却提示"用户未登录"。系统核心流程如下： 用户登录：调用 /login 接口&…...

编程日记 2025/6/29 12:28:18

word显示段落标记符（¶）而不是回车符

现象公司的一位同事找到我说word显示异常，出现了段落标记符（）。反馈的截图如下： 正常的截图如下： 原因语言设置错误解决文件选项更改语言关闭word并重启恢复正常...

编程日记 2025/7/9 8:25:09

使用 Vue Router 和 Vite 构建的自动路由生成系统

这段代码是一个使用 Vue Router 和 Vite 构建的自动路由生成系统。它的主要作用是自动扫描 views 目录下的所有 Vue 组件文件，并为它们创建相应的路由配置，无需手动为每个页面定义路由。主要功能和工作流程项目说明结构 . ├── App.vue ├── assets │ └── v…...

编程日记 2025/7/14 17:33:49

乐家桌面安卓版2025下载-乐家桌面软件纯净版安装分享码大全

是否在为智能电视或机顶盒上的应用资源不够丰富而烦恼？在使用安卓版乐家桌面或者纯净版乐家桌面的过程中还需要通过搜索框多页面查询，小编今天为大家来介绍一款好用的电视桌面——乐看家桌面，将为你打开一个全新的软件世界！ 乐看家…...

编程日记 2025/6/29 11:24:20

【sylar-webserver】重构日志系统

文章目录主要工作流程图FiberConditionBufferBufferManagerLogEvent 序列化 & 反序列化LoggerRotatingFileLogAppender 主要工作实现， LogEvent 序列化和反序列化 （使用序列化是为了更标准，如果转成最终的日志格式再存储（确…...

编程日记 2025/6/29 11:18:51

图形编辑器基于Paper.js教程27：对图像描摹的功能实现，以及参数调整

本篇文章来讲一下图像描摹的功能的实现。我们知道要雕刻图片可以通过分析图片的像素来生成相应的gcode进行雕刻，但如果你想要将图片转换为线稿进行雕刻，这个时候就要从图片中提取出线稿。例如下面的图片： 你想要获取到这个图片的线稿&…...

编程日记 2025/6/29 10:45:19

使用Mybaitis-plus提供的各种的免写SQL的Wrapper的使用方式

文章目录内连接JoinWrappers.lambda和 new MPJLambdaWrapper 生成的MPJLambdaWrapper对象有啥区别？LambdaQueryWrapper 和 QueryWrapper的区别？LambdaQueryWrapper和MPJLambdaQueryWrapper的区别？在作单表更新时建议使用：LambdaU…...

编程日记 2025/6/29 12:19:01

SQL_连续登陆问题

文章目录方案1：使用ROW_NUMBER函数1、针对对数据user_id分组，根据用户的活动日期排序2、用登录日期与rn求date_sub，得到的差值日期如果是相等的，则说明这两天肯定是连续的3、根据user_id和日期差sub_date分组，登录次数…...

编程日记 2025/6/29 12:12:26

【解决】Vue + Vite + TS 配置路径别名成功仍爆红

目录前言一.vite.config.ts 二.tsconfig.json 三. 别名配置成功，但语法提示爆红问题四、可能遇到的问题前言 ‌在项目中设置路径别名后仍然出现爆红问题，通常是由于配置不完整或配置错误导致的。Vite 中配置 alias 总共需要配置两个地方: vite…...

编程日记 2025/6/29 11:00:56

Discuz!与DeepSeek结合：打造智能论坛，提升用户体验与运营效率

引言随着互联网技术的飞速发展，社区论坛作为用户交流、分享信息的重要平台，其用户体验和运营效率成为了影响平台竞争力的关键因素。Discuz!作为国内领先的社区论坛软件系统，以其强大的功能和广泛的用户基础，在社区论坛领域占据着…...

编程日记 2025/6/29 10:02:59

相关文章：