1

zyy3

2025-11-05 91bbc719126310f09031e55967c059c0a01f20b1

 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();