springboot使用SSE
1、pom文件
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency>2、前端代码
<!DOCTYPE html>
<html lang="en">
<head><meta charset="UTF-8"><title> Springboot集成SSE </title>
</head>
<script>let source = null;const clientId = new Date().getTime();if (!!window.EventSource) {source = new EventSource('http://127.0.0.1:8080/sse/subscribe?id=' + clientId);//建立连接source.onopen = function (event) {setMessageInnerHTML("建立连接" + event);}//接收数据source.onmessage = function (event) {setMessageInnerHTML(event.data);}//错误监听source.onerror = function (event) {if (event.readyState === EventSource.CLOSED) {setMessageInnerHTML("连接关闭");} else {console.log(event);}}} else {setMessageInnerHTML("浏览器不支持SSE");}window.onbeforeunload = function () {close();};// 关闭function close() {source.close();const httpRequest = new XMLHttpRequest();httpRequest.open('GET', '/sse/over/?clientId=' + clientId, true);httpRequest.send();console.log("close");}// 显示消息function setMessageInnerHTML(innerHTML) {document.getElementById('text').innerHTML += innerHTML + '<br/>';}
</script>
<body>
<button onclick="close()">关闭连接</button>
<div id="text"></div>
</body>
</html>
3、后端代码
1、订阅
private static Map<String, SseEmitter> cache = new ConcurrentHashMap<>();@GetMapping(path = "subscribe", produces = {MediaType.TEXT_EVENT_STREAM_VALUE})public SseEmitter subscribe(@RequestParam(name = "id", required = false) String id) throws IOException {// 超时时间设置SseEmitter sseEmitter = new SseEmitter(0L);cache.put(id, sseEmitter);//结束连接sseEmitter.onCompletion(() -> {log.info("结束连接：{}", id);cache.remove(id);});//连接异常sseEmitter.onError(throwable -> {log.info("连接异常：{}", id);cache.remove(id);});//连接超时sseEmitter.onTimeout(() -> {log.info("连接超时：{}", id);cache.remove(id);});return sseEmitter;}2、推送
@GetMapping(path = "push/{userId}")public String push(@PathVariable String userId,@RequestBody Map<String,Object> param) throws IOException {try {SseEmitter sseEmitter = cache.get(userId);if (sseEmitter != null) {sseEmitter.send(SseEmitter.event().name("msg").data("后端发送消息：" + param));}} catch (IOException e) {log.error("用户[{}]推送异常:{}", userId, e.getMessage());cache.remove(userId);}return "over";}3、关闭
@GetMapping(path = "over")public String over(@RequestParam(name = "id", required = false) String id) {SseEmitter sseEmitter = cache.get(id);if (sseEmitter != null) {sseEmitter.complete();cache.remove(id);}return "over";}相关文章：
springboot使用SSE
1、pom文件 <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency> 2、前端代码 <!DOCTYPE html> <html lang"en"> <head><meta ch…...
搞定ESD（一）：静电放电测试标准解析
文章目录 一、基本术语与定义1.1 基本定义1.2 重要基本术语 二、静电放电发生器介绍2.1 静电放电发生器的特性：通用规范【GB/T17626.2-2018 标准】2.2 ESD 放电发生器电极规格要求：通用规范【GB/T17626.2-2018 标准】2.3 放电回路电缆的要求：…...
问界M7的诸多优点（自动驾驶走进我们的生活二）
博主一直在问界工厂工作，从未对自己工厂的车如此关注过；但问界系列上市后，经常在茶余饭后看B站视频，发现问界车越来越多不可比拟的优点如下： 一、绿牌 绿牌特权在重庆可以随时过桥，不受限号限制。 二、增…...
[运维|数据库] msql中的 FIND_IN_SET如何转化为pg数据中的ARRAY_POSITION的函数
在 MySQL 中，FIND_IN_SET 函数用于查找一个值是否存在于逗号分隔的字符串列表中。在 PostgreSQL 中，可以使用 string_to_array 函数将逗号分隔的字符串转换为数组，然后使用 ARRAY_POSITION 函数来查找值是否在数组中。 以下是如何将MySQL中的…...
LeetCode 面试题 05.03. 翻转数位
文章目录 一、题目二、Java 题解 一、题目 给定一个32位整数 num，你可以将一个数位从0变为1。请编写一个程序，找出你能够获得的最长的一串1的长度。 示例 1： 输入: num 1775(110111011112) 输出: 8 示例 2： 输入: num 7(01112)…...
Fiddler抓包工具配置+Jmeter基本使用
一、Fiddler抓包工具的配置和使用 在编写网关自动化脚本之前，得先学会如何抓包，这里以Fiddler为例。会抓包的同学可以跳过这一步，当然看看也是没坏处的…… 局域网络配置 将要进行抓包的手机与电脑连入同一局域网，电脑才能够抓到…...
IOTE 2023国际物联网展直击：芯与物发布全新定位芯片，助力多领域智能化发展
IOTE 2023国际物联网展，作为全球物联网领域的盛会，于9月20日在中国深圳拉开帷幕。北斗星通集团应邀参展，旗下专业从事物联网、消费类GNSS芯片研发设计的芯与物公司也随其亮相本届盛会。 展会上，芯与物展示了一系列创新的GNSS定位…...
【软件设计师-从小白到大牛】上午题基础篇：第二章 操作系统
文章目录 前言章节提要一、进程管理1、进程的状态2、前趋图3、进程的同步与互斥4、PV操作6、PV操作与前趋图7、死锁问题进程资源图（补充）真题链接 二、存储管理1、分区存储组织2、页式存储组织3、段式存储组织4、段页式存储组织5、快表6、页面置换算法单…...
【20230921】关于sing-box命令行程序开机自启动运行（Windows、Linux）
1 背景 sing-box是一个命令行程序，官网给出的教程是复制链接到Git Bash（windows）或终端运行（Linux）。每次开机都进行复制运行是一件繁琐的事情。 复制的内容其实就是下次并运行shell脚本，其实系统只需要运…...
LeetCode 75-02：字符串的最大公因子
前置知识：使用欧几里得算法求出最大公约数 func gcdOfStrings(str1 string, str2 string) string {if str1str2 ! str2str1 {return ""}return str1[:gcd(len(str1), len(str2))] }func gcd(a, b int)int{if b 0{return a}return gcd(b, a%b) }...
k8s1.19使用ceph14
一、静态 pv （rbd）方式 1、所有k8s节点安装依赖组件 注意：安装ceph-common软件包推荐使用软件包源与Ceph集群源相同，软件版本一致。 cat > /etc/yum.repos.d/ceph.repo << EOF [ceph] name=ceph baseurl=http://mirrors.aliyun.com/ceph/rpm-nautilus/el7/x86_…...
Leetcode 50. Pow(x, n)
文章目录 题目代码（9.19 首刷看解析） 题目 Leetcode 50. Pow(x, n) 代码（9.19 首刷看解析） 快速幂 class Solution { public:double myPow(double x, int n) {if(n 0)return 1;if(n 1)return x;if(n INT_MIN) { // 避免-n整…...
hive分区表的元数据信息numRows显示为0
创建分区表 CREATE TABLE `dept_partition`(`deptno` int, `dname` string, `loc` string) PARTITIONED BY (...
Baumer工业相机堡盟工业相机如何通过BGAPI SDK设置相机的图像剪切（ROI）功能（C++）
Baumer工业相机堡盟工业相机如何通过BGAPI SDK设置相机的图像剪切（ROI）功能（C） Baumer工业相机Baumer工业相机的图像剪切（ROI）功能的技术背景CameraExplorer如何使用图像剪切（ROI）功…...
【云原生】聊聊为什么需要docker以及其基础架构
为什么需要docker 在没有docker之前，我们开发、测试、生产其实是根据不同的服务器进行配置的，很可能因为软件配置不同而导致的生产事故，那么如果能较好的解决软件和配置等封装成一个可运行的软件，无需关注配置，那么是…...
“高级前端开发技术探索路由的使用及Node安装使用“
目录 引言1. Vue路由的使用2. VueNode.js的安装使用总结 引言 在当今互联网时代，前端开发技术日新月异，不断涌现出各种新的框架和工具。作为一名前端开发者，我们需要不断学习和探索新的技术，以提升自己的开发能力。本文将深入探讨…...
LeetCode 494.目标和 （动态规划 + 性能优化）二维数组 压缩成 一维数组
494. 目标和 - 力扣（LeetCode） 给你一个非负整数数组 nums 和一个整数 target 。 向数组中的每个整数前添加 或 - ，然后串联起所有整数，可以构造一个 表达式 ： 例如，nums [2, 1] ，可以在 2…...
[36c3 2019]includer
[36c3 2019]includer 题目描述：Just sitting here and waiting for PHP 8.0 (lolphp). 首先来了解一下临时文件包含之PHP - compress.zlib:// 在 php-src 里可以找到和 compress.zlib:// 有关的代码 | code 注意到 STREAM_WILL_CAST，涉及到 cast 经常…...
Python150题day10
④continue练习 从列表 Ist [1,3,5,2,7,9,10] 中输出所有的奇数，代码如下 lst [1, 3, 5, 2, 7, 9, 10] for item in lst: if item % 2 0: continue print(item) 在上述代码中，当遇到偶数时，continue 语句会跳过当前迭代&…...
Autosar工具-Davinci Developer
文章目录 前言一、Davinci Developer简介二、导航栏File(主要是用于保存、打开工程等操作)HomeProject(主要用于导入、导出arxml文件)Graphic(主要在SWC设计时使用，包含对图形界面下的设计工具)Window(主要就是对我们的Dev界面外形修改用的，使得界面更加方便我们使用（比如隐…...
js中的数据结构：栈，队列，链表，字典哈希表，树
栈：先进后出 队列：先进先出 链表： 单链表： 双链表： 环形链表：最后一个数据的next指针不是指向null，指向的是任意之间的一个数据，形成一个环 数组和链表的区别： 字典和哈…...
Verdi实现信号的平移
在Verilog/System verilog中，# xxx可以实现延迟指定时间的功能，而在使用verdi查看信号波形并进行分析时，同样也可以实现类似的功能。 (注：这种信号平移是有其应用场景的，例如，在某些仿真模型中，…...
Leetcode算法入门与数组丨6. 数组双指针、滑动窗口
文章目录 1 双指针基础知识1.1 双指针简介1.2 左右指针（对撞指针）1.3 快慢指针1.4 分离双指针 2 滑动窗口基础知识2.1 滑动窗口算法介绍2.2 滑动窗口适用范围2.3 固定长度滑动窗口2.4 不固定长度滑动窗口 1 双指针基础知识 1.1 双指针简介 双指针&…...
推荐一本书《横向领导力》
大家好，这里是大话硬件。 今天想给大家推荐一本我近期正在阅读的书籍《横向领导力》。 这本书很早就买了，但是在去年就看了前面3章的内容，而且也没做笔记，仅仅是在书本上写写画画，也没有什么体会，感觉看不懂…...
React实战过程的知识了解
做项目用到react和antd，没办法循序渐进的学习，只能把一些点记录在这里，希望大家指正。 1.杂七杂八 正文 //actionRef，操作表单的预设方法，包括：刷新、重置所有项并刷新、重置到默认项、加载更多、清空选…...
F对象和Q对象
F对象和Q对象 F对象 一个F对象代表数据库中某条记录的字段的信息 作用: 通常是对数据库中的字段值在不获取的情况下进行操作 用于类属性(字段)之间的比较 语法 from django.db.models import F F(列名)解决一种极端事件的产生，比如用户对一条微博的点赞…...
Visio——绘制倾斜线段
一、形状 -> 图表和数学图形 -> 多行 二、放置多行线，可以发现存在两个折点 三、选择多行线，右键选择删除点，即可得到倾斜线段...
Linux复习-安装与熟悉环境（一）
这里写目录标题 虚拟机ubuntu系统配置镜像Linux命令vi编辑器3个模式光标命令vi模式切换命令vi拷贝与粘贴命令vi保存和退出命令vi的查找命令vi替换命令 末行模式复制、粘贴、剪切gcc编译器 虚拟机 VMware16 官网下载：vmware官网 网盘下载： 链接ÿ…...
Go基础语法：map
9 map Go 语言中提供的映射关系容器为 map ，其内部使用 散列表（hash） 实现。它是一种无序的基于 key-value 的数据结构。 Go 语言中的 map 是引用类型，必须初始化之后才能使用。 9.1 map 定义 Go 语言中 map 的定义语法为&…...
开发板TFTP调试
问题描述 开发板和host(此处指虚拟机linux)可以平通，但是通过uboot tftp下载请求时一直显示T T T, 即超时 使用wireshark抓包也显示超时 措施 关闭windows和linux的防火墙 重新进行下载成功...
百度统计wordpress/软文代发价格
有时你打开vs的解决方案却无法正确的加载项目，根据提示，看看你的vs中是否有提示.csproj.user -----The project file could not be loaded. Root element is missing.并且你的.csproj.user的文件大小为0，这时你应该删除它，关掉vs…...
黄石做企业网站/成人就业技术培训机构
本文转载自News BTC对CROSS的特别报道。以下为翻译的原文： 拍卖是财产权利转让的最古老方式之一。自从人类有了剩余价值的流动性需求，就有了拍卖这种方式。说到捡漏收藏界尽知的当属“明成化斗彩鸡缸杯”了。它的传承过程，似乎就是一部“拣大…...
管理员界面wordpress/广东深圳今天最新通知
NEW关注Tech逆向思维视频号最新视频→【社恐为何成为年轻人的流行病？】3月14日消息，据外媒报道，美国当地时间周日，特斯拉一款新型Model Y出现在美国环保署（EPA）网站上，表明其可能已经通过该机构…...
社会组织网站建设/百度指数怎么算
一.问题众所周知，ARP是一个链路层的地址解析协议，它以IP地址为键值，查询保有该IP地址主机的MAC地址。协议的详情就不详述了，你可以看RFC，也可以看教科书。这里写这么一篇文章，主要是为了做一点记录…...
php做电影网站/小说排行榜百度
1、先上个图看下网页版数据、mysql结构化数据2、分析思路：该网页主要采用动态加载来实现的，通过刷新页面查看URL，最终发现想要的数据，在js链接当中，进行头文件分析，构造URL，完成数据获取数据存储…...
深圳代做网站/qq群引流推广平台
Web基本笔记~04.css入门 上一期 CSS 的引入方式 内联样式（行内样式） <p style"background: orange; font-size: 30px;">MyFirstCSS<p>内部样式 <html><head><meta charset"utf-8" /><title&g…...