【分布式Redis锁】【并发编程】Redis分布式锁实例

@Service
public class LockManagementService {
    private static Logger logger = LoggerFactory.getLogger(LockManagementService.class);
    
    @Autowired
    private RedisService redisService;
    
    /**
     * 加分布式锁
     */
    public void getLock(String type,String value){
        String key = type+value;
        Long result = redisService.setnx(key, "00");
        logger.info("{},开始创建分布式锁...",key);
        while(result==0L){
            Long ttl  =redisService.getTtl(key);
            logger.info("{},并发等待中...，剩余过期时间:{} s",key,ttl);
            try {
                Thread.sleep(500L);
            } catch (InterruptedException e) {
                logger.error("分布式锁线程等待出现异常："+ e.getMessage(),e);
            };
            result = redisService.setnx(key, "00");
        }
        logger.info("{},成功创建分布式锁...",key);
        redisService.setKeyExpire(key, 300);//单位秒
    }
    /**
     * 释放分布式锁
     */
    public void unLock(String type,String value){
        String key = type+value;
        redisService.del(key);
        logger.info("{},成功释放分布式锁...",key);
    }
    
}