Springboot2.7集成websocket及相关问题

2023-09-15 16:44:53

1、集成websocket完整代码

导入maven依赖

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

服务端代码

（1）注入bean
@Configuration
@EnableWebSocket
public class WebSocketConfig {
    @Bean
    public ServerEndpointExporter serverEndpointExporter() {
        return new ServerEndpointExporter();
    }
}
（2）服务端开放的服务及其业务逻辑
@Slf4j
@Component
@ServerEndpoint("/testcase/page/{clientId}")
//@Lazy
public class WsMessageService {

    //与某个客户端的连接会话
    private Session session;

    //存放每个客户端对应的WebSocket对象。
    private static Map<String, WsMessageService> webSocketsBeanMap = new ConcurrentHashMap<>();

    //每次连接都是一个新的会话对象，线程安全的
    String userId;

    //注入业务类。要注意setTestcaseService()的名称不能错，set后的字符串要和要注入的变量名一致。
    private static TestcaseService testcaseService;
    @Autowired
    public void setTestcaseService(TestcaseService testcaseService) {
        WsMessageService.testcaseService= testcaseService;
    }

    //private TestcaseService testcaseService = SpringContextUtil.getBean(TestcaseService.class);

    @OnOpen
    public void onOpen(Session session, @PathParam(value = "clientId") String userId) {
        this.session = session;
        this.userId = userId;
        webSocketsBeanMap.put(userId, this);
        log.info("OnOpen连接成功，userId：{}，当前在线人数：{}", userId, this.getOnLineCount());
    }

    @OnMessage
    public void onMessage(String message) throws IOException {
        Session session = webSocketsBeanMap.get(this.userId).session;
        if (session==null || !session.isOpen()) {
            return;
        }
        log.info("收到客户端的消息:" + message);
        //start业务
        Integer pageNum = null;
        Integer pageSize = null;
        String pid = null;
        String vid = null;
        if (session.getRequestParameterMap().get("pageNum")!= null) {
            pageNum = Integer.valueOf(session.getRequestParameterMap().get("pageNum").get(0));
        }
        if (session.getRequestParameterMap().get("pageNum")!= null) {
            pageSize = Integer.valueOf(session.getRequestParameterMap().get("pageSize").get(0));
        }
        if (session.getRequestParameterMap().get("pid")!= null) {
            pid = session.getRequestParameterMap().get("pid").get(0);
        }
        if (session.getRequestParameterMap().get("vid")!= null) {
            vid = session.getRequestParameterMap().get("vid").get(0);
        }
        PageInfo<TestcasePageVO> pageInfo = testcaseService.findTestcaseByMultiCondition(pageNum, pageSize, pid, vid);
        //end业务
        try {
            JSONObject object = new JSONObject();
            object.put("data", pageInfo);
            object.put("code", 200);
            object.put("message", "SUCCESS");
            this.session.getBasicRemote().sendText(String.valueOf(object.toString()));
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }

    @OnClose
    public void onClose() throws IOException {
        log.info("会话关闭，关闭会话的用户Id为：{}", this.userId);
        webSocketsBeanMap.remove(this.userId);
        log.info("当前在线人数：{}", this.getOnLineCount());
    }

    @OnError
    public void onError(Session session, Throwable error) {
        log.error("连接错误：" + error.getMessage());
        error.printStackTrace();
    }

    private int getOnLineCount() {
        return webSocketsBeanMap.size();
    }
}

测试服务端的可用性。在浏览器的控制台输入以下代码可以测试。

function initWebSocket(wsUri) {
            var websocket = new WebSocket(wsUri);
            websocket.onopen = function(evt) {
                console.log('连接建立中... '+wsUri);
            };
            websocket.onclose = function(evt) {
                console.log('连接关闭中...', evt);
            };
            websocket.onmessage = function(evt) {
                console.log('收到来自服务端的消息：', evt.data);
            };
            websocket.onerror = function(evt) {
                console.log('发生错误...', evt);
            };
            return websocket;
        }
    var websocket = initWebSocket("ws://ip:port/testcase/page/123?pid=5922cc3d03f74012a7112c931c8497d7&vid=fc2d7a6049ff4c7bafc40bf659b4e903");
        var msg, i = 0;
        var loop = setInterval(function(){
            msg = "Hello " +(i++);
            if(websocket.readyState == WebSocket.OPEN) {
                websocket.send(msg);
                console.log('已发送消息：' +msg);
            } else{
                clearInterval(loop);
                console.log('连接已关闭');
            }
        }, 10000);

2、集成websocket另一种方法（用控制台测试时返回的数据会乱码）

代码找不到了。但那种方法有一个特征就是使用的注解比当前的方法少。

3、解决业务类注入不进去的问题（两种方法，推荐第一种）

（1）第一种：就是当前使用的注入方法。注意命名，否则不会注入成功

//注入业务类。要注意setTestcaseService()的名称不能错，set后的字符串要和要注入的变量名一致。
    private static TestcaseService testcaseService;
    @Autowired
    public void setTestcaseService(TestcaseService testcaseService) {
        WsMessageService.testcaseService= testcaseService;
    }

（2）第二种：自己写一个SpringContextUtil工具类，协助注入

package cn.xxxxx.tmMaster.utils;

import lombok.extern.slf4j.Slf4j;
import org.mybatis.logging.LoggerFactory;
import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.stereotype.Component;

import java.util.logging.Logger;

@Slf4j
@Component
public class SpringContextUtil implements ApplicationContextAware {

