refactor(okxApi): 重构WebSocket客户端配置并移除未使用的代码

Administrator

5 days ago c2cd7e00beed237720d87476172b9437824e9e4b

refactor(okxApi): 重构WebSocket客户端配置并移除未使用的代码

- 将SSLConfig工具类移动到okxApi模块中统一管理
- 删除OkxKlineWebSocketClient中的未使用导入包(Date、TimeZone等)
- 移除已废弃的OkxNewPriceWebSocketClient和OkxWebSocketClient文件
- 统一WebSocket连接的SSL配置管理
- 优化代码结构并删除冗余的时间相关导入

 src/main/java/com/xcong/excoin/modules/newPrice/OkxNewPriceWebSocketClient.java

File was deleted

 src/main/java/com/xcong/excoin/modules/newPrice/OkxWebSocketClient.java

File was deleted

 src/main/java/com/xcong/excoin/modules/okxApi/OkxKlineWebSocketClient.java

@@ -4,7 +4,6 @@
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.xcong.excoin.modules.okxApi.wsHandler.OkxChannelHandler;
import com.xcong.excoin.modules.okxNewPrice.utils.SSLConfig;
import lombok.extern.slf4j.Slf4j;
import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;
@@ -14,15 +13,11 @@
import java.net.URI;
import java.net.URISyntaxException;
import java.nio.charset.StandardCharsets;
import java.text.SimpleDateFormat;
import java.time.Instant;
import java.time.ZoneId;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.Base64;
import java.util.Date;
import java.util.List;
import java.util.TimeZone;
import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicReference;

 src/main/java/com/xcong/excoin/modules/okxApi/SSLConfig.java

New file
@@ -0,0 +1,23 @@
package com.xcong.excoin.modules.okxApi;

import javax.net.ssl.HttpsURLConnection;
import javax.net.ssl.SSLContext;
import java.security.SecureRandom;

/**
 * @author Administrator
 */
public class SSLConfig {
    public static void configureSSL() {
        try {
            // 配置SSL上下文
            SSLContext sslContext = SSLContext.getInstance("TLSv1.2");
            sslContext.init(null, null,  new SecureRandom());

            // 设置默认SSL套接字工厂
            HttpsURLConnection.setDefaultSSLSocketFactory(sslContext.getSocketFactory());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}