JAVA 实现websocket作为客户端（自动断线重连）

不念不忘少年蓝@ 2023-05-29 02:34 1阅读 0赞

因为很少有这样作为客户端的使用，但是遇上特殊需求还是要作为客户端使用，spring-boot-starter集成的无法实现客户端，直接上代码

pom引入，这里使用的spring boot 其他项目自行下载jar包库

<dependency>
    			<groupId>org.java-websocket</groupId>
    			<artifactId>Java-WebSocket</artifactId>
    			<version>1.3.8</version>
    		</dependency>

package com.jwuwb.library.service.websocket;
    
    import com.alibaba.fastjson.JSON;
    import com.alibaba.fastjson.JSONObject;
    import com.jwuwb.library.entity.PositionStation;
    import com.jwuwb.library.service.PositionStationService;
    import org.java_websocket.WebSocket.READYSTATE;
    import org.java_websocket.client.WebSocketClient;
    import org.java_websocket.handshake.ServerHandshake;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.stereotype.Component;
    
    import java.net.URI;
    
    /**
     * websocket 建立连接...
     * @author apple
     */
    @Component
    public class Client {
        private static final Logger logger = LoggerFactory.getLogger(Client.class);
    
    	public static void createConnect() throws Exception{
            WebSocketClient client = new WebSocketClient(new URI(这里是你连接的websocket的地址)) {
    
                @Override
                public void onOpen(ServerHandshake arg0) {
                    logger.info("开始建立链接...");
                }
    
                @Override
                public void onMessage(String arg0) {
                  logger.info("检测到服务器请求...arg0 : " + arg0);
                }
    
                @Override
                public void onError(Exception arg0) {
                    arg0.printStackTrace();
                    logger.info("客户端发生错误,即将关闭!");
                }
    
                @Override
                public void onClose(int arg0, String arg1, boolean arg2) {
                    logger.info("客户端已关闭!");
                    logger.info("开始尝试重新连接...");
                    try {
                        Client.createConnect();
                    } catch (Exception e) {
                        e.printStackTrace();
                        logger.info("重新连接失败,请检查网络!");
                    }
                }
            };
    
    		client.connect();
    		//判断连接状态,
    		while (client.getReadyState().equals(READYSTATE.OPEN)) {
    			logger. info("成功建立链接!");
    		}
    	}
    }

由于websocket是多例的无法直接注入可以使用：**（这里只是个示例，使用静态变量的方式可以实现注入）**

public static UserService userService;
    @Autowired
    public void setService(UserService userService) {
        Client.userService = userService;
    }

很简单直接调用

Client.createConnect();
    或者@PostConstruct直接项目启动一起启动

2021-01-08：

修复会自动断线bug: ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIzOTQ1Njg1_size_16_color_FFFFFF_t_70][]

在连接之前设置client的属性

client.setConnectionLostTimeout(0);

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIzOTQ1Njg1_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20210108153356121.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzIzOTQ1Njg1,size_16,color_FFFFFF,t_70