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

Java使用WebSocket(基础)

news 2026/3/30 4:32:34

准备一个html页面

<!DOCTYPE HTML>
<html>
<head><meta charset="UTF-8"><title>WebSocket Demo</title>
</head>
<body><input id="text" type="text" /><button onclick="send()">发送消息</button><button onclick="closeWebSocket()">关闭连接</button><div id="message"></div>
</body>
<script type="text/javascript">var websocket = null;var clientId = Math.random().toString(36).substr(2);//判断当前浏览器是否支持WebSocketif('WebSocket' in window){//连接WebSocket节点websocket = new WebSocket("ws://localhost:8080/ws/"+clientId);}else{alert('Not support websocket')}//连接发生错误的回调方法websocket.onerror = function(){setMessageInnerHTML("error");};//连接成功建立的回调方法websocket.onopen = function(){setMessageInnerHTML("连接成功");}//接收到消息的回调方法websocket.onmessage = function(event){setMessageInnerHTML(event.data);}//连接关闭的回调方法websocket.onclose = function(){setMessageInnerHTML("close");}//监听窗口关闭事件，当窗口关闭时，主动去关闭websocket连接，防止连接还没断开就关闭窗口，server端会抛异常。window.onbeforeunload = function(){websocket.close();}//将消息显示在网页上function setMessageInnerHTML(innerHTML){document.getElementById('message').innerHTML += innerHTML + '<br/>';}//发送消息function send(){var message = document.getElementById('text').value;websocket.send(message);}//关闭连接function closeWebSocket() {websocket.close();}
</script>
</html>

导入Maven坐标

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

配置WebSocket


import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.server.standard.ServerEndpointExporter;/*** WebSocket配置类，用于注册WebSocket的Bean*/
@Configuration
public class WebSocketConfiguration {@Beanpublic ServerEndpointExporter serverEndpointExporter() {return new ServerEndpointExporter();}}

使用webSocket服务

package com.sky.websocket;import org.springframework.stereotype.Component;
import javax.websocket.OnClose;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
import java.util.Collection;
import java.util.HashMap;
import java.util.Map;/*** WebSocket服务*/
@Component
@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();}}}}

添加一个定时器来测试

package com.sky.task;import com.sky.websocket.WebSocketServer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;@Component
public class WebSocketTask {@Autowiredprivate WebSocketServer webSocketServer;/*** 通过WebSocket每隔5秒向客户端发送消息*/@Scheduled(cron = "0/5 * * * * ?")public void sendMessageToClient() {webSocketServer.sendToAllClient("这是来自服务端的消息：" + DateTimeFormatter.ofPattern("HH:mm:ss").format(LocalDateTime.now()));}
}

Java使用WebSocket(基础)

准备一个html页面 <!DOCTYPE HTML> <html> <head><meta charset"UTF-8"><title>WebSocket Demo</title> </head> <body><input id"text" type"text" /><button onclick"send()&…...

编程日记 2023/10/9 4:06:37

图像处理与计算机视觉--第五章-图像分割-自适应阈值分割

文章目录 1.自适应阈值分割介绍2.自适应阈值函数参数解析3.高斯概率函数介绍4.自适应阈值分割核心代码5.自适应阈值分割效果展示6.参考文章及致谢 1.自适应阈值分割介绍在图片处理过程中，针对铺前进行二值化等操作的时候，我们希望能够将图片相应区域内所…...

编程日记 2023/10/9 4:03:35

记一次问题排查

1785年，卡文迪许在实验中发现，把不含水蒸气、二氧化碳的空气除去氧气和氮气后，仍有很少量的残余气体存在。这种现象在当时并没有引起化学家的重视。一百多年后，英国物理学家瑞利测定氮气的密度时，发现从空气里分离出来…...

编程日记 2023/10/9 4:02:34

【Spring Boot】创建一个 Spring Boot 项目

创建一个 Spring Boot 项目 1. 安装插件2. 创建 Spring Boot 项目3. 项目目录介绍和运行注意事项 1. 安装插件 IDEA 中安装 Spring Boot Helper / Spring Assistant / Spring Initializr and Assistant插件才能创建 Spring Boot 项⽬ （有时候不用安装，直…...

编程日记 2023/10/9 4:00:32

flutter中使用缓存

前言在flutter项目中使用ListView或者PageView等有滚动条组件的时候，切换页面的时候，再切换回来会丢失之前的滑动状态，这个时候就需要需要使用缓存功能缓存类 import package:flutter/material.dart;class KeepAliveWrapper extends Sta…...

编程日记 2023/10/9 3:59:30

京东数据分析平台：9月中上旬白酒消费市场数据分析

9月份，围绕白酒的热点不断。9月5日，瑞幸咖啡官微发布消息称，瑞幸与贵州茅台跨界合作推出的酱香拿铁刷新单品纪录，首日销量突破542万杯，销售额破1亿元。9月14日，贵州茅台官微发布消息称与德芙推出联名产品“…...

编程日记 2023/10/9 3:57:27

