因为很少有这样作为客户端的使用,但是遇上特殊需求还是要作为客户端使用,spring-boot-starter集成的无法实现客户端,直接上代码
pom引入,这里使用的spring boot 其他项目自行下载jar包库
<!--WebSocket核心依赖包-->
<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:
在连接之前设置client的属性
client.setConnectionLostTimeout(0);