当前位置:网站首页>Redis redisTemplate.execute 执行锁
Redis redisTemplate.execute 执行锁
2022-08-09 23:33:00 【川流不息的车呀】
Redis 脚本执行redis锁代码如下:
/**
* 加锁
*/
public final static String SCRIPT_LOCK = "local key = KEYS[1];\n"
+ "local value = ARGV[1];\n"
+ "local ttlMillis = tonumber(ARGV[2]);\n"
+ "if ( redis.call('SETNX', key, value) == 1 ) then\n"
+ " redis.call('PEXPIRE', key, ttlMillis);\n"
+ " return true;\n"
+ "end;";
public boolean tryLock(String key, String val, Long timeMillis) {
return tryLock(RedisConstants.KEY + key,SCRIPT_LOCK, val, timeMillis,
TimeUnit.MILLISECONDS);
}
public boolean tryLock(String key, String scriptText, String val, Long timeout, TimeUnit unit) {
DefaultRedisScript<Boolean> script = new DefaultRedisScript<>();
script.setScriptText(scriptText);
script.setResultType(Boolean.class);
long rawTimeout = TimeoutUtils.toMillis(timeout, unit);
return redisTemplate.execute(script, Collections.singletonList(key), val, rawTimeout);
}@Configuration
public class RedisTemplateAutoConfiguration {
@Bean
public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory rcf) {
RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
redisTemplate.setConnectionFactory(rcf);
//使用StringRedisSerializer对Key序列号,使用Jackson对Value序列化
Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
ObjectMapper om = new ObjectMapper();
om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
jackson2JsonRedisSerializer.setObjectMapper(om);
StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
redisTemplate.setKeySerializer(stringRedisSerializer);
redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
redisTemplate.setHashKeySerializer(stringRedisSerializer);
redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);
redisTemplate.afterPropertiesSet();
return redisTemplate;
}
}边栏推荐
猜你喜欢

深入理解Aarch64内存管理

Golden Warehouse Database KingbaseGIS User Manual (6.5. Geometry Object Editing Function)

【C语言】通讯录《静态内存版本》

dlopen failed: library "libtaml.so" not found

MATLB|和她跌宕起伏最终到达人生之峰【浪漫旅途】

ES6 Beginner to Mastery #13: Extension Methods for Arrays 2

程序员从佩洛西窜访事件中可以学到什么?

【云原生】Kubernetes编排工具精讲

Leetcode80. 删除有序数组中的重复项 II

ES6 从入门到精通 # 13:数组的扩展方法二
随机推荐
漫谈缺陷管理的自动化实践方案
ECCV 2022 | Microsoft Open Source TinyViT: Pre-training Capabilities for Small Models
【「收藏」Oracle 数据库安装】
无源晶振负载电容值CL匹配方法及说明
如何抑制告警风暴?
【obs】obsqsv11 硬编 及与metartc codec对比
足不出户也能看星空
Redis 大 key 要如何处理?
Creo5.0 introductory tutorial free material
AppUser object extension based on ABP
AirFlow介绍
信息系统项目管理师核心考点(六十四)信息安全基础知识重要概念
[C language] In-depth understanding of pointers and arrays (issue 4)
【SSL集训DAY2】Sort【树状数组】
Eureka protects itself
Leetcode80. 删除有序数组中的重复项 II
解锁时间生成与比较
博弈小游戏
Impala 疑问
Today's sleep quality record 61 points