当前位置:网站首页>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;
    }
}

原网站

版权声明
本文为[川流不息的车呀]所创,转载请带上原文链接,感谢
https://blog.csdn.net/u010738038/article/details/126252980