From 603d1642239c1f550c44c1c78e19f524f7186122 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Wed, 17 Dec 2025 10:05:46 +0800
Subject: [PATCH] feat(okxNewPrice): 更新网格列表枚举值
---
src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxWebSocketClientMain.java | 15 ++++++++++-----
1 files changed, 10 insertions(+), 5 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxWebSocketClientMain.java b/src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxWebSocketClientMain.java
index 063e02b..9eebd2d 100644
--- a/src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxWebSocketClientMain.java
+++ b/src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxWebSocketClientMain.java
@@ -1,16 +1,21 @@
package com.xcong.excoin.modules.okxNewPrice;
+import com.xcong.excoin.modules.okxNewPrice.celue.CaoZuoServiceImpl;
+import com.xcong.excoin.modules.okxNewPrice.wangge.WangGeServiceImpl;
+import com.xcong.excoin.utils.RedisUtils;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.support.ClassPathXmlApplicationContext;
+
public class OkxWebSocketClientMain {
public static void main(String[] args) throws InterruptedException {
- OkxQuantWebSocketClient clientV2 = new OkxQuantWebSocketClient();
- // 手动调用初始化方法
- clientV2.init();
+ // 使用Spring上下文初始化管理器
+ ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
+ OkxWebSocketClientManager manager = context.getBean(OkxWebSocketClientManager.class);
// 运行一段时间以观察结果
Thread.sleep(1200000000L); // 运行一小时
// 关闭连接
- clientV2.destroy();
-
+ manager.destroy();
}
}
\ No newline at end of file
--
Gitblit v1.9.1