From 172de0d4fd67a72efaf895b9b3233a02df645279 Mon Sep 17 00:00:00 2001 From: liulinfei121 <57127515+liulinfei121@users.noreply.github.com> Date: Wed, 7 Sep 2022 15:24:28 +0800 Subject: [PATCH] add Md5UtilTest test case (#677) * add FileUtilTest test case * add Md5UtilTest test case --- .../hippo4j/common/toolkit/Md5UtilTest.java | 50 +++++++++++++++++++ 1 file changed, 50 insertions(+) diff --git a/hippo4j-common/src/test/java/cn/hippo4j/common/toolkit/Md5UtilTest.java b/hippo4j-common/src/test/java/cn/hippo4j/common/toolkit/Md5UtilTest.java index a6944f49..0c9191b1 100644 --- a/hippo4j-common/src/test/java/cn/hippo4j/common/toolkit/Md5UtilTest.java +++ b/hippo4j-common/src/test/java/cn/hippo4j/common/toolkit/Md5UtilTest.java @@ -17,5 +17,55 @@ package cn.hippo4j.common.toolkit; +import cn.hippo4j.common.model.ThreadPoolParameterInfo; +import org.junit.Test; + +import java.io.IOException; +import java.security.NoSuchAlgorithmException; +import java.util.ArrayList; +import java.util.List; + public class Md5UtilTest { + + @Test + public void assertMd5Hex() throws NoSuchAlgorithmException { + String md5 = "3cdefff74dcf7a5d60893865b84b62c8"; + String message = "message-consume"; + Assert.isTrue(md5.equals(Md5Util.md5Hex(message.getBytes()))); + } + + @Test + public void assertMd5Hex2() { + String md5 = "503840dc3af3cdb39749cd099e4dfeff"; + String message = "dynamic-threadpool-example"; + Assert.isTrue(md5.equals(Md5Util.md5Hex(message, "UTF-8"))); + } + + @Test + public void assetEncodeHexString() { + String encodeHexString = "00010f107f80203040506070"; + byte[] bytes = {0, 1, 15, 16, 127, -128, 32, 48, 64, 80, 96, 112}; + Assert.isTrue(encodeHexString.equals(Md5Util.encodeHexString(bytes))); + } + + @Test + public void assetGetTpContentMd5() { + String md5Result = "ef5ea7cb47377fb9fb85a7125e76715d"; + ThreadPoolParameterInfo threadPoolParameterInfo = ThreadPoolParameterInfo.builder().tenantId("prescription") + .itemId("dynamic-threadpool-example").tpId("message-consume").content("描述信息").corePoolSize(1) + .maximumPoolSize(2).queueType(1).capacity(4).keepAliveTime(513).executeTimeOut(null).rejectedType(4) + .isAlarm(1).capacityAlarm(80).livenessAlarm(80).allowCoreThreadTimeOut(1).build(); + Assert.isTrue(md5Result.equals(Md5Util.getTpContentMd5(threadPoolParameterInfo))); + } + + @Test + public void assetCompareMd5ResultString() throws IOException { + Assert.isTrue("".equals(Md5Util.compareMd5ResultString(null))); + String result = "prescription%02dynamic-threadpool-example%02message-consume%01" + + "prescription%02dynamic-threadpool-example%02message-produce%01"; + List changedGroupKeys = new ArrayList<>(2); + changedGroupKeys.add("prescription+dynamic-threadpool-example+message-consume+12"); + changedGroupKeys.add("prescription+dynamic-threadpool-example+message-produce+11"); + Assert.isTrue(result.equals(Md5Util.compareMd5ResultString(changedGroupKeys))); + } }