java webSocket服务端、客户端、心跳检测优雅解决

港控/mmm° 2024-03-17 21:00 93阅读 0赞

#### java webSocket服务端、客户端、心跳检测优雅解决 ####

*  背景
 *  代码
 *   *  服务端
     *   *  WebSocketConfig
         *  WebSocketServer
     *  客户端
     *   *  WebSocketClient
 *  特殊说明

## 背景 ##

项目分为三个端，项目之间需要webSocket通信。

## 代码 ##

### 服务端 ###

#### WebSocketConfig ####

package com.business.socket;
    
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.web.socket.server.standard.ServerEndpointExporter;
    
    @Configuration
    public class WebSocketConfig {
       
        
        /**
         * 如果使用Springboot默认内置的tomcat容器，则必须注入ServerEndpoint的bean；
         * 如果使用外置的web容器，则不需要提供ServerEndpointExporter，下面的注入可以注解掉
         */
        @Bean
        public ServerEndpointExporter serverEndpointExporter() {
       
        
            return new ServerEndpointExporter();
        }
    }

#### WebSocketServer ####

package com.business.socket;
    
    import cn.hutool.core.collection.CollUtil;
    import cn.hutool.core.convert.Convert;
    import cn.hutool.core.exceptions.ValidateException;
    import cn.hutool.core.lang.Validator;
    import cn.hutool.core.util.StrUtil;
    import cn.hutool.json.JSONUtil;
    import cn.hutool.log.StaticLog;
    import com.user.vo.ws.SocMsgVo;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.core.annotation.Order;
    import org.springframework.data.redis.core.RedisTemplate;
    import org.springframework.stereotype.Component;
    
    import javax.annotation.PostConstruct;
    import javax.websocket.*;
    import javax.websocket.server.PathParam;
    import javax.websocket.server.ServerEndpoint;
    import java