From 3b62feefd61e5da01e97016e64199553c40aff54 Mon Sep 17 00:00:00 2001
From: chendaofei <857448963@qq.com>
Date: Thu, 3 Apr 2025 11:41:51 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95=E7=AE=97=E6=B3=95=E4=BD=BF?=
 =?UTF-8?q?=E7=94=A8=E5=86=85=E5=AD=98=E4=B8=B4=E6=97=B6=E6=8F=90=E4=BA=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/influxdb/InfluxdbDataVImpl.java      | 19 ++++++++++++++++++-
 1 file changed, 18 insertions(+), 1 deletion(-)

diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataVImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataVImpl.java
index 9f0b987..1e2f3a5 100644
--- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataVImpl.java
+++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/influxdb/InfluxdbDataVImpl.java
@@ -120,6 +120,23 @@ public class InfluxdbDataVImpl extends MppServiceImpl<RStatDataVRelationMapper,
 
     @Override
     public List<DataVDto> getRawData(LineCountEvaluateParam lineParam) {
+
+        Runtime runtime = Runtime.getRuntime();
+        // 获取 JVM 最大可用内存（以字节为单位）
+        long maxMemory = runtime.maxMemory();
+        // 获取 JVM 当前已分配的内存（以字节为单位）
+        long totalMemory = runtime.totalMemory();
+        // 获取 JVM 当前空闲内存（以字节为单位）
+        long freeMemory = runtime.freeMemory();
+        // 计算已使用的内存
+        long usedMemory = totalMemory - freeMemory;
+
+        System.out.println("最大可用内存: " + maxMemory / (1024 * 1024) + " MB");
+        System.out.println("当前已分配的内存: " + totalMemory / (1024 * 1024) + " MB");
+        System.out.println("当前空闲内存: " + freeMemory / (1024 * 1024) + " MB");
+        System.out.println("已使用的内存: " + usedMemory / (1024 * 1024) + " MB");
+        System.out.println("dataprocess第一次分析结束-----------------------------------------");
+
         List<DataVDto> result = new ArrayList<>();
         List<DataV> list = getMinuteDataV(lineParam);
         list.forEach(item -> {
@@ -434,7 +451,7 @@ public class InfluxdbDataVImpl extends MppServiceImpl<RStatDataVRelationMapper,
         System.out.println("当前已分配的内存: " + totalMemory / (1024 * 1024) + " MB");
         System.out.println("当前空闲内存: " + freeMemory / (1024 * 1024) + " MB");
         System.out.println("已使用的内存: " + usedMemory / (1024 * 1024) + " MB");
-        System.out.println("第二次分析结束-----------------------------------------");
+        System.out.println("dataprocess第二次分析结束-----------------------------------------");
 
         if (CollUtil.isNotEmpty(list)) {
             Map<String, List<DataV>> lineMap = list.stream().collect(Collectors.groupingBy(DataV::getLineId));