Springboot整合Websocket遇到的坑

Posted 2023-05-04

参考技术A 如果客户端关闭了websocket，但服务端没有监听到关闭事件，即onClose方法没有调用，这是会发生的情况

此时如果服务端向客户端推送消息，会出现异常告诉开发者：关闭了一个连接，并重新调用onClose方法

springboot websocket实现过程中踩过的坑

1springboot和websocket整合

参考原文：SpringBoot2.0集成WebSocket，实现后台向前端推送信息_Moshow郑锴的博客-CSDN博客_springboot websocket，

测试网页可以选择网上现成的：在线websocket测试-在线工具-postjson

问题1:这就是单机的，如果是集群模式该如何处理？

解决办法：将需要发送的消息推送到MQ，然后通过MQ广播到各个服务器去监听，将获取的消息再推给websocket对应的网页（每台机器对应一部分，那么加起来就是所有的前端）。

问题2:在websocket的server类中注入其他service会报空指针，即注入失败。

解决办法：

1. 创建配置类

@Component
public class ApplicationContextRegister  implements ApplicationContextAware 
    private static ApplicationContext APPLICATION_CONTEXT;
 
 
    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException 
        APPLICATION_CONTEXT = applicationContext;
    
 
    public static ApplicationContext getApplicationContext() 
        return APPLICATION_CONTEXT;
    

3. websocket类中配置

 //websocket 使用service 层
                ApplicationContext act = ApplicationContextRegister.getApplicationContext();
                messagelogService=act.getBean(MessagelogService.class);
                int resultlog = messagelogService.insertIntoMessagelog(messagelog);

按照上面的步骤也解决了该问题，但是发布到服务器后发现又出现了新问题（Caused by: java.lang.NullPointerException: null）

问题3:在本地运行正常，在服务器运行又报了注入失败的问题（同问题2类似，但有区别）

原因分析：本地和服务器的类加载顺序不一样

解决办法有如下三种：

1. 在配置类上加order注解（亲测有效）

@Configuration
@Order(0)
public class ApplicationContextRegister  implements ApplicationContextAware 
    private static ApplicationContext APPLICATION_CONTEXT;
    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException 
        APPLICATION_CONTEXT = applicationContext;
    
    public static ApplicationContext getApplicationContext() 
        return APPLICATION_CONTEXT;
    

2. 在初始化方法上添加PostConstruct注解

@PostConstruct
public void init()
ApplicationContext act = ApplicationContextRegister.getApplicationContext();

3）在初始化方法上添加EventListener注解

@EventListener(ApplicationReadyEvent.class)
public void init(ApplicationReadyEvent event)