From 449e4e9df08162b1e7e04ac0d4e05a1387298171 Mon Sep 17 00:00:00 2001 From: Junjie <fallin.jie@qq.com> Date: 星期二, 08 七月 2025 16:48:16 +0800 Subject: [PATCH] # --- src/main/java/com/zy/common/utils/RedisUtil.java | 22 ++++++++++++++++++++++ 1 files changed, 22 insertions(+), 0 deletions(-) diff --git a/src/main/java/com/zy/common/utils/RedisUtil.java b/src/main/java/com/zy/common/utils/RedisUtil.java index 95da6dc..b97506c 100644 --- a/src/main/java/com/zy/common/utils/RedisUtil.java +++ b/src/main/java/com/zy/common/utils/RedisUtil.java @@ -1,6 +1,7 @@ package com.zy.common.utils; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.redis.core.RedisCallback; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.stereotype.Component; @@ -24,6 +25,9 @@ @Autowired private RedisTemplate redisTemplate; + + @Autowired + private StringRedisTemplate stringRedisTemplate; public RedisUtil(RedisTemplate redisTemplate) { this.redisTemplate = redisTemplate; @@ -91,6 +95,11 @@ //============================ String ============================= + public Set<String> searchKeys(String key) { + Set<String> keys = redisTemplate.keys(key + "*"); + return keys; + } + /** * 鏅�氱紦瀛樿幏鍙� * @@ -126,6 +135,18 @@ public boolean set(String key, Object value) { try { redisTemplate.opsForValue().set(key, value); + redisTemplate.execute((RedisCallback<Void>) connection -> null); + long start = System.currentTimeMillis(); + while (System.currentTimeMillis() - start < 10000) {//鏈夋晥鏈�10s + Object o = redisTemplate.opsForValue().get(key); + if (o == null) { + continue; + } + + if (o.equals(value)) { + break; + } + } return true; } catch (Exception e) { e.printStackTrace(); @@ -148,6 +169,7 @@ } else { set(key, value); } + redisTemplate.execute((RedisCallback<Void>) connection -> null); return true; } catch (Exception e) { e.printStackTrace(); -- Gitblit v1.9.1