Redissons 锁细谈

        <!--redisson-->

        <dependency>

            <groupId>org.redisson</groupId>

            <artifactId>redisson</artifactId>

            <version>3.11.6</version>

        </dependency>

@Configuration

@EnableCaching

public class RedisConfig extends CachingConfigurerSupport {

    @Autowired

    private AppConfig appConfig;

    /**

     * 配置redisTemplate实例
     * @return
     */
    @Bean
    RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {

        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();

        redisTemplate.setConnectionFactory(redisConnectionFactory);

        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);

        // 设置值（value）的序列化采用Jackson2JsonRedisSerializer。

        redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);

        // 设置键（key）的序列化采用StringRedisSerializer。

        redisTemplate.setKeySerializer(new StringRedisSerializer());

        redisTemplate.setHashKeySerializer(new StringRedisSerializer());

        redisTemplate.afterPropertiesSet();

        return redisTemplate;

    }

  /**

     * 配置RdeissonClint实例
     * @return
     */
    @Bean
    public RedissonClient redissonClient(){
        Config config = new Config();
        config.useSingleServer().setAddress("redis://" + "127.0.0.1" + ":" + "6379");
        if (StringUtils.isNotBlank(appConfig.getPassword())){
            config.useSingleServer().setPassword(appConfig.getPassword());
        }
        return Redisson.create(config);
    }

    @Autowired

    private RedissonClient redissonClient;

    @GetMapping("seckill")

    public Integer test() throws InterruptedException {

        // 获取锁对象

        RLock lock = redissonClient.getLock("lock");

        try {

            // 参数一：尝试加锁等待时间

            // 参数二：锁key生存时间

            // 参数三：时间单位

            if (lock.tryLock(0,10, TimeUnit.SECONDS)) {

                //  加锁成功，Do something

            }else {

                // 加锁失败

            }

        }catch (InterruptedException e) {

            e.printStackTrace();

        }finally {

            // 释放锁

            lock.unlock();

        }

        return null;

    }