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);
}
}