blame | history | patch | commit | commitdiff | ignore whitespace
1
zj
2024-10-21 3a4ca606fad5d286e8b0de99f39ffbea8ef3cc21 
 mexcClient/src/main/java/org/example/mexcclient/WsBean/MexcWsBean.java


@@ -14,6 +14,7 @@


import org.apache.http.impl.client.DefaultHttpClient;


import org.apache.http.message.BasicNameValuePair;


import org.apache.http.util.EntityUtils;


import org.example.mexcclient.MexcClientApplication;


import org.example.mexcclient.pojo.Currency;


import org.example.mexcclient.server.impl.CurrencySerivceImpl;


import org.example.mexcclient.wsClient.MexcClient;


@@ -21,6 +22,8 @@


import org.json.JSONObject;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.beans.factory.annotation.Qualifier;


import org.springframework.boot.SpringApplication;


import org.springframework.context.ConfigurableApplicationContext;


import org.springframework.context.annotation.Bean;


import org.springframework.context.annotation.Configuration;


import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;


@@ -49,20 +52,26 @@


    private ThreadPoolTaskExecutor threadPoolTaskExecutor;




    @Bean


    public void mexcWebsocketRunClientMap() {


        List<Currency> mexc = currencyService.list(new LambdaQueryWrapper<Currency>().eq(Currency::getSource, "mexc"));


    public void mexcWebsocketRunClientMap() throws InterruptedException {


        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();


            int threadCount = (int) Math.ceil((double) totalSize / batchSize); // 计算需要的线程数




            int count = 0;


            for (int i = 0; i < threadCount; i++) {


                int fromIndex = i * batchSize;


                int toIndex = Math.min(fromIndex + batchSize, totalSize);


                List<Currency> sublist = mexc.subList(fromIndex, toIndex);




                count++;


                if(count % 15 == 0 && count != 0){


                    count = 0;


                    Thread.sleep(1500);


                }


                // 使用自定义线程池提交任务


                threadPoolTaskExecutor.execute(new MexcClient(sublist)::start);


                threadPoolTaskExecutor.execute(() -> {


                    new MexcClient(sublist).start();


                });


            }




        }