SpringBoot集成redis實現分佈式鎖的示例代碼
1、準備
使用redis實現分佈式鎖,需要用的setnx(),所以需要集成Jedis
需要引入jar,jar最好和redis的jar版本對應上,不然會出現版本沖突,使用的時候會報異常redis.clients.jedis.Jedis.set(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;I)Ljava/lang/String;
我使用的redis版本是2.3.0,Jedis使用的是3.3.0
<dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>3.3.0</version> </dependency>
2、配置參數
spring: redis: host: localhost port: 6379 password: root timeout: 5000 # Redis數據庫索引(默認為0) database: 0 # 連接池最大連接數(使用負值表示沒有限制) jedis: pool: # 連接池最大連接數(使用負值表示沒有限制) max-active: 8 # 連接池最大阻塞等待時間(使用負值表示沒有限制) max-wait: -1 # 連接池中的最大空閑連接 max-idle: 8 # 連接池中的最小空閑連接 min-idle: 0 # 獲取連接時檢測是否可用 testOnBorrow: true
3、配置JedisPool
import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig; /** * Jedis配置項 * @autho ConnorSong * @date 2021/1/21 9:55 上午 */ @Configuration @Slf4j public class JedisPoolCinfigration { @Bean public JedisPoolConfig jedisPoolConfig(@Value("${spring.redis.jedis.pool.max-active}") int maxActive, @Value("${spring.redis.jedis.pool.max-idle}") int maxIdle, @Value("${spring.redis.jedis.pool.min-idle}") int minIdle, @Value("${spring.redis.jedis.pool.max-wait}") long maxWaitMillis, @Value("${spring.redis.jedis.pool.testOnBorrow}") boolean testOnBorrow) { JedisPoolConfig jedisPoolConfig = new JedisPoolConfig(); jedisPoolConfig.setMaxTotal(maxActive); jedisPoolConfig.setMaxIdle(maxIdle); jedisPoolConfig.setMinIdle(minIdle); jedisPoolConfig.setMaxWaitMillis(maxWaitMillis); jedisPoolConfig.setTestOnBorrow(testOnBorrow); return jedisPoolConfig; } @Bean public JedisPool jedisPool(@Value("${spring.redis.host}") String host, @Value("${spring.redis.password}") String password, @Value("${spring.redis.port}") int port, @Value("${spring.redis.timeout}") int timeout, JedisPoolConfig jedisPoolConfig) { log.info("=====創建JedisPool連接池====="); if (StringUtils.isNotEmpty(password)) { return new JedisPool(jedisPoolConfig, host, port, timeout, password); } return new JedisPool(jedisPoolConfig, host, port, timeout); } }
4、分佈式鎖工具類
import lombok.extern.slf4j.Slf4j; import redis.clients.jedis.Jedis; import redis.clients.jedis.params.SetParams; import java.util.Collections; /** * jedis分佈式鎖工具類 * @autho ConnorSong * @date 2021/1/20 6:26 下午 */ @Slf4j public class JedisLockUtils { private static final String LOCK_SUCCESS = "OK"; private static final Long RELEASE_SUCCESS = 1L; /** * 嘗試獲取分佈式鎖 * @param jedis Redis客戶端 * @param lockKey 鎖 * @param lockValue value * @param expireTime 超期時間(秒) * @return 是否獲取成功 */ public static boolean tryGetLock(Jedis jedis, String lockKey, String lockValue, int expireTime) { log.info("----獲取Jedis分佈式鎖----lockKey:{}", lockKey); try { //方案一,具有原子性,並且可以設置過期時間,避免拿到鎖後,業務代碼出現異常,無法釋放鎖 String result = jedis.set(lockKey, lockValue, new SetParams().nx().ex(expireTime)); if (LOCK_SUCCESS.equals(result)) { return true; } return false; //方案二,setnx()具有原子性,但是有後續判斷,整體不具有原子性,不能設置過期時間 // //setnx(lockkey, 當前時間+過期超時時間),如果返回 1,則獲取鎖成功;如果返回 0 則沒有獲取到鎖 // String value = new Date().getTime() + expireTime + ""; // if(1 == jedis.setnx(lockKey, value)){ // return true; // }else{ // String oldExpireTime = jedis.get(lockKey); // if(Long.valueOf(oldExpireTime)< new Date().getTime()){ // //鎖超時,可以獲取鎖重新設置鎖 // //計算 newExpireTime = 當前時間+過期超時時間,然後 getset(lockkey, newExpireTime) 會返回當前 lockkey的值currentExpireTime // long newExpireTime = new Date().getTime() + expireTime; // String currentExpireTime = jedis.getSet(lockKey, newExpireTime + ""); // if(currentExpireTime.equals(oldExpireTime)){ // return true; // } // } // return false; // } }finally { returnResource(jedis); } } /** * 釋放分佈式鎖 * @param jedis Redis客戶端 * @param lockKey 鎖 * @return 是否釋放成功 */ public static boolean closeLock(Jedis jedis, String lockKey, String lockValue) { log.info("----釋放Jedis分佈式鎖----lockKey:{}, lockValue:{}", lockKey, lockValue); try { String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end"; Object result = jedis.eval(script, Collections.singletonList(lockKey), Collections.singletonList(lockValue)); if (RELEASE_SUCCESS.equals(result)) { return true; } return false; }finally { returnResource(jedis); } } /** * 關閉資源 * @param jedis */ public static void returnResource(final Jedis jedis){ if(null != jedis){ jedis.close(); } } }
到此這篇關於SpringBoot集成redis實現分佈式鎖的示例代碼的文章就介紹到這瞭,更多相關SpringBoot redis分佈式鎖內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet!