redis锁（demo）

╰半橙微兮° 2024-03-16 23:03 126阅读 0赞

package com.gyjn.common.core.redis;
    
    
    import com.gyjn.common.utils.StringUtils;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.data.redis.core.StringRedisTemplate;
    import org.springframework.stereotype.Component;
    
    /**
     * @author: cyf
     * @Date: 2022/7/26 15:28
     */
    
    @Component
    public class RedisLock {
    
        @Autowired
        private StringRedisTemplate redisTemplate;
    
        private static final Logger log = LoggerFactory.getLogger(RedisLock.class);
    
        /**
         * 加锁
         *
         * @param key
         * @param value 当前时间+超时时间
         * @return
         */
        public boolean lock(String key, String value) {
            if (redisTemplate.opsForValue().setIfAbsent(key, value)) {
                return true;
            }
            String currentValue = redisTemplate.opsForValue().get(key);
            if (!StringUtils.isEmpty(currentValue)
                    && Long.parseLong(currentValue) < System.currentTimeMillis()) {
                String oldValue = redisTemplate.opsForValue().getAndSet(key, value);
                if (!StringUtils.isEmpty(oldValue)
                        && oldValue.equals(currentValue)) {
    
                    return true;
    
                }
            }
            return false;
        }
    
    
        /**
         * 解锁
         *
         * @param key
         * @param value
         */
        public void unlock(String key, String value) {
            try {
                String currentValue = redisTemplate.opsForValue().get(key);
    
                if (!StringUtils.isEmpty(currentValue)
                        && currentValue.equals(value)) {
                    redisTemplate.opsForValue().getOperations().delete(key);
                }
            } catch (Exception e) {
                log.error("使用redis解锁发生异常:{}", e.getMessage());
            }
    
    
        }
    
    
    }

public void everyDayExcel() {
            String key = UUID.randomUUID().toString();
            String value = DateUtils.dateTimeNow();
            try {
                redisLock.lock(key, value);
              
    
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                redisLock.unlock(key, value);
            }
        }