1

zj

2024-10-21 3a4ca606fad5d286e8b0de99f39ffbea8ef3cc21

 mexcClient/src/main/java/org/example/mexcclient/WsBean/MexcWsBean.java

@@ -53,7 +53,7 @@

    @Bean
    public void mexcWebsocketRunClientMap() throws InterruptedException {
        List<Currency> mexc = currencyService.list(new LambdaQueryWrapper<Currency>().eq(Currency::getSource, "mexc"));
        List<Currency> mexc = currencyService.list(new LambdaQueryWrapper<Currency>().eq(Currency::getSource, "mexc").eq(Currency::getBaseAsset,"USBT"));
        if (!CollectionUtils.isEmpty(mexc)) {
            int batchSize = 30; // 每个线程处理的数据量
            int totalSize = mexc.size();