当前位置:网站首页>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;
}
}边栏推荐
猜你喜欢
随机推荐
数字孪生智慧制造生产线项目实施方案,平台认知与概念
Seq2Seq论文阅读笔记
dlopen failed: library "libtaml.so" not found
CST Studio Suite 2021软件安装包和安装教程
【问题解决】训练和验证准确率很高,但测试准确率很低
Today's sleep quality record 61 points
什么是服务治理
数据库的备份与恢复「建议收藏」
博弈小游戏
信息系统项目管理师核心考点(六十四)信息安全基础知识重要概念
下班后用微信处理工作时发病身亡,法院判决:工伤!
【Infiltration tool】Browser data export tool
selenium和驱动安装
【集训DAY3】阶乘【数学】
MATLB|和她跌宕起伏最终到达人生之峰【浪漫旅途】
深入理解Aarch64内存管理
知行合一的时候
漫谈缺陷管理的自动化实践方案
Golden Warehouse Database KingbaseGIS User Manual (6.5. Geometry Object Editing Function)
大龄测试员刚迈过了 35 岁这个“坎儿”,和大家说点儿心里话









