From ba6b508a44cb1f0730c6a27a5d73b8d2ae8f1d4b Mon Sep 17 00:00:00 2001 From: puzhibing <393733352@qq.com> Date: 星期二, 19 八月 2025 18:43:47 +0800 Subject: [PATCH] Merge branch 'master' of http://120.76.84.145:10101/gitblit/r/java/QYTDriving --- user/guns-admin/src/main/java/com/supersavedriving/user/modular/system/util/RedisUtil.java | 53 ++++++++++++++++++++++++++++++++++++++++++++--------- 1 files changed, 44 insertions(+), 9 deletions(-) diff --git a/user/guns-admin/src/main/java/com/supersavedriving/user/modular/system/util/RedisUtil.java b/user/guns-admin/src/main/java/com/supersavedriving/user/modular/system/util/RedisUtil.java index f5b5231..03f7892 100644 --- a/user/guns-admin/src/main/java/com/supersavedriving/user/modular/system/util/RedisUtil.java +++ b/user/guns-admin/src/main/java/com/supersavedriving/user/modular/system/util/RedisUtil.java @@ -1,17 +1,10 @@ package com.supersavedriving.user.modular.system.util; -import com.supersavedriving.user.core.util.ToolUtil; -import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Component; -import org.springframework.util.StringUtils; -import redis.clients.jedis.Jedis; -import redis.clients.jedis.JedisPool; -import redis.clients.jedis.Pipeline; import javax.annotation.Resource; -import java.io.IOException; -import java.util.*; +import java.util.UUID; import java.util.concurrent.TimeUnit; @@ -103,7 +96,37 @@ int num1 = 1; while (num1 <= 10){ try { - Thread.sleep(3000);//等待3秒 + Thread.sleep(1000); + } catch (InterruptedException e) { + e.printStackTrace(); + } + b = lock(5); + if(b){ + return true; + }else{ + num1++; + } + } + return false; + } + return b; + }catch (Exception e){ + e.printStackTrace(); + }finally { + unlock(); + } + return false; + } + + + public boolean lock(String key){ + try { + boolean b = lock(key,5); + if(!b){ + int num1 = 1; + while (num1 <= 10){ + try { + Thread.sleep(1000);//等待1秒 } catch (InterruptedException e) { e.printStackTrace(); } @@ -130,6 +153,18 @@ * @param time * @return */ + public boolean lock(String key, int time){ + String uuid = UUID.randomUUID().toString(); + return lock(key, uuid, time); + } + + + + /** + * 获取redis锁 + * @param time + * @return + */ public boolean lock(int time){ String uuid = UUID.randomUUID().toString(); return lock("redis", uuid, time); -- Gitblit v1.7.1