diff --git a/ruoyi-framework/src/main/java/com/ruoyi/framework/config/ThreadPoolConfig.java b/ruoyi-framework/src/main/java/com/ruoyi/framework/config/ThreadPoolConfig.java index 4bff7c9..841e901 100644 --- a/ruoyi-framework/src/main/java/com/ruoyi/framework/config/ThreadPoolConfig.java +++ b/ruoyi-framework/src/main/java/com/ruoyi/framework/config/ThreadPoolConfig.java @@ -18,10 +18,10 @@ import java.util.concurrent.ThreadPoolExecutor; public class ThreadPoolConfig { // 核心线程池大小 - private int corePoolSize = 10; + private int corePoolSize = 15; // 最大可创建的线程数 - private int maxPoolSize = 20; + private int maxPoolSize = 30; // 队列最大长度 private int queueCapacity = 500; diff --git a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/MeituanServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/MeituanServiceImpl.java index c6b42dd..19ba3cd 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/MeituanServiceImpl.java +++ b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/MeituanServiceImpl.java @@ -275,14 +275,13 @@ public class MeituanServiceImpl implements IMeituanService { * @return */ @Override - @Transactional(rollbackFor = Exception.class) public String orderInfoList() { LocalDateTime now = LocalDateTime.now(); BusStoreInfo busStoreInfo = new BusStoreInfo(); busStoreInfo.setReturnVisitStatus("1"); List busStoreInfoList = busStoreInfoMapper.selectBusStoreInfoList(busStoreInfo); long startTime = System.currentTimeMillis(); // 开始时间 - List> list1= SplitListUtils.pagingList(busStoreInfoList,4); //拆分集合 + List> list1= SplitListUtils.pagingList(busStoreInfoList,30); //拆分集合 CountDownLatch countDownLatch = new CountDownLatch(list1.size()); for (List list2 : list1) { asyncTask.executeAsync(list2,busStoreInfoMapper,countDownLatch); @@ -1124,6 +1123,27 @@ public class MeituanServiceImpl implements IMeituanService { .setDefaultRequestConfig(config) .setDefaultCredentialsProvider(credsProvider) .build(); +// CloseableHttpClient httpClient = HttpClients.custom().setDefaultRequestConfig(config).build(); + return httpClient; + } + + private CloseableHttpClient localHttpClient() { + // JDK 8u111版本后,目标页面为HTTPS协议,启用proxy用户密码鉴权 + System.setProperty("jdk.http.auth.tunneling.disabledSchemes", ""); +// String proxyHost = proxyProperties.getProxyAddr(); +// int proxyPort = proxyProperties.getProxyPort(); +// String username = proxyProperties.getAccount(); +// String password = proxyProperties.getPwd(); +// HttpHost proxy = new HttpHost(proxyHost, proxyPort); +// CredentialsProvider credsProvider = new BasicCredentialsProvider(); +// credsProvider.setCredentials(new AuthScope(proxyHost, proxyPort), +// new UsernamePasswordCredentials(username, password)); +// RequestConfig config = RequestConfig.custom().setProxy(proxy).build(); + CloseableHttpClient httpClient = HttpClients + .custom() +// .setDefaultRequestConfig(config) +// .setDefaultCredentialsProvider(credsProvider) + .build(); // CloseableHttpClient httpClient = HttpClients.custom().setDefaultRequestConfig(config).build(); return httpClient; }