From 8556d27173eaa8a46b3e27da6a50c6ea2b0f9fa6 Mon Sep 17 00:00:00 2001 From: misworga831 Date: Fri, 26 Jul 2024 10:31:39 +0800 Subject: [PATCH] fix & improvement --- .../cn/lili/buyer/test/cart/OnlineTest.java | 64 ------- .../cn/lili/test/CacheTest/CacheTest.java | 173 ------------------ 2 files changed, 237 deletions(-) delete mode 100644 consumer/src/test/java/cn/lili/buyer/test/cart/OnlineTest.java delete mode 100644 manager-api/src/test/java/cn/lili/test/CacheTest/CacheTest.java diff --git a/consumer/src/test/java/cn/lili/buyer/test/cart/OnlineTest.java b/consumer/src/test/java/cn/lili/buyer/test/cart/OnlineTest.java deleted file mode 100644 index e67101d2..00000000 --- a/consumer/src/test/java/cn/lili/buyer/test/cart/OnlineTest.java +++ /dev/null @@ -1,64 +0,0 @@ -package cn.lili.buyer.test.cart; - -import cn.lili.common.utils.DateUtil; -import cn.lili.timetask.handler.impl.statistics.OnlineMemberStatistics; -import org.junit.jupiter.api.Test; -import org.junit.jupiter.api.extension.ExtendWith; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.boot.test.context.SpringBootTest; -import org.springframework.test.context.junit.jupiter.SpringExtension; - -import java.util.Calendar; -import java.util.Random; - -/** - * 订单库存扣减 - */ -@ExtendWith(SpringExtension.class) -@SpringBootTest -class OnlineTest { - - @Autowired - private OnlineMemberStatistics onlineMemberStatistics; - - //订单支付，库存扣减单元测试 - @Test - void everyHour() { - onlineMemberStatistics.execute(); - } - - //订单支付，库存扣减单元测试 - @Test - void customSetting() { - Calendar calendar = Calendar.getInstance(); - calendar.set(Calendar.MINUTE, 0); - calendar.set(Calendar.SECOND, 0); - calendar.set(Calendar.MILLISECOND, 0); - - calendar.set(Calendar.HOUR_OF_DAY, calendar.get(Calendar.HOUR_OF_DAY) - 48 ); - //循环填充数据 - for (int i = 0; i < 48; i++) { - calendar.set(Calendar.HOUR_OF_DAY, calendar.get(Calendar.HOUR_OF_DAY) + 1); - System.out.println(DateUtil.toString(calendar.getTime(),"")); - Random random = new Random(); - onlineMemberStatistics.execute(calendar.getTime(), random.nextInt(1000000)); - } - } - - public static void main(String[] args) { - - Calendar calendar = Calendar.getInstance(); - calendar.set(Calendar.MINUTE, 0); - calendar.set(Calendar.SECOND, 0); - calendar.set(Calendar.MILLISECOND, 0); - - calendar.set(Calendar.HOUR_OF_DAY, calendar.get(Calendar.HOUR_OF_DAY) - 48 - 1); - //循环填充数据 - for (int i = 0; i < 48; i++) { - calendar.set(Calendar.HOUR_OF_DAY, calendar.get(Calendar.HOUR_OF_DAY) + 1); - System.out.println(calendar.getTime().getTime()); - } - } - - -} diff --git a/manager-api/src/test/java/cn/lili/test/CacheTest/CacheTest.java b/manager-api/src/test/java/cn/lili/test/CacheTest/CacheTest.java deleted file mode 100644 index 38fec97a..00000000 --- a/manager-api/src/test/java/cn/lili/test/CacheTest/CacheTest.java +++ /dev/null @@ -1,173 +0,0 @@ -package cn.lili.test.CacheTest; - -import cn.hutool.json.JSONUtil; -import cn.lili.cache.Cache; -import cn.lili.cache.CachePrefix; -import cn.lili.modules.statistics.util.StatisticsSuffix; -import org.junit.jupiter.api.Assertions; -import org.junit.jupiter.api.Test; -import org.junit.jupiter.api.extension.ExtendWith; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.boot.test.context.SpringBootTest; -import org.springframework.data.redis.core.DefaultTypedTuple; -import org.springframework.test.context.junit.jupiter.SpringExtension; - -import java.util.Date; -import java.util.Random; -import java.util.Set; - -/** - * @author Chopper - * @version v1.0 - * @since v7.0 - * 2021/1/15 16:25 - */ -@ExtendWith(SpringExtension.class) -@SpringBootTest -class CacheTest { - - @Autowired - private Cache cache; - - String KEY = "test1"; - - /** - * 计数器测试 - * - * @throws InterruptedException - */ - @Test - void testCache() throws InterruptedException { - - System.out.println(cache.incr(KEY, 3)); - System.out.println(cache.incr(KEY, 1)); - System.out.println(cache.incr(KEY, 1)); - Thread.sleep(2000); - System.out.println(cache.incr(KEY, 1)); - Thread.sleep(1000); - System.out.println(cache.incr(KEY, 1)); - Thread.sleep(10000); - - System.out.println(cache.incr(KEY, 1)); - - } - - /** - * 缓存中的流量统计数据模拟 - */ - @Test - void pageViewInit() { - String storeUV = "{STORE_UV}_2021-4-12-1376369067769724928"; - String storePV = "{STORE_PV}_2021-4-12-1376369067769724928"; - String UV = "{UV}_2021-4-12"; - String PV = "{PV}_2021-4-12"; - Random random = new Random(); - for (int i = 0; i < 1000; i++) { - //PV - cache.incr(PV, 60 * 60 * 48); - cache.incr(storePV, 60 * 60 * 48); - //店铺UV 统计，则需要对id去重复，所以如下处理 - cache.cumulative(storeUV, "192.168.0.1" + random.nextInt(100)); - //平台UV统计 - cache.cumulative(UV, "192.168.0.1" + random.nextInt(100)); - } - } - - - /** - * 流量单元测试 - *

- * 模拟1000次请求发，查看这块执行时间,单节点性能简单尝试同时还有redis连接池问题，这个只是简单压力模拟 - *

- * 执行结果 - * 1.251 - * 1.167 - * 1.363 - */ - @Test - void testPageViewStatistics() { - Date start = new Date(); - System.out.println(start.getTime()); - for (int i = 0; i < 1000; i++) { - - //PV 统计48小时过期 留下一定时间予以统计累计数据库 - cache.incr(CachePrefix.PV.getPrefix() + StatisticsSuffix.suffix(i / 100 + ""), 60 * 60 * 48); - - //店铺UV 统计，则需要对id去重复，所以如下处理 - cache.cumulative(CachePrefix.UV.getPrefix() + StatisticsSuffix.suffix(i / 100 + "1321312312312312321312"), "192.168.0.1" + i); - - //平台UV统计 - cache.cumulative(CachePrefix.UV.getPrefix() + StatisticsSuffix.suffix(), "192.168.0.1" + i); - } - - Date end = new Date(); - System.out.println(end.getTime()); - System.out.println(end.getTime() - start.getTime()); - } - - @Test - void testZincrby() { - cache.incrementScore("searchHotWord", "Chrome"); - Assertions.assertTrue(true); - } - - @Test - void testReverseRangeWithScores() { - Set searchHotWord = cache.reverseRangeWithScores("searchHotWord", 0, 100); - for (Object o : searchHotWord) { - DefaultTypedTuple str = (DefaultTypedTuple) o; - System.out.println(str.getScore()); - System.out.println(str.getValue()); - System.out.println("----------"); - } - Assertions.assertTrue(true); - } - - - @Test - void scanTests() { - - for (int i = 0; i < 1000000; i++) { - cache.put("scan" + i, i); - } - Date date = new Date(); - System.out.println(JSONUtil.toJsonStr(cache.keys("scan999999*"))); - - System.out.println("100w数据耗时"); - System.out.println(new Date().getTime() - date.getTime()); - - - for (int i = 1000000; i < 5000000; i++) { - cache.put("scan" + i, i); - } - - date = new Date(); - System.out.println(JSONUtil.toJsonStr(cache.keys("scan999999*"))); - System.out.println("600w数据耗时"); - System.out.println(new Date().getTime() - date.getTime()); - - } - - // scan 慢些，但是在缓存更多的情况下，表现更好，虽然用时更久，但是不会阻塞其他读写 - // - //["scan999999"] - //redisTemplate scan 500w数据耗时 - //2985 - //["scan999999"] - //redisTemplate keys 500w数据耗时 - //1073 - @Test - void testKsysVsScan() { - Date date = new Date(); - System.out.println(JSONUtil.toJsonStr(cache.keys("scan999999*"))); - System.out.println("redisTemplate scan 500w数据耗时"); - System.out.println(new Date().getTime() - date.getTime()); - - date = new Date(); - System.out.println(JSONUtil.toJsonStr(cache.keysBlock("scan999999*"))); - System.out.println("redisTemplate keys 500w数据耗时"); - System.out.println(new Date().getTime() - date.getTime()); - - } - -}