1

zj

2024-08-04 d41418fa706a65547964a538d11a75b0d8feb2c4

1

 bitgetsClient/pom.xml

@@ -135,7 +135,6 @@
                <version>${spring-boot.version}</version>
                <configuration>
                    <mainClass>org.example.bitgetsclient.BitgetsClientApplication</mainClass>
                    <skip>true</skip>
                </configuration>
                <executions>
                    <execution>

 geteClient/pom.xml

@@ -135,7 +135,6 @@
                <version>${spring-boot.version}</version>
                <configuration>
                    <mainClass>org.example.geteclient.GeteClientApplication</mainClass>
                    <skip>true</skip>
                </configuration>
                <executions>
                    <execution>

 kucoinClient/pom.xml

@@ -15,6 +15,11 @@
    </properties>
    <dependencies>
        <dependency>
            <groupId>com.sun.xml.bind</groupId>
            <artifactId>jaxb-impl</artifactId>
            <version>2.3.1</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
@@ -145,7 +150,6 @@
                <version>${spring-boot.version}</version>
                <configuration>
                    <mainClass>org.example.kucoinclient.KucoinClientApplication</mainClass>
                    <skip>true</skip>
                </configuration>
                <executions>
                    <execution>

 kucoinClient/src/main/java/org/example/kucoinclient/WsBean/MexcWsBean.java

@@ -49,9 +49,10 @@
    public void kucoinWebsocketRunClientMap() throws Exception {
        List<Currency> mexc = currencyService.list(new LambdaQueryWrapper<Currency>().eq(Currency::getSource, "kucoin"));
        if (!CollectionUtils.isEmpty(mexc)) {
            String result = doPost();
            JSONObject jsonObject = new JSONObject(result);
            String token = jsonObject.getJSONObject("data").getString("token");
//            String result = doPost();
//            JSONObject jsonObject = new JSONObject(result);
//            String token = jsonObject.getJSONObject("data").getString("token");
            String token = "2neAiuYvAU61ZDXANAGAsiL4-iAExhsBXZxftpOeh_55i3Ysy2q2LEsEWU64mdzUOPusi34M_wGoSf7iNyEWJwAOaCRcyD1ZqgQMAVRBiG7sPpujjw91tNiYB9J6i9GjsxUuhPw3BlrzazF6ghq4L0vRGCvQlyDu8hXEVeVU824=.c2e16bAGh64wOMyJm_jKxQ==";
            int batchSize = 100; // 每个线程处理的数据量
            int totalSize = mexc.size();
            int threadCount = (int) Math.ceil((double) totalSize / batchSize); // 计算需要的线程数

 kucoinClient/src/main/java/org/example/kucoinclient/wsClient/KucoinClient.java

@@ -5,7 +5,6 @@
import com.google.common.reflect.TypeToken;
import com.google.gson.Gson;
import com.google.gson.JsonSyntaxException;
import com.sun.istack.internal.NotNull;
import lombok.extern.slf4j.Slf4j;
import org.example.kucoinclient.pojo.Currency;
import org.example.kucoinclient.util.RedisUtil;
@@ -240,7 +239,6 @@
        return mapper.writeValueAsString(jsonMap); // 返回 JSON 字符串
    }

    @NotNull
    private String getSymbol() {
        List<String> symbolList = subscriptions.stream()
                .map(currency -> currency.getSymbol().replaceAll("USDT", "-USDT")) // 替换符号

 mexcClient/pom.xml

@@ -135,7 +135,6 @@
                <version>${spring-boot.version}</version>
                <configuration>
                    <mainClass>org.example.mexcclient.MexcClientApplication</mainClass>
                    <skip>true</skip>
                </configuration>
                <executions>
                    <execution>

 websocketSerivce/src/main/resources/application.properties

@@ -1,5 +1,5 @@

XDB_PATH=F:/project/marketData/websocketSerivce/src/main/resources/ip/csdn-ip2region.xdb
XDB_PATH=/www/wwwroot/csdn-ip2region.xdb

redis1.ip=localhost
redis1.port=6379