feat(okxNewPrice): 添加防止重复初始化的机制

Administrator

2025-12-15 7981067b68ee94b27d22dd4619c98acdddc3379b

feat(okxNewPrice): 添加防止重复初始化的机制

- 在 OkxQuantWebSocketClient 中引入 AtomicBoolean 标记以防止重复初始化
- 修改 init 方法逻辑，通过 compareAndSet 确保只初始化一次
- 添加日志警告信息，当尝试重复初始化时进行提示
- 移除每小时重连的定时任务相关代码

 src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxQuantWebSocketClient.java

@@ -68,16 +68,23 @@
        return t;
    });

    // 在 OkxQuantWebSocketClient 中添加初始化标记
    private final AtomicBoolean isInitialized = new AtomicBoolean(false);

    /**
     * 初始化方法，在 Spring Bean 构造完成后执行。
     * 负责建立 WebSocket 连接并启动心跳检测任务。
     */
    @PostConstruct
    public void init() {
        // 防止重复初始化
        if (!isInitialized.compareAndSet(false, true)) {
            log.warn("OkxQuantWebSocketClient 已经初始化过，跳过重复初始化");
            return;
        }

        connect();
        startHeartbeat();
        
        // 移除了每小时重连的定时任务
    }

    /**