From 3a814acd184acb80b035a9b61d688b71f395993b Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Fri, 24 Oct 2025 18:31:56 +0800
Subject: [PATCH] ws优化
---
trading-order-huobi/src/main/java/com.yami.trading.huobi/data/websocket/service/huobi/connection/HuobiWebSocketConnection.java | 15 +++++++++++----
1 files changed, 11 insertions(+), 4 deletions(-)
diff --git a/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/websocket/service/huobi/connection/HuobiWebSocketConnection.java b/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/websocket/service/huobi/connection/HuobiWebSocketConnection.java
index 24af0ff..c986fcb 100644
--- a/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/websocket/service/huobi/connection/HuobiWebSocketConnection.java
+++ b/trading-order-huobi/src/main/java/com.yami.trading.huobi/data/websocket/service/huobi/connection/HuobiWebSocketConnection.java
@@ -318,10 +318,17 @@
state = ConnectionStateEnum.CONNECTED;
lastReceivedTime = System.currentTimeMillis();
- // 不需要验签的话，直接把命令发出去就好
- commandList.forEach(command -> {
- send(command);
- });
+ // 延迟1秒发送订阅命令，避免连接未稳定
+ new Thread(() -> {
+ try {
+ Thread.sleep(1000); // 1秒延迟
+ commandList.forEach(command -> {
+ send(command);
+ });
+ } catch (InterruptedException e) {
+ Thread.currentThread().interrupt();
+ }
+ }).start();
}
--
Gitblit v1.9.3