redis分布式锁

代码如下：其中，假如你想在加锁时，再加一个过期时间，就不要用opsForValue()了，改成boundValueOps即可。

@Slf4j
@Component
public class RedisService {
    @Autowired
    private Redis redis;

	private String lockKey;
	private long lockExpires;
	private long tryTime;
	private TimeUnit tryTimeUnit;
	private boolean locked;

	public RedisLock(ActivityRedis redis, String lockKey, long lockExpires, long tryTime, TimeUnit tryTimeUnit) {
		this.redis = redis;
		this.lockKey = lockKey;
		this.lockExpires = lockExpires;
		this.tryTime = tryTime;
		this.tryTimeUnit = tryTimeUnit;
	}


	public boolean lock() {
		try {
			long start = System.currentTimeMillis();
			long timeout = tryTimeUnit.toMillis(tryTime);

			while (System.currentTimeMillis() - start < timeout) {
				if (setnx(lockKey)) { // 获取到锁
					// 成功获取到锁, 设置相关标识
					locked = true;
					return true;
				}

				Thread.sleep(100L);
			}
		} catch (InterruptedException e) {
			logger.error("Lock error", e);
		}
		return false;
	}

	private boolean setnx(String lockKey) {
		if ("OK".equals(redis.set(lockKey, "1", "NX", "EX", lockExpires))) {
			return true;
		}
		return false;
	}

	public boolean isLocked() {
		return locked;
	}

	/**
	 * 释放锁
	 */
	public void unlock() {
		if (!isLocked()) {
			return;
		}

		redis.del(lockKey);
	}
}