?鎖住3秒：

@Autowired private RedisTemplate redisTemplate;String withdrawals_apply_key = WITHDRAWALS_REDIS_KEY+driver.getId(); boolean flag = redisTemplate.opsForValue().setIfAbsent(withdrawals_apply_key,WITHDRAWALS_LOCK); log.info("任務(wù)是否獲取到鎖:" + flag); if (flag) {redisTemplate.expire(withdrawals_apply_key,3,TimeUnit.SECONDS);//要鎖住的代碼。。。。。。 }else{log.info("任務(wù)沒有獲取到鎖，不執(zhí)行!");return; }

鎖不設(shè)置時(shí)效：

@Autowired private RedisTemplate redisTemplate;boolean flag = false; try{flag = redisTemplate.opsForValue().setIfAbsent(REDIS_KEY, LOCK);log.info("是否獲取到鎖:" + flag);if (flag){//要鎖住的代碼。。。。。。}else {log.info("沒有獲取到鎖，不執(zhí)行定時(shí)任務(wù)!");return;} }finally {if (flag) {redisTemplate.delete(REDIS_KEY);log.info("任務(wù)結(jié)束，釋放鎖!");} else {log.info("沒有獲取到鎖，無需釋放鎖!");} }

?redis的配置類（springboot）：

import com.fengyuncx.common.utils.json.FastJsonRedisSerializer; import org.springframework.beans.factory.annotation.Value; import org.springframework.boot.autoconfigure.condition.ConditionalOnClass; import org.springframework.boot.autoconfigure.data.redis.RedisProperties; import org.springframework.boot.context.properties.EnableConfigurationProperties; import org.springframework.cache.annotation.EnableCaching; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Primary; import org.springframework.data.redis.cache.RedisCacheConfiguration; import org.springframework.data.redis.cache.RedisCacheManager; import org.springframework.data.redis.cache.RedisCacheWriter; import org.springframework.data.redis.connection.RedisConnectionFactory; import org.springframework.data.redis.connection.RedisPassword; import org.springframework.data.redis.connection.RedisStandaloneConfiguration; import org.springframework.data.redis.connection.jedis.JedisClientConfiguration; import org.springframework.data.redis.connection.jedis.JedisConnectionFactory; import org.springframework.data.redis.core.*; import org.springframework.data.redis.serializer.RedisSerializationContext; import org.springframework.data.redis.serializer.StringRedisSerializer; import redis.clients.jedis.JedisPoolConfig;import java.time.Duration;@Configuration @EnableCaching @ConditionalOnClass(RedisOperations.class) @EnableConfigurationProperties(RedisProperties.class) public class RedisConfig {@Value("${spring.driverRedis.host}")private String host;@Value("${spring.driverRedis.port}")private int port;@Value("${spring.driverRedis.password}")private String password;@Value("${spring.driverRedis.maxTotal}")private Integer maxTotal;@Value("${spring.driverRedis.maxIdle}")private Integer maxIdle;@Value("${spring.driverRedis.maxWaitMillis}")private Integer maxWaitMillis;@Value("${spring.driverRedis.timeout}")private int timeout;@Value("${spring.driverRedis.database}")private int database;@Primary@Beanpublic RedisConnectionFactory cacheBusinessRedisConnectionFactory() {JedisPoolConfig poolConfig = new JedisPoolConfig();poolConfig.setMaxTotal(maxTotal);poolConfig.setMaxIdle(maxIdle);poolConfig.setMaxWaitMillis(maxWaitMillis);poolConfig.setTestOnBorrow(true);poolConfig.setTestOnReturn(false);poolConfig.setTestWhileIdle(true);JedisClientConfiguration clientConfig = JedisClientConfiguration.builder().usePooling().poolConfig(poolConfig).and().readTimeout(Duration.ofMillis(timeout)).build();// 單點(diǎn)redisRedisStandaloneConfiguration redisConfig = new RedisStandaloneConfiguration();// 哨兵redis// RedisSentinelConfiguration redisConfig = new RedisSentinelConfiguration();// 集群redis// RedisClusterConfiguration redisConfig = new RedisClusterConfiguration();redisConfig.setHostName(host);redisConfig.setPassword(RedisPassword.of(password));redisConfig.setPort(port);redisConfig.setDatabase(database);return new JedisConnectionFactory(redisConfig, clientConfig);}/*** 管理緩存 springboot2** @param redisTemplate* @return*/@Beanpublic RedisCacheManager redisCacheManager(RedisTemplate redisTemplate) {//初始化一個(gè)RedisCacheWriterRedisCacheWriter redisCacheWriter = RedisCacheWriter.nonLockingRedisCacheWriter(redisTemplate.getConnectionFactory());RedisCacheConfiguration redisCacheConfiguration = RedisCacheConfiguration.defaultCacheConfig().serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(redisTemplate.getValueSerializer()));//設(shè)置序列化//設(shè)置默認(rèn)超過期時(shí)間是30秒redisCacheConfiguration.entryTtl(Duration.ofSeconds(30));//初始化RedisCacheManagerRedisCacheManager cacheManager = new RedisCacheManager(redisCacheWriter, redisCacheConfiguration);return cacheManager;}@Beanpublic RedisTemplate<String, Object> redisTemplate() {RedisTemplate<String, Object> template = new RedisTemplate<>();// Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<Object>(Object.class); // template.setValueSerializer(jackson2JsonRedisSerializer); // template.setHashValueSerializer(jackson2JsonRedisSerializer);//使用fastjson序列化FastJsonRedisSerializer fastJsonRedisSerializer = new FastJsonRedisSerializer(Object.class);// value值的序列化采用fastJsonRedisSerializertemplate.setValueSerializer(fastJsonRedisSerializer);template.setHashValueSerializer(fastJsonRedisSerializer);// key的序列化采用StringRedisSerializertemplate.setKeySerializer(new StringRedisSerializer());template.setHashKeySerializer(new StringRedisSerializer()); //template.setConnectionFactory(cacheBusinessRedisConnectionFactory());return template;}/*** 對(duì)hash類型的數(shù)據(jù)操作** @param redisTemplate* @return*/@Beanpublic HashOperations<String, String, Object> hashOperations(RedisTemplate<String, Object> redisTemplate) {return redisTemplate.opsForHash();}/*** 對(duì)redis字符串類型數(shù)據(jù)操作** @param redisTemplate* @return*/@Beanpublic ValueOperations<String, Object> valueOperations(RedisTemplate<String, Object> redisTemplate) {return redisTemplate.opsForValue();}/*** 對(duì)鏈表類型的數(shù)據(jù)操作** @param redisTemplate* @return*/@Beanpublic ListOperations<String, Object> listOperations(RedisTemplate<String, Object> redisTemplate) {return redisTemplate.opsForList();}/*** 對(duì)無序集合類型的數(shù)據(jù)操作** @param redisTemplate* @return*/@Beanpublic SetOperations<String, Object> setOperations(RedisTemplate<String, Object> redisTemplate) {return redisTemplate.opsForSet();}/*** 對(duì)有序集合類型的數(shù)據(jù)操作** @param redisTemplate* @return*/@Beanpublic ZSetOperations<String, Object> zSetOperations(RedisTemplate<String, Object> redisTemplate) {return redisTemplate.opsForZSet();} }

application.yml配置內(nèi)容：

spring:driverRedis:host: 192.168.101.100port: 6379password: 123456maxIdle: 300maxTotal: 600maxWaitMillis: 1000timeout: 3000database: 4dictRedis:host: 192.168.101.100port: 6379password: 123456maxIdle: 300maxTotal: 600maxWaitMillis: 1000timeout: 3000database: 0

?

總結(jié)

以上是生活随笔為你收集整理的Redis分布式锁加时效和不加时效两种方案的最全代码实现的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。