\u5927\u5bb6\u597d\uff0c\u6211\u4eec\u53c8\u89c1\u9762\u4e86\u554a~\u672c\u6587\u300aSpring Boot\u57fa\u4e8eRedisson\u5b9e\u73b0Redis\u5206\u5e03\u5f0f\u53ef\u91cd\u5165\u9501\u6e90\u7801\u8be6\u89e3\u300b<\/span>\u7684\u5185\u5bb9\u4e2d\u5c06\u4f1a\u6d89\u53ca\u5230<\/span>\u7b49\u7b49\u3002\u5982\u679c\u4f60\u6b63\u5728\u5b66\u4e60\u6570\u636e\u5e93<\/span>\u76f8\u5173\u77e5\u8bc6\uff0c\u6b22\u8fce\u5173\u6ce8\u6211\uff0c\u4ee5\u540e\u4f1a\u7ed9\u5927\u5bb6\u5e26\u6765\u66f4\u591a\u6570\u636e\u5e93<\/span>\u76f8\u5173\u6587\u7ae0\uff0c\u5e0c\u671b\u6211\u4eec\u80fd\u4e00\u8d77\u8fdb\u6b65\uff01\u4e0b\u9762\u5c31\u5f00\u59cb\u672c\u6587\u7684\u6b63\u5f0f\u5185\u5bb9~<\/p>\n \u6211\u4eec\u5728\u5b9e\u73b0\u4f7f\u7528Redis\u5b9e\u73b0\u5206\u5e03\u5f0f\u9501\uff0c\u6700\u5f00\u59cb\u4e00\u822c\u4f7f\u7528 redis\u4e2d\u6587\u5b98\u7f51<\/p>\n Redisson\u5730\u5740<\/p>\n 5. Redisson\u7ed3\u6784<\/p>\n \u4e00\u6b65\u6b65\u5f80\u4e0b\u627e\u6e90\u7801\uff1ascheduleExpirationRenewal —>renewExpiration<\/p>\n \u6839\u636e\u4e0b\u9762\u6e90\u7801\uff0c\u5b9a\u65f6\u4efb\u52a1\u5237\u65b0\u65f6\u95f4\u4e3a\uff1ainternalLockLeaseTime \/ 3\uff0c\u662f\u770b\u95e8\u72d7\u76841\/3\uff0c\u5373\u4e3a10s\u5237\u65b0\u4e00\u6b21<\/p>\n 1. \u6253\u5f00\u5b9e\u73b0\u7c7b<\/p>\n 2. \u65b9\u6cd5 3. \u76f4\u63a5\u6765\u5230\u5c1d\u8bd5\u83b7\u5f97\u9501 4. \u6253\u5f00 \u6211\u4eec\u4e0d\u96be\u53d1\u73b0\u548c\u6ca1\u6709\u4f20\u8fc7\u671f\u65f6\u95f4\u7684\u65b9\u6cd5\u4e00\u6837\uff0c\u53ea\u4e0d\u8fc7leaseTime\u7684\u503c\u53d8\u4e86\u3002<\/p>\n 1. \u6253\u5f00\u65b9\u6cd5\u5b9e\u73b0<\/p>\n 2. \u6253\u5f00 3. \u6253\u5f00 Spring Boot\u57fa\u4e8eRedisson\u5b9e\u73b0Redis\u5206\u5e03\u5f0f\u53ef\u91cd\u5165\u9501\u6e90\u7801\u8be6\u89e3 \u6536\u85cf \u5927\u5bb6\u597d\uff0c\u6211\u4eec\u53c8\u89c1\u9762\u4e86\u554a~\u672c\u6587\u300aSpring Boot\u57fa\u4e8eRedisson\u5b9e\u73b0Redis\u5206\u5e03\u5f0f\u53ef\u91cd\u5165\u9501\u6e90\u7801\u8be6\u89e3\u300b\u7684\u5185\u5bb9\u4e2d\u5c06\u4f1a\u6d89\u53ca\u5230\u7b49\u7b49\u3002\u5982\u679c\u4f60\u6b63\u5728\u5b66\u4e60\u6570\u636e\u5e93\u76f8\u5173\u77e5\u8bc6\uff0c\u6b22\u8fce\u5173\u6ce8\u6211\uff0c\u4ee5\u540e\u4f1a\u7ed9\u5927\u5bb6\u5e26\u6765\u66f4\u591a\u6570\u636e\u5e93\u76f8\u5173\u6587\u7ae0\uff0c\u5e0c\u671b\u6211\u4eec\u80fd\u4e00\u8d77\u8fdb\u6b65\uff01\u4e0b\u9762\u5c31\u5f00\u59cb\u672c\u6587\u7684\u6b63\u5f0f\u5185\u5bb9~ \u4e00\u3001\u524d\u8a00 \u6211\u4eec\u5728\u5b9e\u73b0\u4f7f\u7528Redis\u5b9e\u73b0\u5206\u5e03\u5f0f\u9501\uff0c\u6700\u5f00\u59cb\u4e00\u822c\u4f7f\u7528SET resource-name anystring NX EX max-lock-time\u8fdb\u884c\u52a0\u9501\uff0c\u4f7f\u7528Lua\u811a\u672c\u4fdd\u8bc1\u539f\u5b50\u6027\u8fdb\u884c\u5b9e\u73b0\u91ca\u653e\u9501\u3002\u8fd9\u6837\u624b\u52a8\u5b9e\u73b0\u6bd4\u8f83\u9ebb\u70e6\uff0c\u5bf9\u6b64Redis\u5b98\u7f51\u4e5f\u660e\u786e\u8bf4Java\u7248\u4f7f\u7528Redisson\u6765\u5b9e\u73b0\u3002\u5c0f\u7f16\u4e5f\u662f\u770b\u4e86\u5b98\u7f51\u6162\u6162\u7684\u6478\u7d22\u6e05\u695a\uff0c\u7279\u5199\u6b64\u8bb0\u5f55\u4e00\u4e0b\u3002\u4ece\u5b98\u7f51\u5230\u6574\u5408Springboot\u5230\u6e90\u7801\u89e3\u8bfb\uff0c\u4ee5\u5355\u8282\u70b9\u4e3a\u4f8b\u3002 \u4e8c\u3001\u4e3a\u4ec0\u4e48\u4f7f\u7528Redisson 1. \u6211\u4eec\u6253\u5f00\u5b98\u7f51 redis\u4e2d\u6587\u5b98\u7f51 2. \u6211\u4eec\u53ef\u4ee5\u770b\u5230\u5b98\u65b9\u8ba9\u6211\u4eec\u53bb\u4f7f\u7528\u5176\u4ed6 3. \u6253\u5f00\u5b98\u65b9\u63a8\u8350 4. \u627e\u5230\u6587\u6863 Redisson\u5730\u5740 5. Redisson\u7ed3\u6784 \u4e09\u3001Springboot\u6574\u5408Redisson 1. \u5bfc\u5165\u4f9d\u8d56 org.springframework.boot spring-boot-starter-data-redis redis.clients jedis org.redisson redisson 3.12.0 2. \u4ee5\u5b98\u7f51\u4e3a\u4f8b\u67e5\u770b\u5982\u4f55\u914d\u7f6e 3. \u7f16\u5199\u914d\u7f6e\u7c7b import org.redisson.Redisson; import org.redisson.api.RedissonClient; import org.redisson.config.Config; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; \/** * @author wangzhenjun * @date 2022\/2\/9 9:57 *\/ […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[8],"tags":[],"class_list":["post-67892","post","type-post","status-publish","format-standard","hentry","category-os"],"_links":{"self":[{"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/posts\/67892","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/comments?post=67892"}],"version-history":[{"count":0,"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/posts\/67892\/revisions"}],"wp:attachment":[{"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/media?parent=67892"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/categories?post=67892"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/tags?post=67892"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}\n
<\/ul>\n<\/ul>\n
\n
<\/ul>\n<\/ul>\n
\u4e00\u3001\u524d\u8a00<\/h3>\n
SET resource-name anystring NX EX max-lock-time<\/code>\u8fdb\u884c\u52a0\u9501\uff0c\u4f7f\u7528Lua\u811a\u672c\u4fdd\u8bc1\u539f\u5b50\u6027\u8fdb\u884c\u5b9e\u73b0\u91ca\u653e\u9501\u3002\u8fd9\u6837\u624b\u52a8\u5b9e\u73b0\u6bd4\u8f83\u9ebb\u70e6\uff0c\u5bf9\u6b64Redis\u5b98\u7f51\u4e5f\u660e\u786e\u8bf4Java\u7248\u4f7f\u7528Redisson<\/code>\u6765\u5b9e\u73b0\u3002\u5c0f\u7f16\u4e5f\u662f\u770b\u4e86\u5b98\u7f51\u6162\u6162\u7684\u6478\u7d22\u6e05\u695a\uff0c\u7279\u5199\u6b64\u8bb0\u5f55\u4e00\u4e0b\u3002\u4ece\u5b98\u7f51\u5230\u6574\u5408Springboot\u5230\u6e90\u7801\u89e3\u8bfb\uff0c\u4ee5\u5355\u8282\u70b9\u4e3a\u4f8b\u3002<\/p>\n\u4e8c\u3001\u4e3a\u4ec0\u4e48\u4f7f\u7528Redisson<\/h3>\n
1. \u6211\u4eec\u6253\u5f00\u5b98\u7f51<\/h4>\n
2. \u6211\u4eec\u53ef\u4ee5\u770b\u5230\u5b98\u65b9\u8ba9\u6211\u4eec\u53bb\u4f7f\u7528\u5176\u4ed6<\/h4>\n
![\"Spring](\"https:\/\/www.17golang.com\/uploads\/20230507\/1683460802645792c2931cf.png\" "\\"Spring")
<\/p>\n3. \u6253\u5f00\u5b98\u65b9\u63a8\u8350<\/h4>\n
![\"Spring](\"https:\/\/www.17golang.com\/uploads\/20230507\/1683460802645792c29db56.jpg\" "\\"Spring")
<\/p>\n4. \u627e\u5230\u6587\u6863<\/h4>\n
![\"Spring](\"https:\/\/www.17golang.com\/uploads\/20230507\/1683460802645792c2a78a1.jpg\" "\\"Spring")
<\/p>\n![\"Spring](\"https:\/\/www.17golang.com\/uploads\/20230507\/1683460802645792c2b2469.png\" "\\"Spring")
<\/p>\n\u4e09\u3001Springboot\u6574\u5408Redisson<\/h3>\n
1. \u5bfc\u5165\u4f9d\u8d56<\/h4>\n
\n \n \n \n \n org.springframework.boot\n \n \n \n spring-boot-starter-data-redis\n \n \n \n \n \n \n redis.clients\n \n \n \n jedis\n \n \n \n \n \n \n \n org.redisson\n \n \n \n redisson\n \n \n \n 3.12.0\n \n <\/pre>\n
2. \u4ee5\u5b98\u7f51\u4e3a\u4f8b\u67e5\u770b\u5982\u4f55\u914d\u7f6e<\/h4>\n
![\"Spring](\"https:\/\/www.17golang.com\/uploads\/20230507\/1683460802645792c2bd56d.png\" "\\"Spring")
<\/p>\n3. \u7f16\u5199\u914d\u7f6e\u7c7b<\/h4>\n
import org.redisson.Redisson;\nimport org.redisson.api.RedissonClient;\nimport org.redisson.config.Config;\nimport org.springframework.context.annotation.Bean;\nimport org.springframework.context.annotation.Configuration;\n\n\/**\n * @author wangzhenjun\n * @date 2022\/2\/9 9:57\n *\/\n@Configuration\npublic class MyRedissonConfig {\n\n \/**\n * \u6240\u6709\u5bf9redisson\u7684\u4f7f\u7528\u90fd\u662f\u901a\u8fc7RedissonClient\u6765\u64cd\u4f5c\u7684\n * @return\n *\/\n @Bean(destroyMethod=\"shutdown\")\n public RedissonClient redisson(){\n \/\/ 1. \u521b\u5efa\u914d\u7f6e\n Config config = new Config();\n \/\/ \u4e00\u5b9a\u8981\u52a0redis:\/\/\n config.useSingleServer().setAddress(\"redis:\/\/192.168.17.130:6379\");\n \/\/ 2. \u6839\u636econfig\u521b\u5efa\u51faredissonClient\u5b9e\u4f8b\n RedissonClient redissonClient = Redisson.create(config);\n return redissonClient;\n }\n}<\/pre>\n4. \u5b98\u7f51\u6d4b\u8bd5\u52a0\u9501\u4f8b\u5b50<\/h4>\n
![\"Spring](\"https:\/\/www.17golang.com\/uploads\/20230507\/1683460802645792c2c8262.jpg\" "\\"Spring")
<\/p>\n5. \u6839\u636e\u5b98\u7f51\u7b80\u5355Controller\u63a5\u53e3\u7f16\u5199<\/h4>\n
@ResponseBody\n@GetMapping(\"\/hello\")\npublic String hello(){\n \/\/ 1.\u83b7\u53d6\u4e00\u628a\u9501\uff0c\u53ea\u8981\u9501\u540d\u5b57\u4e00\u6837\uff0c\u5c31\u662f\u540c\u4e00\u628a\u9501\n RLock lock = redisson.getLock(\"my-lock\");\n \/\/ 2. \u52a0\u9501\n lock.lock();\/\/ \u963b\u585e\u8bd5\u7b49\u5f85 \u9ed8\u8ba4\u52a0\u7684\u90fd\u662f30s\n \/\/ \u5e26\u53c2\u6570\u60c5\u51b5\n \/\/ lock.lock(10, TimeUnit.SECONDS);\/\/ 10s\u81ea\u52a8\u89e3\u9501\uff0c\u81ea\u52a8\u89e3\u9501\u65f6\u95f4\u4e00\u5b9a\u8981\u5927\u4e8e\u4e1a\u52a1\u7684\u6267\u884c\u65f6\u95f4\u3002\n try {\n System.out.println(\"\u52a0\u9501\u6210\u529f\" + Thread.currentThread().getId());\n Thread.sleep(30000);\n } catch (InterruptedException e) {\n e.printStackTrace();\n } finally {\n \/\/ 3. \u89e3\u9501\n System.out.println(\"\u89e3\u9501\u6210\u529f\uff1a\" + Thread.currentThread().getId());\n lock.unlock();\n }\n return \"hello\";\n}<\/pre>\n6. \u6d4b\u8bd5<\/h4>\n
![\"Spring](\"https:\/\/www.17golang.com\/uploads\/20230507\/1683460802645792c2d2778.jpg\" "\\"Spring")
<\/p>\n\u56db\u3001lock.lock()\u6e90\u7801\u5206\u6790<\/h3>\n
1. \u6253\u5f00RedissonLock\u5b9e\u73b0\u7c7b<\/h4>\n
![\"Spring](\"https:\/\/www.17golang.com\/uploads\/20230507\/1683460802645792c2de5bd.png\" "\\"Spring")
<\/p>\n2. \u627e\u5230\u5b9e\u73b0\u65b9\u6cd5<\/h4>\n
@Override\npublic void lock() {\n try {\n \t\/\/ \u6211\u4eec\u53d1\u73b0\u4e0d\u7a7f\u8fc7\u671f\u65f6\u95f4\u6e90\u7801\u9ed8\u8ba4\u8fc7\u671f\u65f6\u95f4\u4e3a-1\n lock(-1, null, false);\n } catch (InterruptedException e) {\n throw new IllegalStateException();\n }\n}<\/pre>\n3. \u6309\u4f4fCtrl\u8fdb\u53bblock\u65b9\u6cd5<\/h4>\n
private void lock(long leaseTime, TimeUnit unit, boolean interruptibly) throws InterruptedException {\n\t\/\/ \u83b7\u53d6\u7ebf\u7a0b\u7684id\uff0c\u5360\u6709\u9501\u7684\u65f6\u5019field\u7684\u503c\u4e3aUUID:\u7ebf\u7a0b\u53f7id\n long threadId = Thread.currentThread().getId();\n \/\/ \u5c1d\u8bd5\u83b7\u5f97\u9501\n Long ttl = tryAcquire(leaseTime, unit, threadId);\n \/\/ lock acquired \u83b7\u5f97\u9501\uff0c\u8fd4\u56de\n if (ttl == null) {\n return;\n }\n\t\/\/ \u8fd9\u91cc\u8bf4\u660e\u83b7\u53d6\u9501\u5931\u8d25\uff0c\u5c31\u901a\u8fc7\u7ebf\u7a0bid\u8ba2\u9605\u8fd9\u4e2a\u9501\n RFuture\n \n future = subscribe(threadId);\n if (interruptibly) {\n commandExecutor.syncSubscriptionInterrupted(future);\n } else {\n commandExecutor.syncSubscription(future);\n }\n\n try {\n \t\/\/ \u8fd9\u91cc\u8fdb\u884c\u81ea\u65cb\uff0c\u4e0d\u65ad\u5c1d\u8bd5\u83b7\u53d6\u9501\n while (true) {\n \t\/\/ \u7ee7\u7eed\u5c1d\u8bd5\u83b7\u53d6\u9501\n ttl = tryAcquire(leaseTime, unit, threadId);\n \/\/ lock acquired \u83b7\u53d6\u6210\u529f\n if (ttl == null) {\n \t\/\/ \u76f4\u63a5\u8fd4\u56de\uff0c\u6311\u51fa\u81ea\u65cb\n break;\n }\n\n \/\/ waiting for message \u7ee7\u7eed\u7b49\u5f85\u83b7\u5f97\u9501\n if (ttl >= 0) {\n try {\n future.getNow().getLatch().tryAcquire(ttl, TimeUnit.MILLISECONDS);\n } catch (InterruptedException e) {\n if (interruptibly) {\n throw e;\n }\n future.getNow().getLatch().tryAcquire(ttl, TimeUnit.MILLISECONDS);\n }\n } else {\n if (interruptibly) {\n future.getNow().getLatch().acquire();\n } else {\n future.getNow().getLatch().acquireUninterruptibly();\n }\n }\n }\n } finally {\n \t\/\/ \u53d6\u6d88\u8ba2\u9605\n unsubscribe(future, threadId);\n }\n\/\/ get(lockAsync(leaseTime, unit));\n}\n <\/pre>\n4. \u8fdb\u53bb\u5c1d\u8bd5\u83b7\u53d6\u9501\u65b9\u6cd5<\/h4>\n
![\"Spring](\"https:\/\/www.17golang.com\/uploads\/20230507\/1683460802645792c2e7e6d.png\" "\\"Spring")
<\/p>\nprivate Long tryAcquire(long leaseTime, TimeUnit unit, long threadId) {\n\t\/\/ \u76f4\u63a5\u8fdb\u5165\u5f02\u6b65\u65b9\u6cd5\n return get(tryAcquireAsync(leaseTime, unit, threadId));\n}\n\nprivate \n \n RFuture\n \n tryAcquireAsync(long leaseTime, TimeUnit unit, long threadId) { \/\/ \u8fd9\u91cc\u8fdb\u884c\u5224\u65ad\u5982\u679c\u6ca1\u6709\u8bbe\u7f6e\u53c2\u6570leaseTime = -1 if (leaseTime != -1) { return tryLockInnerAsync(leaseTime, unit, threadId, RedisCommands.EVAL_LONG); } \/\/ \u6b64\u65b9\u6cd5\u8fdb\u884c\u83b7\u5f97\u9501\uff0c\u8fc7\u671f\u65f6\u95f4\u4e3a\u770b\u95e8\u72d7\u7684\u9ed8\u8ba4\u65f6\u95f4 \/\/ private long lockWatchdogTimeout = 30 * 1000;\u770b\u95e8\u72d7\u9ed8\u8ba4\u8fc7\u671f\u65f6\u95f4\u4e3a30s \/\/ \u52a0\u9501\u548c\u8fc7\u671f\u65f6\u95f4\u8981\u4fdd\u8bc1\u539f\u5b50\u6027\uff0c\u8fd9\u4e2a\u65b9\u6cd5\u540e\u9762\u80af\u5b9a\u8c03\u7528\u6267\u884c\u4e86Lua\u811a\u672c\uff0c\u6211\u4eec\u4e0b\u9762\u5728\u770b RFuture\n \n ttlRemainingFuture = tryLockInnerAsync(commandExecutor.getConnectionManager().getCfg().getLockWatchdogTimeout(), TimeUnit.MILLISECONDS, threadId, RedisCommands.EVAL_LONG); \/\/ \u5f00\u542f\u4e00\u4e2a\u5b9a\u65f6\u4efb\u52a1\u8fdb\u884c\u4e0d\u65ad\u5237\u65b0\u8fc7\u671f\u65f6\u95f4 ttlRemainingFuture.onComplete((ttlRemaining, e) -> { if (e != null) { return; } \/\/ lock acquired \u83b7\u5f97\u9501 if (ttlRemaining == null) { \/\/ \u5237\u65b0\u8fc7\u671f\u65f6\u95f4\u65b9\u6cd5\uff0c\u6211\u4eec\u4e0b\u4e00\u6b65\u8be6\u7ec6\u8bf4\u4e00\u4e0b scheduleExpirationRenewal(threadId); }); return ttlRemainingFuture;\n \n \n <\/pre>\n5. \u67e5\u770btryLockInnerAsync()\u65b9\u6cd5<\/h4>\n
\n \n RFuture\n \n tryLockInnerAsync(long leaseTime, TimeUnit unit, long threadId, RedisStrictCommand\n \n command) { internalLockLeaseTime = unit.toMillis(leaseTime); return commandExecutor.evalWriteAsync(getName(), LongCodec.INSTANCE, command, \/\/ \u9996\u5148\u5224\u65ad\u9501\u662f\u5426\u5b58\u5728 \"if (redis.call('exists', KEYS[1]) == 0) then \" + \/\/ \u5b58\u5728\u5219\u83b7\u53d6\u9501 \"redis.call('hset', KEYS[1], ARGV[2], 1); \" + \/\/ \u7136\u540e\u8bbe\u7f6e\u8fc7\u671f\u65f6\u95f4 \"redis.call('pexpire', KEYS[1], ARGV[1]); \" + \"return nil; \" + \"end; \" + \/\/ hexists\u67e5\u770b\u54c8\u5e0c\u8868\u7684\u6307\u5b9a\u5b57\u6bb5\u662f\u5426\u5b58\u5728\uff0c\u5b58\u5728\u9501\u5e76\u4e14\u662f\u5f53\u524d\u7ebf\u7a0b\u6301\u6709\u9501 \"if (redis.call('hexists', KEYS[1], ARGV[2]) == 1) then \" + \/\/ hincrby\u81ea\u589e\u4e00 \"redis.call('hincrby', KEYS[1], ARGV[2], 1); \" + \/\/ \u9501\u7684\u503c\u5927\u4e8e1\uff0c\u8bf4\u660e\u662f\u53ef\u91cd\u5165\u9501\uff0c\u91cd\u7f6e\u8fc7\u671f\u65f6\u95f4 \"redis.call('pexpire', KEYS[1], ARGV[1]); \" + \"return nil; \" + \"end; \" + \/\/ \u9501\u5df2\u5b58\u5728\uff0c\u4e14\u4e0d\u662f\u672c\u7ebf\u7a0b\uff0c\u5219\u8fd4\u56de\u8fc7\u671f\u65f6\u95f4ttl \"return redis.call('pttl', KEYS[1]);\", Collections.\n singletonList(getName()), internalLockLeaseTime, getLockName(threadId)); }\n \n \n <\/pre>\n6. \u8fdb\u51654\u7559\u4e0b\u7684\u5b9a\u65f6\u4efb\u52a1scheduleExpirationRenewal()\u65b9\u6cd5<\/h4>\n
private void renewExpiration() {\n ExpirationEntry ee = EXPIRATION_RENEWAL_MAP.get(getEntryName());\n if (ee == null) {\n return;\n }\n \n Timeout task = commandExecutor.getConnectionManager().newTimeout(new TimerTask() {\n @Override\n public void run(Timeout timeout) throws Exception {\n ExpirationEntry ent = EXPIRATION_RENEWAL_MAP.get(getEntryName());\n if (ent == null) {\n return;\n }\n Long threadId = ent.getFirstThreadId();\n if (threadId == null) {\n return;\n }\n \n RFuture\n \n future = renewExpirationAsync(threadId);\n future.onComplete((res, e) -> {\n if (e != null) {\n log.error(\"Can't update lock \" + getName() + \" expiration\", e);\n return;\n }\n \n if (res) {\n \/\/ reschedule itself\n renewExpiration();\n }\n });\n }\n }, internalLockLeaseTime \/ 3, TimeUnit.MILLISECONDS);\n \n ee.setTimeout(task);\n}\n <\/pre>\n\u4e94\u3001lock.lock(10, TimeUnit.SECONDS)\u6e90\u7801\u5206\u6790<\/h3>\n
@Override\npublic void lock(long leaseTime, TimeUnit unit) {\n try {\n \t\/\/ \u8fd9\u91cc\u7684\u8fc7\u671f\u65f6\u95f4\u4e3a\u6211\u4eec\u8f93\u5165\u768410\n lock(leaseTime, unit, false);\n } catch (InterruptedException e) {\n throw new IllegalStateException();\n }\n}<\/pre>\nlock()<\/code>\u5b9e\u73b0\u5c55\u793a\uff0c\u540c\u4e09.3\u6e90\u7801<\/p>\ntryAcquireAsync()<\/code>\u65b9\u6cd5<\/p>\nprivate \n \n RFuture\n \n tryAcquireAsync(long leaseTime, TimeUnit unit, long threadId) { \/\/ \u8fd9\u91cc\u8fdb\u884c\u5224\u65ad\u5982\u679c\u6ca1\u6709\u8bbe\u7f6e\u53c2\u6570leaseTime = -1,\u6b64\u65f6\u6211\u4eec\u4e3a10 if (leaseTime != -1) { \/\/ \u6765\u5230\u6b64\u65b9\u6cd5 return tryLockInnerAsync(leaseTime, unit, threadId, RedisCommands.EVAL_LONG); } \/\/ \u6b64\u5904\u7701\u7565\u540e\u9762\u5185\u5bb9\uff0c\u524d\u9762\u4ee5\u8be6\u7ec6\u8bf4\u660e\u3002\u3002\u3002\u3002 }\n \n <\/pre>\ntryLockInnerAsync()<\/code>\u65b9\u6cd5<\/p>\n\n \n RFuture\n \n tryLockInnerAsync(long leaseTime, TimeUnit unit, long threadId, RedisStrictCommand\n \n command) { internalLockLeaseTime = unit.toMillis(leaseTime); return commandExecutor.evalWriteAsync(getName(), LongCodec.INSTANCE, command, \/\/ \u9996\u5148\u5224\u65ad\u9501\u662f\u5426\u5b58\u5728 \"if (redis.call('exists', KEYS[1]) == 0) then \" + \/\/ \u5b58\u5728\u5219\u83b7\u53d6\u9501 \"redis.call('hset', KEYS[1], ARGV[2], 1); \" + \/\/ \u7136\u540e\u8bbe\u7f6e\u8fc7\u671f\u65f6\u95f4 \"redis.call('pexpire', KEYS[1], ARGV[1]); \" + \"return nil; \" + \"end; \" + \/\/ hexists\u67e5\u770b\u54c8\u5e0c\u8868\u7684\u6307\u5b9a\u5b57\u6bb5\u662f\u5426\u5b58\u5728\uff0c\u5b58\u5728\u9501\u5e76\u4e14\u662f\u5f53\u524d\u7ebf\u7a0b\u6301\u6709\u9501 \"if (redis.call('hexists', KEYS[1], ARGV[2]) == 1) then \" + \/\/ hincrby\u81ea\u589e\u4e00 \"redis.call('hincrby', KEYS[1], ARGV[2], 1); \" + \/\/ \u9501\u7684\u503c\u5927\u4e8e1\uff0c\u8bf4\u660e\u662f\u53ef\u91cd\u5165\u9501\uff0c\u91cd\u7f6e\u8fc7\u671f\u65f6\u95f4 \"redis.call('pexpire', KEYS[1], ARGV[1]); \" + \"return nil; \" + \"end; \" + \/\/ \u9501\u5df2\u5b58\u5728\uff0c\u4e14\u4e0d\u662f\u672c\u7ebf\u7a0b\uff0c\u5219\u8fd4\u56de\u8fc7\u671f\u65f6\u95f4ttl \"return redis.call('pttl', KEYS[1]);\", Collections.\n singletonList(getName()), internalLockLeaseTime, getLockName(threadId)); }\n \n \n <\/pre>\n\u516d\u3001lock.unlock()\u6e90\u7801\u5206\u6790<\/h3>\n
@Override\npublic void unlock() {\n try {\n \t\/\/ \u70b9\u51fb\u8fdb\u5165\u91ca\u653e\u9501\u65b9\u6cd5\n get(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 \n\/\/ Future\n \n future = unlockAsync();\n\/\/ future.awaitUninterruptibly();\n\/\/ if (future.isSuccess()) {\n\/\/ return;\n\/\/ }\n\/\/ if (future.cause() instanceof IllegalMonitorStateException) {\n\/\/ throw (IllegalMonitorStateException)future.cause();\n\/\/ }\n\/\/ throw commandExecutor.convertException(future);\n}\n <\/pre>\nunlockAsync()<\/code>\u65b9\u6cd5<\/p>\n@Override\npublic RFuture\n \n unlockAsync(long threadId) {\n RPromise\n \n result = new RedissonPromise\n \n (); \/\/ \u89e3\u9501\u65b9\u6cd5\uff0c\u540e\u9762\u5c55\u5f00\u8bf4 RFuture\n \n future = unlockInnerAsync(threadId); \/\/ \u5b8c\u6210 future.onComplete((opStatus, e) -> { if (e != null) { \/\/ \u53d6\u6d88\u5230\u671f\u7eed\u8ba2 cancelExpirationRenewal(threadId); \/\/ \u5c06\u8fd9\u4e2a\u672a\u6765\u6807\u8bb0\u4e3a\u5931\u8d25\u5e76\u901a\u77e5\u6240\u6709\u4eba result.tryFailure(e); return; } \/\/ \u72b6\u6001\u4e3a\u7a7a\uff0c\u8bf4\u660e\u89e3\u9501\u7684\u7ebf\u7a0b\u548c\u5f53\u524d\u9501\u4e0d\u662f\u540c\u4e00\u4e2a\u7ebf\u7a0b if (opStatus == null) { IllegalMonitorStateException cause = new IllegalMonitorStateException(\"attempt to unlock lock, not locked by current thread by node id: \" + id + \" thread-id: \" + threadId); result.tryFailure(cause); return; } cancelExpirationRenewal(threadId); result.trySuccess(null); }); return result; }\n \n \n \n <\/pre>\nunlockInnerAsync()<\/code>\u65b9\u6cd5<\/p>\nprotected RFuture\n \n unlockInnerAsync(long threadId) {\n return commandExecutor.evalWriteAsync(getName(), LongCodec.INSTANCE, RedisCommands.EVAL_BOOLEAN,\n \t\t\/\/ \u5224\u65ad\u91ca\u653e\u9501\u7684\u7ebf\u7a0b\u548c\u5df2\u5b58\u5728\u9501\u7684\u7ebf\u7a0b\u662f\u4e0d\u662f\u540c\u4e00\u4e2a\u7ebf\u7a0b\uff0c\u4e0d\u662f\u8fd4\u56de\u7a7a\n \"if (redis.call('hexists', KEYS[1], ARGV[3]) == 0) then \" +\n \"return nil;\" +\n \"end; \" +\n \/\/ \u91ca\u653e\u9501\u540e\uff0c\u52a0\u9501\u6b21\u6570\u51cf\u4e00\n \"local counter = redis.call('hincrby', KEYS[1], ARGV[3], -1); \" +\n \/\/ \u5224\u65ad\u5269\u4f59\u6570\u91cf\u662f\u5426\u5927\u4e8e0\n \"if (counter > 0) then \" +\n \t\/\/ \u5927\u4e8e0 \uff0c\u5219\u5237\u65b0\u8fc7\u671f\u65f6\u95f4\n \"redis.call('pexpire', KEYS[1], ARGV[2]); \" +\n \"return 0; \" +\n \"else \" +\n \t\/\/ \u91ca\u653e\u9501\uff0c\u5220\u9664key\u5e76\u53d1\u5e03\u9501\u91ca\u653e\u7684\u6d88\u606f\n \"redis.call('del', KEYS[1]); \" +\n \"redis.call('publish', KEYS[2], ARGV[1]); \" +\n \"return 1; \"+\n \"end; \" +\n \"return nil;\",\n Arrays.\n asList(getName(), getChannelName()), LockPubSub.UNLOCK_MESSAGE, internalLockLeaseTime, getLockName(threadId)); }\n <\/pre>\n","protected":false},"excerpt":{"rendered":"