![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260208031006-6987fe8e1771d.png\")
<\/h3>\n\u57fa\u4e8e Redis \u7684\u79d2\u6740\u5355\u673a\u7cfb\u7edf\u8fed\u4ee3\u5b9e\u73b0（\u9644\u8be6\u7ec6\u6d41\u7a0b\u56fe）-CSDN\u535a\u5ba2<\/p>\n
\u57fa\u4e8e Redis \u7684\u79d2\u6740\u96c6\u7fa4\u7cfb\u7edf\u8fed\u4ee3\u5b9e\u73b0\u3010SETNX\u3011（\u9644\u8be6\u7ec6\u6d41\u7a0b\u56fe）-CSDN\u535a\u5ba2<\/p>\n
<\/h3>\n\u7528SETNX\u5b9e\u73b0\u7684\u9501，\u6709\u4e0d\u53ef\u91cd\u5165，\u4e0d\u53ef\u91cd\u8bd5，\u9501\u8fc7\u671f，\u4e3b\u4ece\u4e0d\u4e00\u81f4\u7684\u95ee\u9898<\/p>\n
Redisson \u662f\u4e00\u4e2a\u57fa\u4e8e Redis \u7684 Java \u5ba2\u6237\u7aef，\u5b83\u4e0d\u4ec5\u5c01\u88c5\u4e86 Redis \u7684\u57fa\u7840\u64cd\u4f5c，\u8fd8\u63d0\u4f9b\u4e86\u4e00\u5957\u5b8c\u6574\u7684\u5206\u5e03\u5f0f\u9501\u5b9e\u73b0，\u89e3\u51b3\u4e86\u539f\u751f Redis \u5b9e\u73b0\u5206\u5e03\u5f0f\u9501\u65f6\u7684\u8bf8\u591a\u75db\u70b9（\u6bd4\u5982\u9501\u81ea\u52a8\u7eed\u671f\u3001\u6b7b\u9501\u3001\u91ca\u653e\u522b\u4eba\u7684\u9501\u7b49\u95ee\u9898）\u3002<\/p>\n
\u53ef\u91cd\u5165\u9501：\u652f\u6301\u7ebf\u7a0b\u91cd\u5165（\u540c\u4e00\u4e2a\u7ebf\u7a0b\u591a\u6b21\u83b7\u53d6\u540c\u4e00\u628a\u9501\u4e0d\u4f1a\u6b7b\u9501），\u7b26\u5408 Java \u4e2d\u00a0ReentrantLock\u00a0\u7684\u7279\u6027\u3002<\/p>\n
@Configuration
\npublic class RedissonConfig {<\/p>\n
@Bean
\n public RedissonClient redissonClient(){
\n \/\/ \u914d\u7f6e
\n Config config = new Config();
\n config.useSingleServer().setAddress("\u5730\u5740")
\n .setPassword("\u5bc6\u7801");
\n \/\/ \u521b\u5efaRedissonClient\u5bf9\u8c61
\n return Redisson.create(config);
\n }
\n}
\n @Override
\n @Transactional
\n public Long seckillVoucher(Long voucherId) {
\n \/\/ 1.\u67e5\u8be2\u4f18\u60e0\u5238
\n SeckillVoucher voucher = seckillVoucherService.getById(voucherId);
\n \/\/ 2.\u5224\u65ad\u79d2\u6740\u662f\u5426\u5f00\u59cb
\n if (voucher.getBeginTime().isAfter(LocalDateTime.now())) {
\n \/\/ \u5c1a\u672a\u5f00\u59cb
\n throw new BaseException(ExceptionConstants.NOT_START);
\n }
\n \/\/ 3.\u5224\u65ad\u79d2\u6740\u662f\u5426\u5df2\u7ecf\u7ed3\u675f
\n if (voucher.getEndTime().isBefore(LocalDateTime.now())) {
\n \/\/ \u5c1a\u672a\u5f00\u59cb
\n throw new BaseException(ExceptionConstants.IS_END);
\n }
\n \/\/ 4.\u5224\u65ad\u5e93\u5b58\u662f\u5426\u5145\u8db3
\n if (voucher.getStock() < 1) {
\n \/\/ \u5e93\u5b58\u4e0d\u8db3
\n throw new BaseException(ExceptionConstants.NOT_ENOUGH);
\n }
\n Long userId = UserHolder.getUser().getId();
\n String key = RedisConstants.getLockOrderKey(userId);
\n RLock lock = redissonClient.getLock(key);
\n boolean isLock = lock.tryLock();
\n if (!isLock) {
\n \/\/ \u83b7\u53d6\u9501\u5931\u8d25，\u8fd4\u56de\u9519\u8bef\u6216\u91cd\u8bd5
\n throw new BaseException(ExceptionConstants.EXIST_BUY);
\n }
\n try {
\n IVoucherOrderService proxy = (IVoucherOrderService) AopContext.currentProxy();
\n return proxy.createVoucherOrder(voucherId);
\n } catch (IllegalStateException e) {
\n throw new RuntimeException(e);
\n } finally {
\n lock.unlock();
\n }
\n } <\/p>\n
\u8fd9\u91cc\u7684\u9501\u4ece\u539f\u6765\u81ea\u5df1\u5b9e\u73b0\u53d8\u6210\u4e86\u4f7f\u7528\u73b0\u6210\u7684Api<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260208031007-6987fe8f3ee6a.png\")
<\/p>\n
\u539f\u6765\u7684\u9501\u952e\u662f\u7528\u6237，\u9501\u662f\u7ebf\u7a0b<\/p>\n
Redisson\u9501\u5728redis\u4e2d\u5b58\u50a8\u7684\u662fhash\u7ed3\u6784，\u5927\u952e\u662f\u7528\u6237，\u5c0f\u952e\u662f\u7ebf\u7a0b，\u503c\u662f\u9501\u7684\u91cd\u590d\u6b21\u6570<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260208031008-6987fe90b282b.png\")
<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260208031009-6987fe9154a05.png\")
<\/p>\n
\u8fdb\u5165RedissonLock.tryLock()，\u6b64\u7c7b\u5b9e\u73b0\u4e86Rlock\u63a5\u53e3
\n public boolean tryLock() {
\n return (Boolean)this.get(this.tryLockAsync());
\n }<\/p>\n
public RFuture<Boolean> tryLockAsync() {
\n return this.tryLockAsync(Thread.currentThread().getId());
\n }<\/p>\n
public RFuture<Boolean> tryLockAsync(long threadId) {
\n return this.tryAcquireOnceAsync(-1L, -1L, (TimeUnit)null, threadId);
\n }<\/p>\n
private RFuture<Boolean> tryAcquireOnceAsync(long waitTime, long leaseTime, TimeUnit unit, long threadId) {
\n if (leaseTime != -1L) {
\n return this.<Boolean>tryLockInnerAsync(waitTime, leaseTime, unit, threadId, RedisCommands.EVAL_NULL_BOOLEAN);
\n } else {
\n RFuture<Boolean> ttlRemainingFuture = this.<Boolean>tryLockInnerAsync(waitTime, this.commandExecutor.getConnectionManager().getCfg().getLockWatchdogTimeout(), TimeUnit.MILLISECONDS, threadId, RedisCommands.EVAL_NULL_BOOLEAN);
\n ttlRemainingFuture.onComplete((ttlRemaining, e) -> {
\n if (e == null) {
\n if (ttlRemaining) {
\n this.scheduleExpirationRenewal(threadId);
\n }<\/p>\n
}
\n });
\n return ttlRemainingFuture;
\n }
\n } <\/p>\n
<T> RFuture<T> tryLockInnerAsync(long waitTime, long leaseTime, TimeUnit unit, long threadId, RedisStrictCommand<T> command) {
\n this.internalLockLeaseTime = unit.toMillis(leaseTime);
\n return this.<T>evalWriteAsync(this.getName(), LongCodec.INSTANCE, command,
\n"if (redis.call('exists', KEYS[1]) == 0) then"+
\n" redis.call('hincrby', KEYS[1], ARGV[2], 1); "+
\n"redis.call('pexpire', KEYS[1], ARGV[1]);"+
\n"return nil;"+
\n"end;"+
\n"if (redis.call('hexists', KEYS[1], ARGV[2]) == 1) then "+
\n"redis.call('hincrby', KEYS[1], ARGV[2], 1); "+
\n"redis.call('pexpire', KEYS[1], ARGV[1]); "+
\n"return nil; "+
\n"end; "+
\n"return redis.call('pttl', KEYS[1]);",
\nCollections.singletonList(this.getName()), this.internalLockLeaseTime, this.getLockName(threadId));
\n } <\/p>\n
\u00a0![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260208031010-6987fe92618a0.png\")
\u00a0<\/p>\n
public void unlock() {
\n try {
\n this.get(this.unlockAsync(Thread.currentThread().getId()));
\n } catch (RedisException e) {
\n if (e.getCause() instanceof IllegalMonitorStateException) {
\n throw (IllegalMonitorStateException)e.getCause();
\n } else {
\n throw e;
\n }
\n }
\n }<\/p>\n
public RFuture<Void> unlockAsync(long threadId) {
\n RPromise<Void> result = new RedissonPromise();
\n RFuture<Boolean> future = this.unlockInnerAsync(threadId);
\n future.onComplete((opStatus, e) -> {
\n this.cancelExpirationRenewal(threadId);
\n if (e != null) {
\n result.tryFailure(e);
\n } else if (opStatus == null) {
\n IllegalMonitorStateException cause = new IllegalMonitorStateException("attempt to unlock lock, not locked by current thread by node id: " + this.id + " thread-id: " + threadId);
\n result.tryFailure(cause);
\n } else {
\n result.trySuccess((Object)null);
\n }
\n });
\n return result;
\n }<\/p>\n
protected RFuture<Boolean> unlockInnerAsync(long threadId) {
\n return this.<Boolean>evalWriteAsync(this.getName(), LongCodec.INSTANCE,
\nRedisCommands.EVAL_BOOLEAN, "if (redis.call('hexists', KEYS[1], ARGV[3]) == 0) then
\nreturn nil;end; local counter = redis.call('hincrby', KEYS[1], ARGV[3], -1); if (counter
\n> 0) then redis.call('pexpire', KEYS[1], ARGV[2]); return 0; else redis.call('del',
\nKEYS[1]); redis.call('publish', KEYS[2], ARGV[1]); return 1; end; return nil;",
\nArrays.asList(this.getName(), this.getChannelName()), LockPubSub.UNLOCK_MESSAGE,
\nthis.internalLockLeaseTime, this.getLockName(threadId));
\n } <\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260208031010-6987fe92dc099.png\")
<\/p>\n
public boolean tryLock(long waitTime, TimeUnit unit) throws InterruptedException {
\n return this.tryLock(waitTime, -1L, unit);
\n }<\/p>\n
public boolean tryLock(long waitTime, long leaseTime, TimeUnit unit) throws InterruptedException {
\n long time = unit.toMillis(waitTime);
\n long current = System.currentTimeMillis();
\n long threadId = Thread.currentThread().getId();
\n Long ttl = this.tryAcquire(waitTime, leaseTime, unit, threadId);
\n if (ttl == null) {
\n return true;
\n } else {
\n time -= System.currentTimeMillis() – current;
\n if (time <= 0L) {
\n this.acquireFailed(waitTime, unit, threadId);
\n return false;
\n } else {
\n current = System.currentTimeMillis();
\n RFuture<RedissonLockEntry> subscribeFuture = this.subscribe(threadId);
\n if (!subscribeFuture.await(time, TimeUnit.MILLISECONDS)) {
\n if (!subscribeFuture.cancel(false)) {
\n subscribeFuture.onComplete((res, e) -> {
\n if (e == null) {
\n this.unsubscribe(subscribeFuture, threadId);
\n }<\/p>\n
});
\n }<\/p>\n
this.acquireFailed(waitTime, unit, threadId);
\n return false;
\n } else {
\n boolean var14;
\n try {
\n time -= System.currentTimeMillis() – current;
\n if (time > 0L) {
\n do {
\n long currentTime = System.currentTimeMillis();
\n ttl = this.tryAcquire(waitTime, leaseTime, unit, threadId);
\n if (ttl == null) {
\n boolean var28 = true;
\n return var28;
\n }<\/p>\n
time -= System.currentTimeMillis() – currentTime;
\n if (time <= 0L) {
\n this.acquireFailed(waitTime, unit, threadId);
\n boolean var27 = false;
\n return var27;
\n }<\/p>\n
currentTime = System.currentTimeMillis();
\n if (ttl >= 0L && ttl < time) {
\n ((RedissonLockEntry)subscribeFuture.getNow()).getLatch().tryAcquire(ttl, TimeUnit.MILLISECONDS);
\n } else {
\n ((RedissonLockEntry)subscribeFuture.getNow()).getLatch().tryAcquire(time, TimeUnit.MILLISECONDS);
\n }<\/p>\n
time -= System.currentTimeMillis() – currentTime;
\n } while(time > 0L);<\/p>\n
this.acquireFailed(waitTime, unit, threadId);
\n boolean var16 = false;
\n return var16;
\n }<\/p>\n
this.acquireFailed(waitTime, unit, threadId);
\n var14 = false;
\n } finally {
\n this.unsubscribe(subscribeFuture, threadId);
\n }<\/p>\n
return var14;
\n }
\n }
\n }
\n }<\/p>\n
private Long tryAcquire(long waitTime, long leaseTime, TimeUnit unit, long threadId) {
\n return (Long)this.get(this.tryAcquireAsync(waitTime, leaseTime, unit, threadId));
\n } <\/p>\n
\u9996\u6b21\u5c1d\u8bd5\u5148\u8c03\u7528\u00a0tryAcquire\u00a0\u5c1d\u8bd5\u83b7\u53d6\u9501\u3002\u5982\u679c\u6210\u529f（\u8fd4\u56de\u00a0null），\u76f4\u63a5\u8fd4\u56de\u00a0true\u3002<\/p>\n<\/li>\n
\u8ba2\u9605\u9501\u91ca\u653e\u4e8b\u4ef6\u5982\u679c\u9996\u6b21\u5c1d\u8bd5\u5931\u8d25，\u5c31\u901a\u8fc7\u00a0subscribe\u00a0\u8ba2\u9605\u8be5\u9501\u7684\u91ca\u653e\u901a\u77e5，\u907f\u514d\u65e0\u6548\u7684\u81ea\u65cb\u7b49\u5f85\u3002<\/p>\n<\/li>\n
\u5faa\u73af\u91cd\u8bd5\u8fdb\u5165\u00a0do-while\u00a0\u5faa\u73af，\u53ea\u8981\u8fd8\u6709\u5269\u4f59\u7b49\u5f85\u65f6\u95f4，\u5c31\u4f1a：<\/p>\n
\u8d85\u65f6\u9000\u51fa\u5982\u679c\u7b49\u5f85\u65f6\u95f4\u8017\u5c3d\u4ecd\u672a\u83b7\u53d6\u5230\u9501，\u5c31\u8c03\u7528\u00a0acquireFailed\u00a0\u5e76\u8fd4\u56de\u00a0false\u3002<\/p>\n<\/li>\n
\u8d44\u6e90\u6e05\u7406\u65e0\u8bba\u6210\u529f\u8fd8\u662f\u5931\u8d25，\u6700\u7ec8\u90fd\u4f1a\u5728\u00a0finally\u00a0\u5757\u4e2d\u53d6\u6d88\u8ba2\u9605，\u907f\u514d\u8d44\u6e90\u6cc4\u6f0f\u3002<\/p>\n<\/li>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260208031011-6987fe9372eb3.png\")
<\/p>\n
private RFuture<Boolean> tryAcquireOnceAsync(long waitTime, long leaseTime, TimeUnit unit, long threadId) {
\n if (leaseTime != -1L) {
\n return this.<Boolean>tryLockInnerAsync(waitTime, leaseTime, unit, threadId, RedisCommands.EVAL_NULL_BOOLEAN);
\n } else {
\n RFuture<Boolean> ttlRemainingFuture = this.<Boolean>tryLockInnerAsync(waitTime, this.commandExecutor.getConnectionManager().getCfg().getLockWatchdogTimeout(), TimeUnit.MILLISECONDS, threadId, RedisCommands.EVAL_NULL_BOOLEAN);
\n ttlRemainingFuture.onComplete((ttlRemaining, e) -> {
\n if (e == null) {
\n if (ttlRemaining) {
\n this.scheduleExpirationRenewal(threadId);
\n }<\/p>\n
}
\n });
\n return ttlRemainingFuture;
\n }
\n }<\/p>\n
private void scheduleExpirationRenewal(long threadId) {
\n ExpirationEntry entry = new ExpirationEntry();
\n ExpirationEntry oldEntry = (ExpirationEntry)EXPIRATION_RENEWAL_MAP.putIfAbsent(this.getEntryName(), entry);
\n if (oldEntry != null) {
\n oldEntry.addThreadId(threadId);
\n } else {
\n entry.addThreadId(threadId);
\n this.renewExpiration();
\n }<\/p>\n
}<\/p>\n
private void renewExpiration() {
\n ExpirationEntry ee = (ExpirationEntry)EXPIRATION_RENEWAL_MAP.get(this.getEntryName());
\n if (ee != null) {
\n Timeout task = this.commandExecutor.getConnectionManager().newTimeout(new TimerTask() {
\n public void run(Timeout timeout) throws Exception {
\n ExpirationEntry ent = (ExpirationEntry)RedissonLock.EXPIRATION_RENEWAL_MAP.get(RedissonLock.this.getEntryName());
\n if (ent != null) {
\n Long threadId = ent.getFirstThreadId();
\n if (threadId != null) {
\n RFuture<Boolean> future = RedissonLock.this.renewExpirationAsync(threadId);
\n future.onComplete((res, e) -> {
\n if (e != null) {
\n RedissonLock.log.error("Can't update lock " + RedissonLock.this.getName() + " expiration", e);
\n } else {
\n if (res) {
\n RedissonLock.this.renewExpiration();
\n }<\/p>\n
}
\n });
\n }
\n }
\n }
\n }, this.internalLockLeaseTime \/ 3L, TimeUnit.MILLISECONDS);
\n ee.setTimeout(task);
\n }
\n }<\/p>\n
protected RFuture<Boolean> renewExpirationAsync(long threadId) {
\n return this.<Boolean>evalWriteAsync(this.getName(), LongCodec.INSTANCE, RedisCommands.EVAL_BOOLEAN, "if (redis.call('hexists', KEYS[1], ARGV[2]) == 1) then redis.call('pexpire', KEYS[1], ARGV[1]); return 1; end; return 0;", Collections.singletonList(this.getName()), this.internalLockLeaseTime, this.getLockName(threadId));
\n } <\/p>\n
\u5f00\u542f\u7eed\u547d\u5f53\u8c03\u7528\u00a0tryLock\u00a0\u4e14\u672a\u6307\u5b9a\u00a0leaseTime（\u5373\u00a0leaseTime = -1）\u65f6，\u9501\u83b7\u53d6\u6210\u529f\u540e\u4f1a\u89e6\u53d1\u00a0scheduleExpirationRenewal，\u5f00\u542f\u770b\u95e8\u72d7\u3002<\/p>\n<\/li>\n
\u5b9a\u65f6\u4efb\u52a1\u89e6\u53d1renewExpiration\u00a0\u65b9\u6cd5\u4f1a\u521b\u5efa\u4e00\u4e2a\u5b9a\u65f6\u4efb\u52a1，\u9ed8\u8ba4\u5728\u9501\u8fc7\u671f\u65f6\u95f4\u7684 1\/3 \u65f6（\u6bd4\u5982\u9501\u9ed8\u8ba4 30 \u79d2\u8fc7\u671f，\u4efb\u52a1\u5c31\u4f1a\u5728 10 \u79d2\u540e\u6267\u884c），\u53bb\u68c0\u67e5\u9501\u662f\u5426\u8fd8\u88ab\u5f53\u524d\u7ebf\u7a0b\u6301\u6709\u3002<\/p>\n<\/li>\n
\u7eed\u547d\u64cd\u4f5c\u5b9a\u65f6\u4efb\u52a1\u4f1a\u8c03\u7528\u00a0renewExpirationAsync，\u901a\u8fc7 Lua \u811a\u672c\u53bb Redis \u4e2d\u66f4\u65b0\u9501\u7684\u8fc7\u671f\u65f6\u95f4，\u5b8c\u6210 \u201c\u7eed\u547d\u201d\u3002<\/p>\n<\/li>\n
\u5faa\u73af\u7eed\u547d\u53ea\u8981\u9501\u8fd8\u88ab\u6301\u6709，\u6bcf\u6b21\u7eed\u547d\u6210\u529f\u540e，\u5c31\u4f1a\u518d\u6b21\u8c03\u5ea6\u4e0b\u4e00\u4e2a\u5b9a\u65f6\u4efb\u52a1，\u5982\u6b64\u5faa\u73af，\u76f4\u5230\u9501\u88ab\u4e3b\u52a8\u91ca\u653e\u6216\u7ebf\u7a0b\u5d29\u6e83\u3002<\/p>\n<\/li>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260208031012-6987fe9450793.png\")
<\/p>\n
\u5f53\u6211\u4eec\u4e0d\u6307\u5b9a\u9501\u8fc7\u671f\u65f6\u95f4，\u5c31\u4f1a\u6267\u884c\u770b\u95e8\u72d7\u7b56\u7565，\u4f1a\u4e00\u76f4\u5e2e\u6211\u4eec\u7eed\u671f<\/p>\n
\u601d\u8003：\u4e3a\u4ec0\u4e48\u4e0d\u5e72\u8106\u8bbe\u5b9a\u4e0d\u8fc7\u671f，\u800c\u662f\u8981\u91c7\u7528\u5b9a\u65f6\u4efb\u52a1\u4e0d\u65ad\u5730\u7eed\u671f？<\/p>\n
public RFuture<Void> unlockAsync(long threadId) {
\n RPromise<Void> result = new RedissonPromise();
\n RFuture<Boolean> future = this.unlockInnerAsync(threadId);
\n future.onComplete((opStatus, e) -> {
\n this.cancelExpirationRenewal(threadId);
\n if (e != null) {
\n result.tryFailure(e);
\n } else if (opStatus == null) {
\n IllegalMonitorStateException cause = new IllegalMonitorStateException("attempt to unlock lock, not locked by current thread by node id: " + this.id + " thread-id: " + threadId);
\n result.tryFailure(cause);
\n } else {
\n result.trySuccess((Object)null);
\n }
\n });
\n return result;
\n }<\/p>\n
void cancelExpirationRenewal(Long threadId) {
\n ExpirationEntry task = (ExpirationEntry)EXPIRATION_RENEWAL_MAP.get(this.getEntryName());
\n if (task != null) {
\n if (threadId != null) {
\n task.removeThreadId(threadId);
\n }<\/p>\n
if (threadId == null || task.hasNoThreads()) {
\n Timeout timeout = task.getTimeout();
\n if (timeout != null) {
\n timeout.cancel();
\n }<\/p>\n
EXPIRATION_RENEWAL_MAP.remove(this.getEntryName());
\n }<\/p>\n
}
\n } <\/p>\n
\u89e3\u9501\u65f6\u4e3b\u52a8\u5173\u95ed\u5728\u00a0unlockAsync\u00a0\u65b9\u6cd5\u4e2d，\u89e3\u9501\u64cd\u4f5c\u5b8c\u6210\u540e\u4f1a\u7acb\u523b\u8c03\u7528\u00a0cancelExpirationRenewal，\u4e3b\u52a8\u5173\u95ed\u770b\u95e8\u72d7\u7684\u7eed\u547d\u4efb\u52a1\u3002<\/p>\n<\/li>\n
\u7ebf\u7a0b\u5b89\u5168\u7684\u6e05\u7406<\/p>\n
\u505c\u6b62\u5b9a\u65f6\u4efb\u52a1<\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260208031013-6987fe95ec34d.png\")
<\/p>\n
\u5b9a\u65f6\u4efb\u52a1\u4f1a\u5728\u89e3\u9501\u7684\u65f6\u5019\u53d6\u6d88\u6389，\u4e0d\u4f1a\u4e00\u76f4\u6267\u884c<\/p>\n
redission\u63d0\u51fa\u6765\u4e86MutiLock\u9501，\u4f7f\u7528\u8fd9\u628a\u9501\u54b1\u4eec\u5c31\u4e0d\u4f7f\u7528\u4e3b\u4ece\u4e86，\u6bcf\u4e2a\u8282\u70b9\u7684\u5730\u4f4d\u90fd\u662f\u4e00\u6837\u7684， \u8fd9\u628a\u9501\u52a0\u9501\u7684\u903b\u8f91\u9700\u8981\u5199\u5165\u5230\u6bcf\u4e00\u4e2a\u4e3b\u4e1b\u8282\u70b9\u4e0a，\u53ea\u6709\u6240\u6709\u7684\u670d\u52a1\u5668\u90fd\u5199\u5165\u6210\u529f，\u6b64\u65f6\u624d\u662f\u52a0\u9501\u6210\u529f，\u5047\u8bbe\u73b0\u5728\u67d0\u4e2a\u8282\u70b9\u6302\u4e86，\u90a3\u4e48\u4ed6\u53bb\u83b7\u5f97\u9501\u7684\u65f6\u5019，\u53ea\u8981\u6709\u4e00\u4e2a\u8282\u70b9\u62ff\u4e0d\u5230，\u90fd\u4e0d\u80fd\u7b97\u662f\u52a0\u9501\u6210\u529f，\u5c31\u4fdd\u8bc1\u4e86\u52a0\u9501\u7684\u53ef\u9760\u6027\u3002<\/p>\n
@Configuration
\npublic class RedissonConfig {<\/p>\n
@Bean
\n public RedissonClient redissonClient(){
\n \/\/ \u914d\u7f6e
\n Config config = new Config();
\n config.useSingleServer().setAddress("\u5730\u5740")
\n .setPassword("\u5bc6\u7801");
\n \/\/ \u521b\u5efaRedissonClient\u5bf9\u8c61
\n return Redisson.create(config);
\n }<\/p>\n
@Bean
\n public RedissonClient redissonClient2(){
\n \/\/ \u914d\u7f6e
\n Config config = new Config();
\n config.useSingleServer().setAddress("\u5730\u5740")
\n .setPassword("\u5bc6\u7801");
\n \/\/ \u521b\u5efaRedissonClient\u5bf9\u8c61
\n return Redisson.create(config);
\n }<\/p>\n
@Bean
\n public RedissonClient redissonClient3(){
\n \/\/ \u914d\u7f6e
\n Config config = new Config();
\n config.useSingleServer().setAddress("\u5730\u5740")
\n .setPassword("\u5bc6\u7801");
\n \/\/ \u521b\u5efaRedissonClient\u5bf9\u8c61
\n return Redisson.create(config);
\n }
\n}
\n @Override
\n @Transactional
\n public Long seckillVoucher(Long voucherId) {
\n \/\/ 1.\u67e5\u8be2\u4f18\u60e0\u5238
\n SeckillVoucher voucher = seckillVoucherService.getById(voucherId);
\n \/\/ 2.\u5224\u65ad\u79d2\u6740\u662f\u5426\u5f00\u59cb
\n if (voucher.getBeginTime().isAfter(LocalDateTime.now())) {
\n \/\/ \u5c1a\u672a\u5f00\u59cb
\n throw new BaseException(ExceptionConstants.NOT_START);
\n }
\n \/\/ 3.\u5224\u65ad\u79d2\u6740\u662f\u5426\u5df2\u7ecf\u7ed3\u675f
\n if (voucher.getEndTime().isBefore(LocalDateTime.now())) {
\n \/\/ \u5c1a\u672a\u5f00\u59cb
\n throw new BaseException(ExceptionConstants.IS_END);
\n }
\n \/\/ 4.\u5224\u65ad\u5e93\u5b58\u662f\u5426\u5145\u8db3
\n if (voucher.getStock() < 1) {
\n \/\/ \u5e93\u5b58\u4e0d\u8db3
\n throw new BaseException(ExceptionConstants.NOT_ENOUGH);
\n }
\n Long userId = UserHolder.getUser().getId();
\n String key = RedisConstants.getLockOrderKey(userId);
\n RLock lock1 = redissonClient.getLock(key);
\n RLock lock2 = redissonClient2.getLock(key);
\n RLock lock3 = redissonClient3.getLock(key);
\n RLock lock = redissonClient.getMultiLock(lock1 , lock2 , lock3);
\n boolean isLock = lock.tryLock();
\n if (!isLock) {
\n \/\/ \u83b7\u53d6\u9501\u5931\u8d25，\u8fd4\u56de\u9519\u8bef\u6216\u91cd\u8bd5
\n throw new BaseException(ExceptionConstants.EXIST_BUY);
\n }
\n try {
\n IVoucherOrderService proxy = (IVoucherOrderService) AopContext.currentProxy();
\n return proxy.createVoucherOrder(voucherId);
\n } catch (IllegalStateException e) {
\n throw new RuntimeException(e);
\n } finally {
\n lock.unlock();
\n }
\n } <\/p>\n
public RLock getMultiLock(RLock… locks) {
\n return new RedissonMultiLock(locks);
\n }
\n final List<RLock> locks = new ArrayList();<\/p>\n
public RedissonMultiLock(RLock… locks) {
\n if (locks.length == 0) {
\n throw new IllegalArgumentException("Lock objects are not defined");
\n } else {
\n this.locks.addAll(Arrays.asList(locks));
\n }
\n } <\/p>\n
public boolean tryLock() {
\n try {
\n return this.tryLock(-1L, -1L, (TimeUnit)null);
\n } catch (InterruptedException var2) {
\n Thread.currentThread().interrupt();
\n return false;
\n }
\n }<\/p>\n
public boolean tryLock(long waitTime, long leaseTime, TimeUnit unit) throws InterruptedException {
\n long newLeaseTime = -1L;
\n if (leaseTime != -1L) {
\n if (waitTime == -1L) {
\n newLeaseTime = unit.toMillis(leaseTime);
\n } else {
\n newLeaseTime = unit.toMillis(waitTime) * 2L;
\n }
\n }<\/p>\n
long time = System.currentTimeMillis();
\n long remainTime = -1L;
\n if (waitTime != -1L) {
\n remainTime = unit.toMillis(waitTime);
\n }<\/p>\n
long lockWaitTime = this.calcLockWaitTime(remainTime);
\n int failedLocksLimit = this.failedLocksLimit();
\n List<RLock> acquiredLocks = new ArrayList(this.locks.size());
\n ListIterator<RLock> iterator = this.locks.listIterator();<\/p>\n
while(iterator.hasNext()) {
\n RLock lock = (RLock)iterator.next();<\/p>\n
boolean lockAcquired;
\n try {
\n if (waitTime == -1L && leaseTime == -1L) {
\n lockAcquired = lock.tryLock();
\n } else {
\n long awaitTime = Math.min(lockWaitTime, remainTime);
\n lockAcquired = lock.tryLock(awaitTime, newLeaseTime, TimeUnit.MILLISECONDS);
\n }
\n } catch (RedisResponseTimeoutException var21) {
\n this.unlockInner(Arrays.asList(lock));
\n lockAcquired = false;
\n } catch (Exception var22) {
\n lockAcquired = false;
\n }<\/p>\n
if (lockAcquired) {
\n acquiredLocks.add(lock);
\n } else {
\n if (this.locks.size() – acquiredLocks.size() == this.failedLocksLimit()) {
\n break;
\n }<\/p>\n
if (failedLocksLimit == 0) {
\n this.unlockInner(acquiredLocks);
\n if (waitTime == -1L) {
\n return false;
\n }<\/p>\n
failedLocksLimit = this.failedLocksLimit();
\n acquiredLocks.clear();<\/p>\n
while(iterator.hasPrevious()) {
\n iterator.previous();
\n }
\n } else {
\n –failedLocksLimit;
\n }
\n }<\/p>\n
if (remainTime != -1L) {
\n remainTime -= System.currentTimeMillis() – time;
\n time = System.currentTimeMillis();
\n if (remainTime <= 0L) {
\n this.unlockInner(acquiredLocks);
\n return false;
\n }
\n }
\n }<\/p>\n
if (leaseTime != -1L) {
\n List<RFuture<Boolean>> futures = new ArrayList(acquiredLocks.size());<\/p>\n
for(RLock rLock : acquiredLocks) {
\n RFuture<Boolean> future = ((RedissonLock)rLock).expireAsync(unit.toMillis(leaseTime), TimeUnit.MILLISECONDS);
\n futures.add(future);
\n }<\/p>\n
for(RFuture<Boolean> rFuture : futures) {
\n rFuture.syncUninterruptibly();
\n }
\n }<\/p>\n
return true;
\n } <\/p>\n
![\"\"](\"https:\/\/www.wsisp.com\/helps\/wp-content\/uploads\/2026\/02\/20260208031016-6987fe98983b5.png\")
<\/p>\n
\u76ee\u524d\u6211\u4eec\u7684\u6d41\u7a0b\u8fd8\u662f\u4e32\u884c\u6267\u884c\u7684，\u6027\u80fd\u4e0d\u662f\u5f88\u597d，\u6211\u4eec\u5728\u4e0b\u4e00\u7bc7\u8fdb\u884c\u5f02\u6b65\u4f18\u5316<\/p>\n","protected":false},"excerpt":{"rendered":"
\u4e00\u3001\u524d\u7f6e\u5185\u5bb9
\n1.1 \u5355\u673a\u79d2\u6740\u5b9e\u73b0
\n\u57fa\u4e8e Redis \u7684\u79d2\u6740\u5355\u673a\u7cfb\u7edf\u8fed\u4ee3\u5b9e\u73b0（\u9644\u8be6\u7ec6\u6d41\u7a0b\u56fe）-CSDN\u535a\u5ba2
\n1.2 SETNX\u5b9e\u73b0\u96c6\u7fa4\u6a21\u5f0f\u4e0b
\n\u57fa\u4e8e Redis \u7684\u79d2\u6740\u96c6\u7fa4\u7cfb\u7edf\u8fed\u4ee3\u5b9e\u73b0\u3010SETNX\u3011（\u9644\u8be6\u7ec6\u6d41\u7a0b\u56fe）-CSDN\u535a\u5ba2
\n1.3 \u524d\u7f6e\u6d41\u7a0b\u56fe\u00a0
\n1.4 \u524d\u7f6e\u95ee\u9898
\n\u7528SETNX\u5b9e\u73b0\u7684\u9501，\u6709\u4e0d\u53ef\u91cd\u5165，\u4e0d\u53ef\u91cd\u8bd5，\u9501\u8fc7\u671f，\u4e3b\u4ece\u4e0d\u4e00\u81f4\u7684\u95ee\u9898
\n\u4e8c\u3001Redis<\/p>\n","protected":false},"author":2,"featured_media":73760,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[7095,99,105,101,292,100,4647],"topic":[],"class_list":["post-73770","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-server","tag-7095","tag-java","tag-redis","tag-spring","tag-292","tag-100","tag-4647"],"yoast_head":"\n