| | |
|---|
| | | 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 token = "2neAiuYvAU61ZDXANAGAsiL4-iAExhsBXZxftpOeh_55i3Ysy2q2LEsEWU64mdzUOPusi34M_wGoSf7iNyEWJwAOaCRcyD1ZqgQMAVRBiG7sPpujjw91tNiYB9J6i9GjsxUuhPw3BlrzazF6ghq4L0vRGCvQlyDu8hXEVeVU824=.c2e16bAGh64wOMyJm_jKxQ=="; |
|---|
| | | String result = doPost(); |
|---|
| | | JSONObject jsonObject = new JSONObject(result); |
|---|
| | | String token = jsonObject.getJSONObject("data").getString("token"); |
|---|
| | | int batchSize = 100; // 每个线程处理的数据量 |
|---|
| | | int totalSize = mexc.size(); |
|---|
| | | int threadCount = (int) Math.ceil((double) totalSize / batchSize); // 计算需要的线程数 |
|---|