Linux安装 spark 教程详解

目录一准备安装包二安装 scala 三修改配置文件 1）修改 workers 文件 2）修改 spark-env.sh文件四进入 spark 交互式平台一准备安装包可以自行去 spark 官网下载想要的版本这里准备了 spark3.1.2的网盘资源链接: https://pan.baidu.com…...

编程日记 2023/10/9 3:56:26

动态内存管理函数（malloc，calloc，realloc，free）

动态内存函数 1.1malloc和free C语言提供了一个动态内存开辟的函数： void* malloc (size_t size); 这个函数向内存申请一块连续可用的空间，并返回指向这块空间的指针。如果开辟成功，则返回一个指向开辟好空间的指针。如果开辟失败&#…...

编程日记 2023/10/9 3:55:25

云表|都有生产管理模块,MES和ERP有什么不同,该如何选择

MES和ERP是生产制造领域的两大知名系统，虽然早已声名鹊起，但仍有不少人难以明确区分两者的差异。下面将详细阐述这两个系统的不同之处。首先，要了解MES和ERP的定义。 MES系统：全称制造执行系统（Manufacturing Executio…...

编程日记 2023/10/9 3:53:23

C语言 - 数组

目录 1. 一维数组的创建和初始化 1.1 数组的创建 1.2 数组的初始化 1.3 一维数组的使用 1.4 一维数组在内存中的存储 2. 二维数组的创建和初始化 2.1 二维数组的创建 2.2 二维数组的初始化 2.3 二维数组的使用 2.4 二维数组在内存中的存储 3. 数组越界 4. 数组作为函数参数 4.1…...

编程日记 2023/10/9 3:52:22

Vue 中的插槽（Slot），有什么用，不同插槽的区别？

Vue 中的插槽（Slot案例详解） 是一种非常有用的功能，用于组件之间的内容分发和复用。以下是关于插槽的一些重要概念： 插槽的作用: 插槽允许你将组件的内容分发到其子组件中，以实现灵活的组件复用和自定义布局。通过插槽…...

编程日记 2023/10/9 3:51:21

Linux登录自动执行脚本

一、所有用户每次登录时自动执行。 1、在/etc/profile文件末尾添加。将启动命令添加到/etc/profile文件末尾。 2、在/etc/profile.d/目录下添加sh脚本。在/etc/profile.d/目录下新建sh脚本，设置每次登录自动执行脚本。有用户登录时，/etc/profile会遍…...

编程日记 2023/10/9 3:50:20

架构方法、模型、范式、治理

从架构方法、模型、范式、治理等四个方面介绍架构的概念和方法论、典型业务场景下的架构范式、不同架构的治理特点这3个方面的内容...

编程日记 2023/10/9 3:49:19

Linux 安全 - 内核提权

文章目录前言一、简介1.1 prepare_creds1.2 commit_creds 二、demo参考资料前言在这篇文章：Linux 安全 - Credentials 介绍了 Task Credentials 相关的知识点，接下来给出一个内核编程提权的例程。一、简介内核模块提权主要借助于 prepare_creds …...

编程日记 2023/10/9 3:48:19

数字三角形加强版题解（组合计数+快速幂+逆元）

Description 一个无限行的数字三角形，第 i 行有 i 个数。第一行的第一个数是 1 ，其他的数满足如下关系：如果用 F[i][j] 表示第 i 行的第 j 个数，那么 F[i][j]A∗F[i−1][j]B∗F[i−1][j−1] （不合法的下标的数为 0 &a…...

编程日记 2023/10/9 3:47:18

MySQL：主从复制-基础复制（6）

环境主服务器 192.168.254.1 从服务器（1）192.168.254.2 从服务器（2）192.168.253.3 我在主服务器上执行的操作会同步至从服务器主服务器 yum -y install ntp 我们去配置ntp是需要让从服务器和我们主服务器时间同步 sed -i /…...

编程日记 2023/10/9 3:46:16

盒子模型的基础

