From e130ccb2e08bcb2e481ccf84d2a5559ebc1ce38c Mon Sep 17 00:00:00 2001 From: wr <1754607820@qq.com> Date: Mon, 28 Apr 2025 10:59:10 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4influxdb=E6=8F=92=E5=85=A5?= =?UTF-8?q?=E6=9D=A1=E6=95=B020000=EF=BC=8C=E5=A2=9E=E5=8A=A0=E7=BA=BF?= =?UTF-8?q?=E7=A8=8B=E6=B1=A0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/InsertDataFlickerImpl.java | 2 +- .../service/impl/InsertDataFlucImpl.java | 2 +- .../service/impl/InsertDataHarmRateIImpl.java | 2 +- .../service/impl/InsertDataHarmRateVImpl.java | 2 +- .../impl/InsertDataHarmphasicIImpl.java | 2 +- .../impl/InsertDataHarmphasicVImpl.java | 2 +- .../impl/InsertDataHarmpowerPImpl.java | 2 +- .../impl/InsertDataHarmpowerQImpl.java | 2 +- .../impl/InsertDataHarmpowerSImpl.java | 2 +- .../insert/service/impl/InsertDataIImpl.java | 2 +- .../service/impl/InsertDataInharmIImpl.java | 2 +- .../service/impl/InsertDataInharmVImpl.java | 2 +- .../service/impl/InsertDataPltImpl.java | 2 +- .../insert/service/impl/InsertDataVImpl.java | 2 +- .../impl/InsertPqsCommunicateImpl.java | 2 +- .../read/MigrationReadBootApplication.java | 2 + .../config/AsyncInfluxDBConfiguration.java | 48 +++++++++++++++++++ .../service/impl/MigrationServiceImpl.java | 5 +- .../src/main/resources/bootstrap.yml | 5 ++ 19 files changed, 73 insertions(+), 17 deletions(-) create mode 100644 migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/config/AsyncInfluxDBConfiguration.java diff --git a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataFlickerImpl.java b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataFlickerImpl.java index f744a7d..c9c47aa 100644 --- a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataFlickerImpl.java +++ b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataFlickerImpl.java @@ -53,7 +53,7 @@ public class InsertDataFlickerImpl implements InsertIDataFlicker { @Override public void insertDataFlicker(List list) { if(CollUtil.isNotEmpty(list)){ - List> partition = ListUtils.partition(list, 100000); + List> partition = ListUtils.partition(list, 20000); for (List dataFlickerList : partition) { for (DataFlicker data : dataFlickerList) { Instant instant = LocalDateTimeUtil.parse(data.getTimeId(), DatePattern.NORM_DATETIME_PATTERN) .atZone(ZoneId.systemDefault()).toInstant(); diff --git a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataFlucImpl.java b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataFlucImpl.java index 09cdedf..102dd6c 100644 --- a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataFlucImpl.java +++ b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataFlucImpl.java @@ -52,7 +52,7 @@ public class InsertDataFlucImpl implements InsertIDataFluc { @Override public void insertDataFluc(List list) { if(CollUtil.isNotEmpty(list)){ - List> partition = ListUtils.partition(list, 100000); + List> partition = ListUtils.partition(list, 20000); for (List dataFlickerList : partition) { for (DataFluc data : dataFlickerList) { Instant instant = LocalDateTimeUtil.parse(data.getTimeId(), DatePattern.NORM_DATETIME_PATTERN) .atZone(ZoneId.systemDefault()).toInstant(); diff --git a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmRateIImpl.java b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmRateIImpl.java index a6ebbad..bf2b83d 100644 --- a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmRateIImpl.java +++ b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmRateIImpl.java @@ -49,7 +49,7 @@ public class InsertDataHarmRateIImpl implements InsertIDataHarmRateI { @Override public void insertDataHarmrateI(List list) { if(CollUtil.isNotEmpty(list)){ - List> partition = ListUtils.partition(list, 100000); + List> partition = ListUtils.partition(list, 20000); for (List dataFlickerList : partition) { for (DataHarmrateI data : dataFlickerList) { Instant instant = LocalDateTimeUtil.parse(data.getTimeId(), DatePattern.NORM_DATETIME_PATTERN) .atZone(ZoneId.systemDefault()).toInstant(); diff --git a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmRateVImpl.java b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmRateVImpl.java index 1403f8f..33d6e90 100644 --- a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmRateVImpl.java +++ b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmRateVImpl.java @@ -52,7 +52,7 @@ public class InsertDataHarmRateVImpl implements InsertIDataHarmRateV { @Override public void insertDataHarmrateV(List list) { if(CollUtil.isNotEmpty(list)){ - List> partition = ListUtils.partition(list, 100000); + List> partition = ListUtils.partition(list, 20000); for (List dataFlickerList : partition) { for (DataHarmrateV data : dataFlickerList) { Instant instant = LocalDateTimeUtil.parse(data.getTimeId(), DatePattern.NORM_DATETIME_PATTERN) .atZone(ZoneId.systemDefault()).toInstant(); diff --git a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmphasicIImpl.java b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmphasicIImpl.java index a633f4b..d8c804d 100644 --- a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmphasicIImpl.java +++ b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmphasicIImpl.java @@ -55,7 +55,7 @@ public class InsertDataHarmphasicIImpl implements InsertIDataHarmphasicI { @Override public void insertDataHarmphasicI(List list) { if(CollUtil.isNotEmpty(list)){ - List> partition = ListUtils.partition(list, 100000); + List> partition = ListUtils.partition(list, 20000); for (List dataFlickerList : partition) { for (DataHarmphasicI data : dataFlickerList) { Instant instant = LocalDateTimeUtil.parse(data.getTimeId(), DatePattern.NORM_DATETIME_PATTERN) .atZone(ZoneId.systemDefault()).toInstant(); diff --git a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmphasicVImpl.java b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmphasicVImpl.java index 660c3b3..c6bf042 100644 --- a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmphasicVImpl.java +++ b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmphasicVImpl.java @@ -54,7 +54,7 @@ public class InsertDataHarmphasicVImpl implements InsertIDataHarmphasicV { @Override public void insertDataHarmphasicV(List list) { if(CollUtil.isNotEmpty(list)){ - List> partition = ListUtils.partition(list, 100000); + List> partition = ListUtils.partition(list, 20000); for (List dataFlickerList : partition) { for (DataHarmphasicV data : dataFlickerList) { Instant instant = LocalDateTimeUtil.parse(data.getTimeId(), DatePattern.NORM_DATETIME_PATTERN) .atZone(ZoneId.systemDefault()).toInstant(); diff --git a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmpowerPImpl.java b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmpowerPImpl.java index cffb1d8..838cc40 100644 --- a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmpowerPImpl.java +++ b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmpowerPImpl.java @@ -57,7 +57,7 @@ public class InsertDataHarmpowerPImpl implements InsertIDataHarmpowerP { @Override public void insertDataHarmpowerP(List list) { if(CollUtil.isNotEmpty(list)){ - List> partition = ListUtils.partition(list, 100000); + List> partition = ListUtils.partition(list, 20000); for (List dataFlickerList : partition) { for (DataHarmpowerP data : dataFlickerList) { Instant instant = LocalDateTimeUtil.parse(data.getTimeId(), DatePattern.NORM_DATETIME_PATTERN) .atZone(ZoneId.systemDefault()).toInstant(); diff --git a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmpowerQImpl.java b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmpowerQImpl.java index 3c76c90..89ed7a1 100644 --- a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmpowerQImpl.java +++ b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmpowerQImpl.java @@ -54,7 +54,7 @@ public class InsertDataHarmpowerQImpl implements InsertIDataHarmpowerQ { @Override public void insertDataHarmpowerQ(List list) { if(CollUtil.isNotEmpty(list)){ - List> partition = ListUtils.partition(list, 100000); + List> partition = ListUtils.partition(list, 20000); for (List dataFlickerList : partition) { for (DataHarmpowerQ data : dataFlickerList) { Instant instant = LocalDateTimeUtil.parse(data.getTimeId(), DatePattern.NORM_DATETIME_PATTERN) .atZone(ZoneId.systemDefault()).toInstant(); diff --git a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmpowerSImpl.java b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmpowerSImpl.java index cdad7e0..7e6f982 100644 --- a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmpowerSImpl.java +++ b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataHarmpowerSImpl.java @@ -54,7 +54,7 @@ public class InsertDataHarmpowerSImpl implements InsertIDataHarmpowerS { @Override public void insertDataHarmpowerS(List list) { if(CollUtil.isNotEmpty(list)){ - List> partition = ListUtils.partition(list, 100000); + List> partition = ListUtils.partition(list, 20000); for (List dataFlickerList : partition) { for (DataHarmpowerS data : dataFlickerList) { Instant instant = LocalDateTimeUtil.parse(data.getTimeId(), DatePattern.NORM_DATETIME_PATTERN) .atZone(ZoneId.systemDefault()).toInstant(); diff --git a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataIImpl.java b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataIImpl.java index b6df087..49cfcd0 100644 --- a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataIImpl.java +++ b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataIImpl.java @@ -63,7 +63,7 @@ public class InsertDataIImpl implements InsertIDataI { @Override public void insertDataI(List list) { if(CollUtil.isNotEmpty(list)){ - List> partition = ListUtils.partition(list, 100000); + List> partition = ListUtils.partition(list, 20000); for (List dataFlickerList : partition) { for (DataI data : dataFlickerList) { Instant instant = LocalDateTimeUtil.parse(data.getTimeId(), DatePattern.NORM_DATETIME_PATTERN) .atZone(ZoneId.systemDefault()).toInstant(); diff --git a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataInharmIImpl.java b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataInharmIImpl.java index 5f51c3f..ab4fedb 100644 --- a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataInharmIImpl.java +++ b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataInharmIImpl.java @@ -53,7 +53,7 @@ public class InsertDataInharmIImpl implements InsertIDataInharmI { @Override public void insertDataInharmI(List list) { if(CollUtil.isNotEmpty(list)){ - List> partition = ListUtils.partition(list, 100000); + List> partition = ListUtils.partition(list, 20000); for (List dataFlickerList : partition) { for (DataInharmI data : dataFlickerList) { Instant instant = LocalDateTimeUtil.parse(data.getTimeId(), DatePattern.NORM_DATETIME_PATTERN) .atZone(ZoneId.systemDefault()).toInstant(); diff --git a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataInharmVImpl.java b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataInharmVImpl.java index fbc171a..12cccd6 100644 --- a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataInharmVImpl.java +++ b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataInharmVImpl.java @@ -56,7 +56,7 @@ public class InsertDataInharmVImpl implements InsertIDataInharmV { @Override public void insertDataInharmV(List list) { if(CollUtil.isNotEmpty(list)){ - List> partition = ListUtils.partition(list, 100000); + List> partition = ListUtils.partition(list, 20000); for (List dataFlickerList : partition) { for (DataInharmV data : dataFlickerList) { Instant instant = LocalDateTimeUtil.parse(data.getTimeId(), DatePattern.NORM_DATETIME_PATTERN) .atZone(ZoneId.systemDefault()).toInstant(); diff --git a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataPltImpl.java b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataPltImpl.java index 0414bcf..a54d60c 100644 --- a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataPltImpl.java +++ b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataPltImpl.java @@ -50,7 +50,7 @@ public class InsertDataPltImpl implements InsertIDataPlt { @Override public void insertDataPlt(List list) { if(CollUtil.isNotEmpty(list)){ - List> partition = ListUtils.partition(list, 100000); + List> partition = ListUtils.partition(list, 20000); for (List dataFlickerList : partition) { for (DataPlt data : dataFlickerList) { Instant instant = LocalDateTimeUtil.parse(data.getTimeId(), DatePattern.NORM_DATETIME_PATTERN) .atZone(ZoneId.systemDefault()).toInstant(); diff --git a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataVImpl.java b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataVImpl.java index 0fe3009..64ad288 100644 --- a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataVImpl.java +++ b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertDataVImpl.java @@ -98,7 +98,7 @@ public class InsertDataVImpl implements InsertIDataV { @Override public void insertDataV(List list) { if(CollUtil.isNotEmpty(list)){ - List> partition = ListUtils.partition(list, 100000); + List> partition = ListUtils.partition(list, 20000); for (List dataFlickerList : partition) { for (DataV dataV : dataFlickerList) { Instant instant = LocalDateTimeUtil.parse(dataV.getTimeId(), DatePattern.NORM_DATETIME_PATTERN) .atZone(ZoneId.systemDefault()).toInstant(); diff --git a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertPqsCommunicateImpl.java b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertPqsCommunicateImpl.java index 6f80292..d97cf61 100644 --- a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertPqsCommunicateImpl.java +++ b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/InsertPqsCommunicateImpl.java @@ -48,7 +48,7 @@ public class InsertPqsCommunicateImpl implements InsertIPqsCommunicate { @Override public void insertPqsCommunicate(List list) { if(CollUtil.isNotEmpty(list)){ - List> partition = ListUtils.partition(list, 100000); + List> partition = ListUtils.partition(list, 20000); for (List dataFlickerList : partition) { for (PqsCommunicate data : dataFlickerList) { Instant instant = LocalDateTimeUtil.parse(data.getTimeId(), DatePattern.NORM_DATETIME_PATTERN) .atZone(ZoneId.systemDefault()).toInstant(); diff --git a/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/MigrationReadBootApplication.java b/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/MigrationReadBootApplication.java index 8f51eb8..c35a369 100644 --- a/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/MigrationReadBootApplication.java +++ b/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/MigrationReadBootApplication.java @@ -7,6 +7,7 @@ import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.openfeign.EnableFeignClients; import org.springframework.context.annotation.DependsOn; import org.springframework.scheduling.annotation.EnableAsync; +import org.springframework.scheduling.annotation.EnableScheduling; /** @@ -18,6 +19,7 @@ import org.springframework.scheduling.annotation.EnableAsync; @MapperScan("com.njcn.**.mapper") @EnableFeignClients(basePackages = "com.njcn") @SpringBootApplication(scanBasePackages = "com.njcn") +@EnableScheduling public class MigrationReadBootApplication { public static void main(String[] args) { diff --git a/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/config/AsyncInfluxDBConfiguration.java b/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/config/AsyncInfluxDBConfiguration.java new file mode 100644 index 0000000..fd4ad54 --- /dev/null +++ b/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/config/AsyncInfluxDBConfiguration.java @@ -0,0 +1,48 @@ +package com.njcn.migration.read.config; + +import com.njcn.common.config.GeneralInfo; +import lombok.AllArgsConstructor; +import lombok.Data; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import org.springframework.core.annotation.Order; +import org.springframework.scheduling.annotation.EnableAsync; +import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; + +import java.util.concurrent.Executor; +import java.util.concurrent.ThreadPoolExecutor; + +/** + * @author hongawen + * @version 1.0.0 + * @date 2022年03月11日 09:32 + */ +@Data +@Order(100) +@Configuration +@EnableAsync +@AllArgsConstructor +public class AsyncInfluxDBConfiguration { + + private final GeneralInfo generalInfo; + + @Bean("asyncInfluxDBExecutor") + public Executor asyncExecutor() { + ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); + // 核心线程数：线程池创建时候初始化的线程数 + executor.setCorePoolSize(generalInfo.getCorePoolSize()); + // 最大线程数：线程池最大的线程数，只有在缓冲队列满了之后才会申请超过核心线程数的线程 + executor.setMaxPoolSize(generalInfo.getMaxPoolSize()); + // 缓冲队列：用来缓冲执行任务的队列 + executor.setQueueCapacity(generalInfo.getQueueCapacity()); + // 允许线程的空闲时间60秒：当超过了核心线程之外的线程在空闲时间到达之后会被销毁 + executor.setKeepAliveSeconds(generalInfo.getKeepAliveSeconds()); + // 线程池名的前缀：设置好了之后可以方便我们定位处理任务所在的线程池 + executor.setThreadNamePrefix(generalInfo.getMicroServiceName()); + // 缓冲队列满了之后的拒绝策略：由调用线程处理（一般是主线程） + executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); + executor.initialize(); + return executor; + } + +} diff --git a/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/service/impl/MigrationServiceImpl.java b/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/service/impl/MigrationServiceImpl.java index a28f60f..7a4937a 100644 --- a/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/service/impl/MigrationServiceImpl.java +++ b/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/service/impl/MigrationServiceImpl.java @@ -52,7 +52,7 @@ public class MigrationServiceImpl implements MigrationService { @Override - @Async + @Async("asyncInfluxDBExecutor") public void hourseLineDataBacthSysc(LineCountEvaluateParam param) { Map map = TimeUtil.getLineMap(); int size = map.size(); @@ -97,7 +97,7 @@ public class MigrationServiceImpl implements MigrationService { } @Override - @Async + @Async("asyncInfluxDBExecutor") public void hourseDevDataBacthSysc(LineCountEvaluateParam param) { Map map = TimeUtil.getDevMap(); int size = map.size(); @@ -127,6 +127,7 @@ public class MigrationServiceImpl implements MigrationService { } @Override + @Async("asyncInfluxDBExecutor") public void initializeExcel() throws IOException { File file = new File("/usr/local/jar/sj.xlsx"); Map map = TimeUtil.getLineMap(); diff --git a/migration-influxdb/migration-influxdb-read-boot/src/main/resources/bootstrap.yml b/migration-influxdb/migration-influxdb-read-boot/src/main/resources/bootstrap.yml index 7a2e509..6003b5d 100644 --- a/migration-influxdb/migration-influxdb-read-boot/src/main/resources/bootstrap.yml +++ b/migration-influxdb/migration-influxdb-read-boot/src/main/resources/bootstrap.yml @@ -58,6 +58,11 @@ mybatis-plus: #配置sql日志输出 log-impl: org.apache.ibatis.logging.nologging.NoLoggingImpl +threadPool: + corePoolSize: 12 + maxPoolSize: 24 + queueCapacity: 500 + keepAliveSeconds: 60 # type-aliases-package: com.njcn.harmonic.pojo # type-handlers-package: com.njcn.db.handler