1

zj

2025-01-27 ea9c019dbe350e261bc01dc6c8ae92511e47e68a

 bitgetsClient/src/main/java/org/example/bitgetsclient/WsBean/BitgetsWsBean.java

@@ -43,7 +43,7 @@

    @Bean
    public void bitgetWebsocketRunClientMap() throws JSONException, JsonProcessingException {
        List<Currency> mexc = currencyService.list(new LambdaQueryWrapper<Currency>().eq(Currency::getSource, "bitget"));
        List<Currency> mexc = currencyService.list(new LambdaQueryWrapper<Currency>().eq(Currency::getSource, "bitget").eq(Currency::getQuoteAsset,"USDT"));
        if (!CollectionUtils.isEmpty(mexc)) {
            int batchSize = 100; // 每个线程处理的数据量
            int totalSize = mexc.size();