学习JDK动态代理

request-test/pom.xml

@@ -28,5 +28,10 @@
             <artifactId>jedis</artifactId>
             <version>4.4.6</version> <!-- 推荐使用稳定版 -->
         </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <scope>provided</scope>
+        </dependency>
     </dependencies>
 </project>

request-test/src/main/java/cn/mayiming/App.java

@@ -1,5 +1,11 @@
 package cn.mayiming;
 
+import cn.mayiming.Properties.UserProperties;
+import cn.mayiming.Serivce.UserSerivce;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.ApplicationContext;
 import redis.clients.jedis.Jedis;
 
 import java.net.URI;
@@ -7,9 +13,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.*;
-import java.util.List;
-import java.util.Set;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
@@ -18,99 +22,14 @@ import java.util.concurrent.TimeUnit;
  * Hello world!
  *
  */
+@SpringBootApplication
 public class App 
 {
 
     public static void main(String[] args) {
-        Jedis jedis = null;
+        ApplicationContext context = SpringApplication.run(App.class, args);
-        try {
+        UserSerivce userSerivce = context.getBean(UserSerivce.class);
-            // 建立 Redis 连接
+        System.out.println("UserSerivce 对象：" + userSerivce);
-            jedis = new Jedis("localhost", 6379);
+        userSerivce.getUser(); // 输出：mayiming
-            // 可选：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<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 连接已关闭");
-            }
-        }
     }
 }

request-test/src/main/java/cn/mayiming/Properties/UserProperties.java

@@ -0,0 +1,14 @@
+package cn.mayiming.Properties;
+
+
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.stereotype.Component;
+
+@ConfigurationProperties(prefix = "user")
+@Component
+@Data
+public class UserProperties {
+    private String name;
+}

request-test/src/main/java/cn/mayiming/Serivce/UserSerivce.java

@@ -0,0 +1,16 @@
+package cn.mayiming.Serivce;
+
+
+import cn.mayiming.Properties.UserProperties;
+import org.apache.catalina.User;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+public class UserSerivce {
+    @Autowired
+    UserProperties userProperties;
+    public void  getUser() {
+        System.out.println(userProperties.getName());
+    }
+}

request-test/src/main/resources/properties.yml

@@ -0,0 +1,2 @@
+user:
+  name: mayiming