    private static ApplicationContext applicationContext;

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        SpringContextUtil.applicationContext = applicationContext;
    }

    /**
     * 获取 applicationContext
     */
    public static ApplicationContext getApplicationContext() {
        return applicationContext;
    }

    /**
     * 通过 name 获取 bean 对象
     */
    public static Object getBean(String name) {

        return getApplicationContext().getBean(name);
    }

    /**
     * 通过 class 获取 bean 对象
     */
    public static <T> T getBean(Class<T> clazz) {
        return getApplicationContext().getBean(clazz);
    }

    /**
     * 通过 name，clazz  获取指定的 bean 对象
     */
    public static <T> T getBean(String name, Class<T> clazz) {
        return getApplicationContext().getBean(name, clazz);
    }
}

在WsMessageService中使用如下代码注入进去，但在类上必须要@Lazy进行懒加载，否则会报错

@Lazy
public class WsMessageService {
……
    private TestcaseService testcaseService = SpringContextUtil.getBean(TestcaseService.class);
……
}

不加@Lazy报错如下：org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'wsMessageService' defined in file [D:\javaworkspace\test-xxxx\tm-master\target\classes\cn\xxxxx\tmMaster\service\testcase\WsMessageService.class]: Instantiation of bean failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [cn.xxxxx.tmMaster.service.testcase.WsMessageService]: Constructor threw exception; nested exception is java.lang.NullPointerException

org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'wsMessageService' defined in file [D:\javaworkspace\test-xxxx\tm-master\target\classes\cn\xxxxx\tmMaster\service\testcase\WsMessageService.class]: Instantiation of bean failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [cn.xxxxx.tmMaster.service.testcase.WsMessageService]: Constructor threw exception; nested exception is java.lang.NullPointerException
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateBean(AbstractAutowireCapableBeanFactory.java:1334) ~[spring-beans-5.3.29.jar:5.3.29]
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1232) ~[spring-beans-5.3.29.jar:5.3.29]
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:582) ~[spring-beans-5.3.29.jar:5.3.29]
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:542) ~[spring-beans-5.3.29.jar:5.3.29]
    at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:335) ~[spring-beans-5.3.29.jar:5.3.29]
    at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:234) ~[spring-beans-5.3.29.jar:5.3.29]
    at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:333) ~[spring-beans-5.3.29.jar:5.3.29]
    at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:208) ~[spring-beans-5.3.29.jar:5.3.29]
    at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:955) ~[spring-beans-5.3.29.jar:5.3.29]
    at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:921) ~[spring-context-5.3.29.jar:5.3.29]
    at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:583) ~[spring-context-5.3.29.jar:5.3.29]
    at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:147) ~[spring-boot-2.7.14.jar:2.7.14]
    at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:731) [spring-boot-2.7.14.jar:2.7.14]
    at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:408) [spring-boot-2.7.14.jar:2.7.14]
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:307) [spring-boot-2.7.14.jar:2.7.14]
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:1303) [spring-boot-2.7.14.jar:2.7.14]
    at org.springframework.boot.SpringApplication.run(SpringApplication.java:1292) [spring-boot-2.7.14.jar:2.7.14]
    at cn.xxxxx.tmMaster.MasterApplication.main(MasterApplication.java:17) [classes/:na]
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_382]
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_382]
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_382]
    at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_382]
    at org.springframework.boot.devtools.restart.RestartLauncher.run(RestartLauncher.java:50) [spring-boot-devtools-2.7.14.jar:2.7.14]
Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [cn.xxxxx.tmMaster.service.testcase.WsMessageService]: Constructor threw exception; nested exception is java.lang.NullPointerException
    at org.springframework.beans.BeanUtils.instantiateClass(BeanUtils.java:224) ~[spring-beans-5.3.29.jar:5.3.29]
    at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:87) ~[spring-beans-5.3.29.jar:5.3.29]
    at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateBean(AbstractAutowireCapableBeanFactory.java:1326) ~[spring-beans-5.3.29.jar:5.3.29]
    ... 22 common frames omitted
