From 91bbc719126310f09031e55967c059c0a01f20b1 Mon Sep 17 00:00:00 2001
From: zyy3 <zyy3@zy.com>
Date: Wed, 05 Nov 2025 18:50:49 +0800
Subject: [PATCH] 1
---
trading-order-huobi/src/main/java/com/yami/trading/huobi/jsws/WebsocketRunClient.java | 19 +++++++++++++------
1 files changed, 13 insertions(+), 6 deletions(-)
diff --git a/trading-order-huobi/src/main/java/com/yami/trading/huobi/jsws/WebsocketRunClient.java b/trading-order-huobi/src/main/java/com/yami/trading/huobi/jsws/WebsocketRunClient.java
index 86fc437..e120d1f 100644
--- a/trading-order-huobi/src/main/java/com/yami/trading/huobi/jsws/WebsocketRunClient.java
+++ b/trading-order-huobi/src/main/java/com/yami/trading/huobi/jsws/WebsocketRunClient.java
@@ -12,6 +12,8 @@
import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Scope;
+import org.springframework.stereotype.Component;
import java.lang.reflect.Type;
import java.math.BigDecimal;
@@ -20,6 +22,8 @@
import java.util.*;
@Slf4j
+@Component
+@Scope("prototype")
public class WebsocketRunClient extends WebSocketClient {
private EStockType eStockType;
@@ -27,16 +31,20 @@
@Autowired
ItemService itemService;
+ public WebsocketRunClient() {
+ super(URI.create("wss://ws.jinmanxuan.com/websocket-server"));
+ }
+
public WebsocketRunClient(URI serverUri, EStockType eStockType) {
// 修改为新的WebSocket服务器地址
- super(URI.create("wss://usws.yanshiz.com/websocket-server"));
+ super(URI.create("wss://ws.jinmanxuan.com/websocket-server"));
this.eStockType = eStockType;
}
@Override
public void onOpen(ServerHandshake serverHandshake) {
- log.info("WebSocket连接已建立，连接到: wss://usws.yanshiz.com/websocket-server");
+ log.info("WebSocket连接已建立，连接到: wss://ws.jinmanxuan.com/websocket-server");
// 发送身份验证消息
send(("key:"+ eStockType.getStockKey()+":"+eStockType.getContryId()).getBytes());
Timer heartbeatTimer;
@@ -58,10 +66,9 @@
if(!s.equals("pong") && !s.equals("身份验证成功")){
try {
Map<String, String> stringObjectMap = jsonToMap(s);
-
- String symbol = stringObjectMap.get("symbol");
- Item item = itemService.findBySymbol(symbol);
- if (!item.getType().equalsIgnoreCase(Item.US_STOCKS)) {
+ String symbol = stringObjectMap.get("symbol").trim();
+ Item item = itemService.findCaCheBySymbol(symbol);
+ if (item == null || !item.getType().equalsIgnoreCase(Item.US_STOCKS)) {
return;
}
Realtime realtime = new Realtime();
--
Gitblit v1.9.3