Redis 加鎖和解鎖的應用

上代碼

應用調用示例

            RedisLockEntity lockEntityYlb = RedisLockEntity.builder().lockKey(TradeConstants.HP_APP_AMOUNT_LOCK_PREFIX + appUser.getAccount()).value(orderId).build();boolean isLockedYlb = false;try {if (redisLock.tryLock(lockEntityYlb)) {業務邏輯}else {logger.info("給用戶分ylb加鎖失敗，賬戶正在交易中");}}catch (Exception e){logger.info("給用戶分ylb加鎖失敗，賬戶正在交易中");}finally {if (isLockedYlb) {try {redisLock.unlock(lockEntityYlb);} catch (LockException e) {logger.error(lockEntityYlb.toString());}}}

RedisLockEntity 實體類

import lombok.Builder;
import lombok.Getter;
import lombok.Setter;
import lombok.ToString;@Getter
@Setter
@Builder
@ToString
public class RedisLockEntity {private String lockKey;private String value;
}

RedisLock 類

import java.util.concurrent.TimeUnit;import com.happypay.trade.exception.LockException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;import lombok.extern.slf4j.Slf4j;@Service
@Slf4j
public class RedisLock {private static final Logger logger = LoggerFactory.getLogger(RedisLock.class);@Autowiredprivate RedisTemplate<String, Object> redisTemplate;private static final int TRY_COUNT = 4;public boolean tryLock(RedisLockEntity redisLockEntity) throws LockException {boolean locked = false;int tryCount = TRY_COUNT;try {while (!locked && tryCount > 0) {locked = redisTemplate.opsForValue().setIfAbsent(redisLockEntity.getLockKey(),redisLockEntity.getValue(), 2, TimeUnit.MINUTES);tryCount--;try {Thread.sleep(300);} catch (InterruptedException e) {log.error("線程被中斷" + Thread.currentThread().getId(), e);}}} catch (Exception e) {throw new LockException(e);}if (locked) {logger.info("獲取操作鎖成功:" + redisLockEntity.toString());}return locked;}public boolean unlock(RedisLockEntity redisLockEntity) throws LockException {boolean releaseLock = false;try {if (redisLockEntity == null || redisLockEntity.getLockKey() == null || redisLockEntity.getValue() == null)return false;releaseLock = false;String value = (String) redisTemplate.opsForValue().get(redisLockEntity.getLockKey());if (redisLockEntity.getValue().equals(value)) {releaseLock = redisTemplate.delete(redisLockEntity.getLockKey());}logger.info("釋放操作鎖成功:" + redisLockEntity.toString());} catch (Exception e) {logger.error("釋放鎖出錯", e);throw new LockException(e);}return releaseLock;}}