当前位置:网站首页>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;
}
}
边栏推荐
猜你喜欢
随机推荐
Wireshark classic practice and interview 13-point summary
服装店管理系统如何推送活动?
In-depth understanding of multithreading (Part 1)
hql语言
[C language] In-depth understanding of pointers and arrays (issue 4)
断开和服务器共享连接的方法「建议收藏」
mysql无法远程连接 Can‘t connect to MySQL server on ‘xxx.xxx.xxx.xxx‘ (10060 “Unknown error“)
【集训DAY4】询问【Hash】
蔚来杯2022牛客暑期多校训练营7 CFGJ
Project (7) - PolarSeg point cloud semantic segmentation
解锁时间生成与比较
【集训DAY3】阶乘【数学】
ES6 从入门到精通 # 13:数组的扩展方法二
基于ABP的AppUser对象扩展
数据库的备份与恢复「建议收藏」
【剑指offer】第一题 第二题
考柏的感慨
深入理解Aarch64内存管理
基于ABP的AppUser对象扩展
Dry goods!Towards robust test-time adaptation