From c5faaa1111091280365100c95e7e06930b98ee4b Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Tue, 23 Dec 2025 16:21:44 +0800
Subject: [PATCH] feat(indicator): 添加15分钟交易策略和指标详细说明
---
src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxWebSocketClientManager.java | 17 ++++++++---------
1 files changed, 8 insertions(+), 9 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxWebSocketClientManager.java b/src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxWebSocketClientManager.java
index be64554..4f23fb8 100644
--- a/src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxWebSocketClientManager.java
+++ b/src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxWebSocketClientManager.java
@@ -3,8 +3,6 @@
import com.xcong.excoin.modules.okxNewPrice.celue.CaoZuoService;
import com.xcong.excoin.modules.okxNewPrice.okxWs.enums.ExchangeInfoEnum;
import com.xcong.excoin.modules.okxNewPrice.okxWs.wanggeList.WangGeListService;
-import com.xcong.excoin.modules.okxNewPrice.wangge.WangGeService;
-import com.xcong.excoin.rabbit.pricequeue.WebsocketPriceService;
import com.xcong.excoin.utils.RedisUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
@@ -34,7 +32,8 @@
private final Map<String, OkxQuantWebSocketClient> quantClientMap = new ConcurrentHashMap<>();
// 存储OkxNewPriceWebSocketClient实例
- private OkxNewPriceWebSocketClient newPriceClient;
+ private OkxKlineWebSocketClient klinePriceClient;
+
/**
* 初始化方法，在Spring Bean构造完成后执行
@@ -46,8 +45,8 @@
// 初始化价格WebSocket客户端
try {
- newPriceClient = new OkxNewPriceWebSocketClient(redisUtils, caoZuoService, this, wangGeListService);
- newPriceClient.init();
+ klinePriceClient = new OkxKlineWebSocketClient(redisUtils, caoZuoService, this, wangGeListService);
+ klinePriceClient.init();
log.info("已初始化OkxNewPriceWebSocketClient");
} catch (Exception e) {
log.error("初始化OkxNewPriceWebSocketClient失败", e);
@@ -80,9 +79,9 @@
log.info("开始销毁OkxWebSocketClientManager");
// 关闭价格WebSocket客户端
- if (newPriceClient != null) {
+ if (klinePriceClient != null) {
try {
- newPriceClient.destroy();
+ klinePriceClient.destroy();
log.info("已销毁OkxNewPriceWebSocketClient");
} catch (Exception e) {
log.error("销毁OkxNewPriceWebSocketClient失败", e);
@@ -127,7 +126,7 @@
* 获取OkxNewPriceWebSocketClient实例
* @return 价格WebSocket客户端实例
*/
- public OkxNewPriceWebSocketClient getNewPriceClient() {
- return newPriceClient;
+ public OkxKlineWebSocketClient getKlineWebSocketClient() {
+ return klinePriceClient;
}
}
\ No newline at end of file
--
Gitblit v1.9.1