From 49943af4167ec20881724bde9f4851aa70aca6fe Mon Sep 17 00:00:00 2001 From: wangshuai Date: Thu, 1 Aug 2024 05:22:57 +0800 Subject: [PATCH] =?UTF-8?q?1=EF=BC=9B=E7=BA=BF=E7=A8=8B=E6=B1=A0=E9=85=8D?= =?UTF-8?q?=E7=BD=AE=E4=BF=AE=E6=94=B9=202=EF=BC=9B=E6=9C=AC=E5=9C=B0http?= =?UTF-8?q?=E6=96=B9=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../framework/config/ThreadPoolConfig.java | 4 ++-- .../service/impl/MeituanServiceImpl.java | 24 +++++++++++++++++-- 2 files changed, 24 insertions(+), 4 deletions(-) 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; }