盒子模型边框（border） border可以设置元素的边框，边框分成三部分，边框的（粗细）边框的样式，边框的颜色 <style>div {width: 100px;height: 100px;border-width: 200;border-style: 边框…...

编程日记 2023/10/9 3:42:12

Go复合类型之数组类型

Go复合类型之数组文章目录 Go复合类型之数组一、数组(Array)介绍1.1 基本介绍1.2 数组的特点二、数组的声明与初始化2.1 数组声明2.2 常见的数据类型声明方法2.3 数组的初始化方式一：使用初始值列表初始化数组方法二：根据初始值个数自动推断数组长度方…...

编程日记 2023/10/9 3:41:12

rust闭包

一、闭包是什么 （一）闭包是什么我们先来看看javascript中的闭包。在函数外部无法读取函数内的局部变量。但是我们有时候需要得到函数内的局部变量，那么如何从外部读取局部变量？那就是在函数的内部，再定义一个函数。…...

编程日记 2023/10/9 3:40:11

通过位运算，实现单字段标识多个状态位

可能经常有如下这种需求: 需要一张表,来记录学员课程的通过与否. 课程数量不确定,往往很多,且会有变动,随时可能新增一门课. 这种情况下,在设计表结构时,一门课对应一个字段,就有些不合适, 因为不知道课程的具体数量,也无法应对后期课程的增加. 考虑只用一个状态标志位,利用位运…...

编程日记 2023/10/9 3:39:10

【网络】Wireshark实战：TCP连接异常之RST报文深度解析

1. 认识TCP的RST报文：网络世界的紧急刹车第一次在Wireshark里看到RST标志位时，我正盯着满屏的TCP握手包发呆。那个鲜红的[RST, ACK]就像交通信号灯突然变红，让原本流畅的数据传输戛然而止。简单来说，RST（Reset&#x…...

编程新知 2026/3/30 3:04:42

Windows Cleaner终极指南：三步解决C盘爆红，让电脑重获新生

Windows Cleaner终极指南：三步解决C盘爆红，让电脑重获新生【免费下载链接】WindowsCleaner Windows Cleaner——专治C盘爆红及各种不服！ 项目地址: https://gitcode.com/gh_mirrors/wi/WindowsCleaner 当你的C盘进度条变成刺眼的红色…...

编程新知 2026/3/30 2:52:39

ollama-QwQ-32B提示工程：提升OpenClaw操作准确率的10个模板

ollama-QwQ-32B提示工程：提升OpenClaw操作准确率的10个模板 1. 为什么需要专门优化OpenClaw的提示词？ 第一次用OpenClaw执行文件整理任务时，我遭遇了灾难性结果——AI误将整个Downloads文件夹按修改日期排序后，把300多个文件全部…...

编程新知 2026/3/30 2:32:34

保姆级移植教程：将正点原子ATK-IMU901官方例程从STM32 HAL库迁移到MSPM0G3507

跨平台传感器驱动移植实战：从STM32 HAL到MSPM0的代码重构方法论当我们需要将成熟的传感器驱动迁移到新硬件平台时，往往面临底层接口差异带来的适配难题。本文将以正点原子ATK-IMU901十轴陀螺仪模块为例，详解如何将其官方STM32 HAL驱动移植到…...

编程新知 2026/3/30 1:56:23

保姆级教程：在Ubuntu 20.04上用Docker搞定GPUStack，让Atlas 300I Duo推理卡跑通LLM

保姆级教程：Ubuntu 20.04Docker部署GPUStack全流程指南（Atlas 300I Duo专版） 最近在折腾Atlas 300I Duo这块推理卡的朋友应该都深有体会——虽然硬件性能强悍，但要让它在Ubuntu系统上顺利跑起大语言模型，光驱动和依赖就…...

编程新知 2026/3/30 1:52:21

Vivado项目文件太多分不清？这份FPGA开发必备的“文件后缀速查手册”请收好

Vivado项目文件管理实战指南：从混乱到有序的FPGA开发进阶每次打开Vivado项目文件夹，看到满屏的.bat、.dcp、.xci文件是不是感觉像走进了一个迷宫？作为FPGA开发者，我们经常需要在这些看似杂乱的文件海洋中寻找特定的配置或输出结果…...

编程新知 2026/3/30 1:09:56

Fast-LIO2 + Lidar_IMU_Init：提升机器人定位精度的完整数据流与标定实战

Fast-LIO2与Lidar_IMU_Init融合实践：从标定到部署的机器人定位优化全流程在机器人自主导航领域，激光雷达与IMU的融合定位系统已成为工业级应用的主流选择。然而，许多开发者在实际部署时会发现：即使采用了Fast-LIO2这样先进的激光…...

编程新知 2026/3/30 0:51:46

基于SpringBoot+Vue的招生宣传管理系统管理系统设计与实现【Java+MySQL+MyBatis完整源码】

💡实话实说：用最专业的技术、最实惠的价格、最真诚的态度服务大家。无论最终合作与否，咱们都是朋友，能帮的地方我绝不含糊。买卖不成仁义在，这就是我的做人原则。摘要随着教育信息化的快速发展，高校招生宣…...

编程新知 2026/3/30 0:23:39

STM32用KEIL调试总进不了main？可能是printf重定向惹的祸（附完整解决方案）

STM32调试卡在SystemInit？深入解析printf重定向与半主机模式陷阱调试STM32时遇到程序卡在SystemInit函数而无法进入main函数的情况，往往会让开发者陷入长时间的排查困境。这种现象背后可能隐藏着多种原因，但其中最容易被忽视却又频繁出现的&…...

编程新知 2026/3/29 23:55:23

VLP-16数据包解析实战：从原始字节到三维点云

1. VLP-16数据包解析入门指南第一次拿到VLP-16激光雷达的原始UDP数据流时，我完全被那一串串十六进制数字搞懵了。这就像收到一封用密码写成的信，明明知道里面藏着宝贵的三维环境信息，却不知道如何破译。经过几个项目的实战积累，我…...

编程新知 2026/3/29 21:44:30

相关文章：