fix : add MemoryUtil for get memory info

hippo4j-adapter/hippo4j-adapter-web/src/main/java/cn/hippo4j/adapter/web/WebThreadPoolRunStateHandler.java

@@ -19,13 +19,11 @@ package cn.hippo4j.adapter.web;
 
 import cn.hippo4j.common.model.ThreadPoolRunStateInfo;
 import cn.hippo4j.common.toolkit.ByteConvertUtil;
+import cn.hippo4j.common.toolkit.MemoryUtil;
+import cn.hippo4j.common.toolkit.StringUtil;
 import cn.hippo4j.core.executor.state.AbstractThreadPoolRuntime;
 import lombok.extern.slf4j.Slf4j;
 
-import java.lang.management.ManagementFactory;
-import java.lang.management.MemoryMXBean;
-import java.lang.management.MemoryUsage;
-
 /**
  * Web thread pool run state handler.
  */
@@ -34,16 +32,13 @@ public class WebThreadPoolRunStateHandler extends AbstractThreadPoolRuntime {
 
     @Override
     public ThreadPoolRunStateInfo supplement(ThreadPoolRunStateInfo poolRunStateInfo) {
-        MemoryMXBean memoryMXBean = ManagementFactory.getMemoryMXBean();
+        long used = MemoryUtil.heapMemoryUsed();
-        MemoryUsage heapMemoryUsage = memoryMXBean.getHeapMemoryUsage();
+        long max = MemoryUtil.heapMemoryMax();
-        long used = heapMemoryUsage.getUsed();
+        String memoryProportion = StringUtil.newBuilder(
-        long max = heapMemoryUsage.getMax();
+                "已分配: ",
-        String memoryProportion = new StringBuilder()
+                ByteConvertUtil.getPrintSize(used),
-                .append("已分配: ")
+                " / 最大可用: ",
-                .append(ByteConvertUtil.getPrintSize(used))
+                ByteConvertUtil.getPrintSize(max));
-                .append(" / 最大可用: ")
-                .append(ByteConvertUtil.getPrintSize(max))
-                .toString();
         poolRunStateInfo.setCurrentLoad(poolRunStateInfo.getCurrentLoad() + "%");
         poolRunStateInfo.setPeakLoad(poolRunStateInfo.getPeakLoad() + "%");
         poolRunStateInfo.setMemoryProportion(memoryProportion);

hippo4j-common/src/main/java/cn/hippo4j/common/toolkit/MemoryUtil.java

@@ -0,0 +1,80 @@
+package cn.hippo4j.common.toolkit;
+
+import lombok.AccessLevel;
+import lombok.NoArgsConstructor;
+
+import java.lang.management.ManagementFactory;
+import java.lang.management.MemoryMXBean;
+import java.lang.management.MemoryUsage;
+
+/**
+ * memory util<br>
+ * the obtained information is not invalid, after a long wait, obtain it again
+ *
+ * @author liuwenhao
+ */
+@NoArgsConstructor(access = AccessLevel.PRIVATE)
+public class MemoryUtil {
+
+    static MemoryMXBean memoryMXBean = ManagementFactory.getMemoryMXBean();
+    static MemoryUsage heapMemoryUsage = memoryMXBean.getHeapMemoryUsage();
+    static MemoryUsage noHeapMemoryUsage = memoryMXBean.getNonHeapMemoryUsage();
+
+
+    /**
+     * get used memory in heap
+     *
+     * @return long bytes
+     */
+    public static long heapMemoryUsed() {
+        return heapMemoryUsage.getUsed();
+    }
+
+    /**
+     * get max memory in heap
+     *
+     * @return long bytes
+     */
+    public static long heapMemoryMax() {
+        return heapMemoryUsage.getMax();
+    }
+
+
+    /**
+     * get free memory in heap
+     *
+     * @return long bytes
+     */
+    public static long heapMemoryFree() {
+        return Math.subtractExact(heapMemoryMax(), heapMemoryUsed());
+    }
+
+    /**
+     * get used memory in no-heap
+     *
+     * @return long bytes
+     */
+    public static long noHeapMemoryUsed() {
+        return noHeapMemoryUsage.getUsed();
+    }
+
+    /**
+     * get max memory in no-heap
+     *
+     * @return long bytes
+     */
+    public static long noHeapMemoryMax() {
+        return noHeapMemoryUsage.getMax();
+    }
+
+
+    /**
+     * get free memory in no-heap
+     *
+     * @return long bytes
+     */
+    public static long noHeapMemoryFree() {
+        return Math.subtractExact(noHeapMemoryMax(), noHeapMemoryUsed());
+    }
+
+}

hippo4j-common/src/test/java/cn/hippo4j/common/toolkit/MemoryUtilTest.java

@@ -0,0 +1,44 @@
+package cn.hippo4j.common.toolkit;
+
+
+import org.junit.Assert;
+import org.junit.Test;
+
+public class MemoryUtilTest {
+
+    @Test
+    public void heapMemoryUsed() {
+        long memoryUsed = MemoryUtil.heapMemoryUsed();
+        Assert.assertNotEquals(0, memoryUsed);
+    }
+
+    @Test
+    public void heapMemoryMax() {
+        long memoryUsed = MemoryUtil.heapMemoryMax();
+        Assert.assertNotEquals(0, memoryUsed);
+    }
+
+    @Test
+    public void heapMemoryFree() {
+        long memoryUsed = MemoryUtil.heapMemoryFree();
+        Assert.assertNotEquals(0, memoryUsed);
+    }
+
+    @Test
+    public void noHeapMemoryUsed() {
+        long memoryUsed = MemoryUtil.noHeapMemoryUsed();
+        Assert.assertNotEquals(0, memoryUsed);
+    }
+
+    @Test
+    public void noHeapMemoryMax() {
+        long memoryUsed = MemoryUtil.noHeapMemoryMax();
+        Assert.assertNotEquals(0, memoryUsed);
+    }
+
+    @Test
+    public void noHeapMemoryFree() {
+        long memoryUsed = MemoryUtil.noHeapMemoryFree();
+        Assert.assertNotEquals(0, memoryUsed);
+    }
+}

hippo4j-common/src/test/java/cn/hippo4j/common/toolkit/http/HttpUtilsTest.java

@@ -72,14 +72,14 @@ public class HttpUtilsTest {
         Assert.assertNotNull(data);
     }
 
-    @Test
+    @Test(expected = SocketTimeoutException.class)
     public void testRestApiPostTimeout() {
         String loginUrl = postUrl + "auth/login";
         LoginInfo loginInfo = new LoginInfo();
         loginInfo.setPassword("hippo4j");
         loginInfo.setUsername("hippo4j");
         loginInfo.setRememberMe(1);
-        Assert.assertThrows(SocketTimeoutException.class, () -> HttpUtil.post(loginUrl, loginInfo, 1, Result.class));
+        HttpUtil.post(loginUrl, loginInfo, 1, Result.class);
     }
 
     @Test

hippo4j-core/src/main/java/cn/hippo4j/core/executor/state/ThreadPoolRunStateHandler.java

@@ -21,6 +21,8 @@ import cn.hippo4j.common.model.ManyThreadPoolRunStateInfo;
 import cn.hippo4j.common.model.ThreadPoolRunStateInfo;
 import cn.hippo4j.common.toolkit.BeanUtil;
 import cn.hippo4j.common.toolkit.ByteConvertUtil;
+import cn.hippo4j.common.toolkit.MemoryUtil;
+import cn.hippo4j.common.toolkit.StringUtil;
 import cn.hippo4j.core.executor.DynamicThreadPoolExecutor;
 import cn.hippo4j.core.executor.DynamicThreadPoolWrapper;
 import cn.hippo4j.core.executor.manage.GlobalThreadPoolManage;
@@ -30,9 +32,6 @@ import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.core.env.ConfigurableEnvironment;
 
-import java.lang.management.ManagementFactory;
-import java.lang.management.MemoryMXBean;
-import java.lang.management.MemoryUsage;
 import java.util.concurrent.ThreadPoolExecutor;
 
 import static cn.hippo4j.core.toolkit.IdentifyUtil.CLIENT_IDENTIFICATION_VALUE;
@@ -50,16 +49,13 @@ public class ThreadPoolRunStateHandler extends AbstractThreadPoolRuntime {
 
     @Override
     public ThreadPoolRunStateInfo supplement(ThreadPoolRunStateInfo poolRunStateInfo) {
-        MemoryMXBean memoryMXBean = ManagementFactory.getMemoryMXBean();
+        long used = MemoryUtil.heapMemoryUsed();
-        MemoryUsage heapMemoryUsage = memoryMXBean.getHeapMemoryUsage();
+        long max = MemoryUtil.heapMemoryMax();
-        long used = heapMemoryUsage.getUsed();
+        String memoryProportion = StringUtil.newBuilder(
-        long max = heapMemoryUsage.getMax();
+                "已分配: ",
-        String memoryProportion = new StringBuilder()
+                ByteConvertUtil.getPrintSize(used),
-                .append("已分配: ")
+                " / 最大可用: ",
-                .append(ByteConvertUtil.getPrintSize(used))
+                ByteConvertUtil.getPrintSize(max));
-                .append(" / 最大可用: ")
-                .append(ByteConvertUtil.getPrintSize(max))
-                .toString();
         poolRunStateInfo.setCurrentLoad(poolRunStateInfo.getCurrentLoad() + "%");
         poolRunStateInfo.setPeakLoad(poolRunStateInfo.getPeakLoad() + "%");
         String ipAddress = hippo4JInetUtils.findFirstNonLoopBackHostInfo().getIpAddress();