Caused by: java.lang.NullPointerException: null
    at cn.xxxxx.tmMaster.utils.SpringContextUtil.getBean(SpringContextUtil.java:55) ~[classes/:na]
    at cn.xxxxx.tmMaster.service.testcase.WsMessageService.<init>(WsMessageService.java:48) ~[classes/:na]
    at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) ~[na:1.8.0_382]
    at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) ~[na:1.8.0_382]
    at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) ~[na:1.8.0_382]
    at java.lang.reflect.Constructor.newInstance(Constructor.java:423) ~[na:1.8.0_382]
    at org.springframework.beans.BeanUtils.instantiateClass(BeanUtils.java:211) ~[spring-beans-5.3.29.jar:5.3.29]
    ... 24 common frames omitted

参考资料：

SpringBoot集成WebSocket实现客户端与服务端长连接通信_springboot实现websocket客户端_拄杖忙学轻声码的博客-CSDN博客 SpringBoot集成WebSocket实现客户端与服务端长连接通信

快速搭建springboot websocket客户端_springboot实现websocket客户端_wcybaonier的博客-CSDN博客 快速搭建springboot websocket客户端

更多推荐

异步机制的简单实现

计算机有两种阻塞，一是cpu阻塞，二是io阻塞。cpu阻塞就是cpu密集计算，io阻塞比如等待网络响应，等待磁盘响应，纯粹是浪费时间。线程机制和异步机制都可避免io阻塞，但cpu阻塞的负面效果就只有线程可以避免了。在现代计算机语言里，大量线程切换虽然会有性能问题，但是线程用起来简单，而且线程能在固定时间切换，可保证实时

Typora mac新手入门教程

ypora是一款由AbnerLee创造的Markdown编辑器，它具备轻巧的特性。与其他Markdown编辑器有所不同的是，Typora不采用传统的源代码和预览分栏显示方式，而是提供了一种所见即所得的编辑方式，允许用户即时预览文档渲染效果，同时也提供了源代码编辑模式的切换功能。以下是一个在macOS下入门使用Typor

PG-多版本并发控制

多版本并发控制（Multi-VersionConcurrencyControl，MVCC），是数据库中并发访问数据时保证数据一致性的一种方法1.原理1)在并发操作中，当正在写时，如果有用户在读，这时写可能只写了一半，如一行的前半部分刚写入，后半部分还没有写入，这时可能读的用户读取到的数据行的前半部分数据是新的，后半部分

聚焦数据库和新兴硬件的技术合力 中科驭数受邀分享基于DPU的数据库异构加速方案

随着新型硬件成本逐渐降低，充分利用新兴硬件资源提升数据库性能是未来数据库发展的重要方向之一，SIGMOD、VLDB、CICE数据库顶会上出现越来越多新兴硬件的论文和专题。在需求侧，随着数据量暴增和实时性的要求越来越高，数据库围绕处理器、内存、存储和网络四个硬件架构方向不断突破和创新。数据库和新兴硬件之间的融合产生了令人

机器学习中分类问题的初步

分类任务做人脸辨识也可以是分类，手写字识别也可以是用回归来预测分类，因为回归会惩罚那些太正确的分类，反而得到的结果是不好的，还有一个问题如果你把class1当作1，class2当作2，class3当3，这样做就相当于默认了class12相近二元分类的任务的步骤类别的个数的概率水系中某一个品种的概率如果找到了高斯分布就可

JavaScript学习笔记04

