From c2b42476bc290fa4b06236027baa9f99724ad4d7 Mon Sep 17 00:00:00 2001 From: JACKYMYPERSON Date: Mon, 9 Mar 2026 16:35:54 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AD=A6=E4=B9=A0=E8=BF=AD=E4=BB=A3=E5=99=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/cn/mayiming/App.java | 100 ++---------------- 1 file changed, 8 insertions(+), 92 deletions(-) diff --git a/request-test/src/main/java/cn/mayiming/App.java b/request-test/src/main/java/cn/mayiming/App.java index c57914e..e91b0f5 100644 --- a/request-test/src/main/java/cn/mayiming/App.java +++ b/request-test/src/main/java/cn/mayiming/App.java @@ -7,9 +7,7 @@ import java.net.http.HttpClient; import java.net.http.HttpRequest; import java.net.http.HttpResponse; import java.time.Duration; -import java.util.HashMap; -import java.util.List; -import java.util.Set; +import java.util.*; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; @@ -22,95 +20,13 @@ public class App { public static void main(String[] args) { - Jedis jedis = null; - try { - // 建立 Redis 连接 - jedis = new Jedis("localhost", 6379); - // 可选：Redis 密码认证 - // jedis.auth("你的Redis密码"); - - // ==================== ZSet 结构核心操作 ==================== - // ZSet 特点：有序、元素唯一（member 不重复）、每个元素关联一个分数（score），按score排序 - // 场景1：商品销量排行榜（按销量从高到低排序） - String salesRankKey = "rank:product:sales"; // 商品销量排行榜 - - // 方式1：添加元素（member=商品ID，score=销量，重复添加会更新score） - jedis.zadd(salesRankKey, 500, "product1001"); // 商品1001销量500 - jedis.zadd(salesRankKey, 800, "product1002"); // 商品1002销量800 - jedis.zadd(salesRankKey, 1200, "product1003");// 商品1003销量1200 - jedis.zadd(salesRankKey, 800, "product1002");// 重复添加，仅更新score（这里score不变） - System.out.println("商品销量排行榜初始化完成"); - - // 方式2：按score升序/降序查询（核心！排行榜核心操作） - // zrange：升序查询（0=第1名，-1=最后1名），WITHSCORES 显示分数 - Set ascRank = (Set) jedis.zrange(salesRankKey, 0, -1); - System.out.println("\n销量升序排行榜（商品ID:销量）：" + ascRank); - - // zrevrange：降序查询（最常用，排行榜从高到低） - Set descRank = (Set) jedis.zrevrange(salesRankKey, 0, -1); - System.out.println("销量降序排行榜（商品ID:销量）：" + descRank); - - // 方式3：查询指定元素的分数（查看单个商品销量） - Double sales1002 = jedis.zscore(salesRankKey, "product1002"); - System.out.println("商品1002的销量：" + sales1002); - - // 方式4：更新元素分数（销量增加，比如商品1001新增200单） - jedis.zincrby(salesRankKey, 200, "product1001"); // score += 200 - System.out.println("商品1001销量+200后：" + jedis.zscore(salesRankKey, "product1001")); - - // 方式5：查询元素排名（降序，从0开始计数） - Long rank1003 = jedis.zrevrank(salesRankKey, "product1003"); - System.out.println("商品1003的销量排名（第1名=0）：" + (rank1003 + 1) + "名"); - - // 方式6：按分数范围查询（比如销量≥800的商品） - Set highSales = (Set) jedis.zrangeByScore(salesRankKey, 800, Double.MAX_VALUE); - System.out.println("销量≥800的商品：" + highSales); - - // ==================== 场景2：延迟队列（按时间戳排序） ==================== - String delayQueueKey = "queue:delay:order"; // 订单延迟队列 - - // 核心逻辑：score=执行时间戳（比如10秒后执行、30秒后执行） - long now = System.currentTimeMillis() / 1000; // 当前时间戳（秒） - jedis.zadd(delayQueueKey, now + 10, "订单1001：10秒后自动取消"); // 10秒后处理 - jedis.zadd(delayQueueKey, now + 30, "订单1002：30秒后自动确认收货"); // 30秒后处理 - System.out.println("\n延迟队列初始化完成，当前时间戳：" + now); - - // 方式7：获取需要执行的任务（score ≤ 当前时间戳的元素） - Set needExecute = (Set) jedis.zrangeByScore(delayQueueKey, 0, now, 0, 10); // 取前10个待执行任务 - System.out.println("当前需要执行的延迟任务（无）：" + needExecute); - - // 模拟10秒后（仅演示逻辑，实际需定时轮询） - long after10s = now + 10; - needExecute = (Set) jedis.zrangeByScore(delayQueueKey, 0, after10s, 0, 10); - System.out.println("10秒后需要执行的延迟任务：" + needExecute); - - // 执行任务后删除（避免重复执行） - for (String task : needExecute) { - jedis.zrem(delayQueueKey, task); - System.out.println("执行并删除延迟任务：" + task); - } - - // ==================== 场景3：带权重的用户推荐（按权重排序） ==================== - String recommendKey = "recommend:user:1001"; // 给用户1001的推荐列表 - - // score=推荐权重（越高越优先） - jedis.zadd(recommendKey, 95, "商品A（高转化）"); - jedis.zadd(recommendKey, 80, "商品B（高浏览）"); - jedis.zadd(recommendKey, 60, "商品C（相关推荐）"); - System.out.println("\n用户1001的推荐列表（按权重降序）："); - - // 取TOP2推荐商品 - Set top2Recommend = (Set) jedis.zrevrange(recommendKey, 0, 1); - System.out.println("TOP2推荐：" + top2Recommend); - - } catch (Exception e) { - e.printStackTrace(); - } finally { - // 关闭连接 - if (jedis != null) { - jedis.close(); - System.out.println("\nRedis 连接已关闭"); - } + ArrayList fruitList = new ArrayList<>(); + fruitList.add("苹果"); + fruitList.add("香蕉"); + fruitList.add("橙子"); + Iterator iterator = fruitList.iterator(); + while (iterator.hasNext()) { + System.out.println(iterator.next()); } } }