From c2cf572d823f5ab410fd82ae169f012caf3386c7 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Fri, 12 Jul 2024 17:50:36 +0800
Subject: [PATCH] 1
---
websocketClient/src/main/java/org/example/controller/WsClientController.java | 39 +++++++++++++++++++++++++++++++++++++++
1 files changed, 39 insertions(+), 0 deletions(-)
diff --git a/websocketClient/src/main/java/org/example/controller/WsClientController.java b/websocketClient/src/main/java/org/example/controller/WsClientController.java
index 0657766..2b1d6be 100644
--- a/websocketClient/src/main/java/org/example/controller/WsClientController.java
+++ b/websocketClient/src/main/java/org/example/controller/WsClientController.java
@@ -1,10 +1,49 @@
package org.example.controller;
+import lombok.extern.slf4j.Slf4j;
+import org.example.enums.EStockType;
+import org.example.server.wcServer;
+import org.java_websocket.client.WebSocketClient;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.net.URI;
+import java.util.HashMap;
+import java.util.Map;
+
/**
* @ClassDescription: 客户端请求类
* @JdkVersion: 1.8
* @Created: 2023/8/31 16:13
*/
+@Slf4j
+@Configuration
public class WsClientController {
+
+ @Bean
+ public Map<String, WebSocketClient> websocketRunClientMap() {
+
+ Map<String, WebSocketClient> retMap = new HashMap<>(2);
+ try {
+ wcServer websocketRunClient = new wcServer(new URI("ws://api-jp-ws.js-stock.top"));
+ websocketRunClient.connect();
+ websocketRunClient.setConnectionLostTimeout(0);
+ new Thread(() -> {
+ while (true) {
+ try {
+ Thread.sleep(8000);
+ websocketRunClient.send("heartbeat".getBytes());
+ } catch (Exception e) {
+ websocketRunClient.reconnect();
+ websocketRunClient.setConnectionLostTimeout(0);
+ }
+ }
+ }).start();
+ } catch (Exception e) {
+ }
+ return retMap;
+ }
+
+
}
--
Gitblit v1.9.3