JavaScript笔记04方法定义方法当一个函数是一个对象的属性时，称之为方法。例：<!DOCTYPEhtml><htmllang="en"><head><metacharset="UTF-8"><title>Title</title><script>letperson={name:"张三",birthday:200

JavaScript之观察者模式

本文作者为360奇舞团前端开发工程师概述在日常开发中，开发人员经常使用设计模式来解决软件设计中的问题。其中，观察者模式是一种常用的模式，它可以帮助开发人员更好地处理对象之间的通信。在JavaScript中，观察者模式的应用非常广泛，可以用于实现事件处理、数据绑定等功能。本文将介绍观察者模式的基本概念和实现方式。什么是观

大数据之Hadoop

大数据按顺序给出数据存储单位：bit、Byte、KB、MB、GB、TB、PB、EB、ZB、YB、BB、NB、DB。1Byte=8bit1K=1024Byte1MB=1024K1G=1024M1T=1024G1P=1024THadoopHadoop是一个能够对大量数据进行分布式处理的软件框架。分布式处理是指：比如有100

苹果CMS主题 MXonePro二开优化修复开源版影视网站源码

MXPro模板主题(又名：mxonepro)是一款基于苹果cms程序的一款全新的简洁好看UI的影视站模板类似于西瓜视频，不过同对比MxoneV10魔改模板来说功能没有那么多,也没有那么大气，但是比较且可视化功能较多简洁且有周更记录样式等多功能后台设置，类似预mxone魔改版的预告片功能，用来做影视站模板也是极好的，但之

【go语言】条件，选择，循环和特殊语句

if语句a:=10ifa>20{fmt.Printf("a大于20")}elseifa<10{fmt.Printf("a小于10")}else{fmt.Printf("a大于等于10，a小于等于20")}go语言的if语句和C语言的if语句的差不多，需要注意的是else和elseif要写在括号右边；go语言的if语句还

golang http

函数说明http.ServeMux是Go语言标准库中的一个多路复用器（multiplexer）。它用于路由和处理HTTP请求，将请求分发到相应的处理器函数。http.HandleFunc是Go语言标准库中的一个函数，用于注册处理器函数来处理HTTP请求。它是对http.ServeMux的简化封装，方便快速实现路由功能。

热文推荐
  1. 使用亚马逊云服务器在 G4 实例上运行 Android 应用程序

    随着Android应用程序和游戏变得越来越丰富，其中有些甚至比PC上的软件更易于使用和娱乐，因此许多人希望能够在云上运行Android游戏或应用程序，而在EC2实例上运行Android的解决方案可以让开发人员更轻松地测试和运行Android应用程序。在这篇博客文章中，我们将展示如何使用NICEDCV在Anbox中运行A

  2. 如何通过文件自动备份软件进行自动化备份？

    ​为什么要使用文件自动备份软件有一位做客户资料保管登记的朋友，每天会在电脑上录入很多新的客户资料，并需要进行相关维护。比如删掉一些取消合作的客户，或者添加一些备注等等。对于像他这种工作性质的人来说，很需要一个可以进行文件自动备份的软件，无论电脑出现什么问题，可以将重要资料还原。其实每个人有对自己而言特别珍贵或重要的资料

  3. 一份企业业务流程自动化指南

    自2020年以来，与低代码相关的种种趋势已经充分表明，更加高效的开发速度是企业数字化转型过程中的主要目标之一。Gartner曾预测，到2023年底，低代码开发技术市场将增长20%。此外，他们还预计，到2026年，非正式IT部门的开发人员将占低代码开发工具用户群至少80%的比例，而这一比例在2021年为60%。基于过去所

  4. 贪心算法-会议室问题

    1、题目描述一些项目要占用一个会议室宣讲，会议室不能同时容纳两个项目。现在给你两个长度一样的数组，starts数组代码每个会议开始的时间，ends数组代表每个会议结束的时间。在给你一个当前时间，请你求出当日可以利用会议室宣讲的最大值思路分析：1.按照最早开始的会议排序，最早开始的优先。2.按照最短时间排序，时间最短的优

  5. Linux系统编程——网络编程的学习

    Linux系统编程学习相关博文Linux系统编程——文件编程的学习Linux系统编程——进程的学习Linux系统编程——进程间通信的学习Linux系统编程——线程的学习Linux系统编程——网络编程的学习一、概述1.TCP/UDP2.端口号3.字节序4.Sockt服务器和客户端的开发步骤1.服务器2.客户端二、网络编程

  6. Python+Requests+Excel接口测试实战

    1、EXCEL文件接口保存方式，如图。2、然后就是读取EXCEL文件中的数据方法，如下：1importxlrd234classreadExcel(object):5def__init__(self,path):6self.path=path78@property9defgetSheet(self):10#获取索引11x

  7. SQL注入脚本编写

    文章目录布尔盲注脚本延时注入脚本安装xampp，在conf目录下修改它的http配置文件，如下，找到配置文件：修改配置文件中的默认主页，让xampp能访问phpstudy的www目录，因为xampp的响应速度比phpstudy快得多，所以用它做SQL注入脚本的服务器：布尔盲注脚本以sqli-labs第8关为例，在第8关

  8. Vue3通透教程【十七】Vite构建TS版本Vue项目

    文章目录🌟写在前面🌟创建TS版本的Vue3项目🌟插件安装🌟写在最后🌟写在前面专栏介绍：凉哥作为Vue的忠实粉丝输出过大量的Vue文章，应粉丝要求开始更新Vue3的相关技术文章，Vue框架目前的地位大家应该都晓得，所谓三大框架使用人数最多，公司选型最多的框架，凉哥之前在文章中也提到过就是Vue框架之所以火起来的

  9. 高压配电安全监测系统：确保电力系统的稳定运行

    随着现代社会对电力需求的不断增长，高压配电系统的重要性日益凸显。为了保证电力系统的稳定运行，提高供电质量，采用高压配电安全监测系统至关重要。力安科技高压配电安全监测系统通过在每面高压柜（进线柜、出线柜、联络柜）配置一只A62系列电力探测器，在断路器的进出铜排接线处各安装一只无线测温探测器，并加装开口电流互感器一套，经G