学习迭代器
This commit is contained in:
@@ -7,9 +7,7 @@ import java.net.http.HttpClient;
|
|||||||
import java.net.http.HttpRequest;
|
import java.net.http.HttpRequest;
|
||||||
import java.net.http.HttpResponse;
|
import java.net.http.HttpResponse;
|
||||||
import java.time.Duration;
|
import java.time.Duration;
|
||||||
import java.util.HashMap;
|
import java.util.*;
|
||||||
import java.util.List;
|
|
||||||
import java.util.Set;
|
|
||||||
import java.util.concurrent.ExecutorService;
|
import java.util.concurrent.ExecutorService;
|
||||||
import java.util.concurrent.Executors;
|
import java.util.concurrent.Executors;
|
||||||
import java.util.concurrent.TimeUnit;
|
import java.util.concurrent.TimeUnit;
|
||||||
@@ -22,95 +20,13 @@ public class App
|
|||||||
{
|
{
|
||||||
|
|
||||||
public static void main(String[] args) {
|
public static void main(String[] args) {
|
||||||
Jedis jedis = null;
|
ArrayList<String> fruitList = new ArrayList<>();
|
||||||
try {
|
fruitList.add("苹果");
|
||||||
// 建立 Redis 连接
|
fruitList.add("香蕉");
|
||||||
jedis = new Jedis("localhost", 6379);
|
fruitList.add("橙子");
|
||||||
// 可选:Redis 密码认证
|
Iterator<String> iterator = fruitList.iterator();
|
||||||
// jedis.auth("你的Redis密码");
|
while (iterator.hasNext()) {
|
||||||
|
System.out.println(iterator.next());
|
||||||
// ==================== 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<String> ascRank = (Set<String>) jedis.zrange(salesRankKey, 0, -1);
|
|
||||||
System.out.println("\n销量升序排行榜(商品ID:销量):" + ascRank);
|
|
||||||
|
|
||||||
// zrevrange:降序查询(最常用,排行榜从高到低)
|
|
||||||
Set<String> descRank = (Set<String>) 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<String> highSales = (Set<String>) 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<String> needExecute = (Set<String>) jedis.zrangeByScore(delayQueueKey, 0, now, 0, 10); // 取前10个待执行任务
|
|
||||||
System.out.println("当前需要执行的延迟任务(无):" + needExecute);
|
|
||||||
|
|
||||||
// 模拟10秒后(仅演示逻辑,实际需定时轮询)
|
|
||||||
long after10s = now + 10;
|
|
||||||
needExecute = (Set<String>) 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<String> top2Recommend = (Set<String>) 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 连接已关闭");
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user