{"id":201335,"date":"2025-05-10T10:50:42","date_gmt":"2025-05-10T02:50:42","guid":{"rendered":"https:\/\/server.hk\/cnblog\/201335\/"},"modified":"2025-05-10T10:50:42","modified_gmt":"2025-05-10T02:50:42","slug":"%e5%a6%82%e4%bd%95%e4%bd%bf%e7%94%a8%e6%b3%a8%e8%a7%a3%e6%96%b9%e5%bc%8f%e5%ae%9e%e7%8e%b0-redis-%e5%88%86%e5%b8%83%e5%bc%8f%e9%94%81","status":"publish","type":"post","link":"https:\/\/server.hk\/cnblog\/201335\/","title":{"rendered":"\u5982\u4f55\u4f7f\u7528\u6ce8\u89e3\u65b9\u5f0f\u5b9e\u73b0\u00a0Redis\u00a0\u5206\u5e03\u5f0f\u9501"},"content":{"rendered":"

<\/b> <\/p>\n

\u5982\u4f55\u4f7f\u7528\u6ce8\u89e3\u65b9\u5f0f\u5b9e\u73b0 Redis \u5206\u5e03\u5f0f\u9501<\/h1>\n

<\/i>\u6536\u85cf<\/span> <\/p>\n

\u5728\u6570\u636e\u5e93\u5b9e\u6218\u5f00\u53d1\u7684\u8fc7\u7a0b\u4e2d\uff0c\u6211\u4eec\u7ecf\u5e38\u4f1a\u9047\u5230\u4e00\u4e9b\u8fd9\u6837\u90a3\u6837\u7684\u95ee\u9898\uff0c\u7136\u540e\u8981\u5361\u597d\u534a\u5929\uff0c\u7b49\u95ee\u9898\u89e3\u51b3\u4e86\u624d\u53d1\u73b0\u539f\u6765\u4e00\u4e9b\u7ec6\u8282\u77e5\u8bc6\u70b9\u8fd8\u662f\u6ca1\u6709\u638c\u63e1\u597d\u3002\u4eca\u5929golang\u5b66\u4e60\u7f51\u5c31\u6574\u7406\u5206\u4eab\u300a\u5982\u4f55\u4f7f\u7528\u6ce8\u89e3\u65b9\u5f0f\u5b9e\u73b0 Redis \u5206\u5e03\u5f0f\u9501\u300b\uff0c\u804a\u804a\u5206\u5e03\u5f0f\u3001Redis\u3001\u9501\u3001\u5b9e\u73b0\u3001\u6ce8\u89e3\u65b9\u5f0f\uff0c\u5e0c\u671b\u53ef\u4ee5\u5e2e\u52a9\u5230\u6b63\u5728\u52aa\u529b\u8d5a\u94b1\u7684\u4f60\u3002<\/p>\n

\u5f15\u5165 Redisson<\/h2>\n
\n   \n    \n     org.redisson\n    \n    \n     redisson-spring-boot-starter\n    \n    \n     3.14.1\n    \n   <\/pre>\n
\u521d\u59cb\u5316 Redisson<\/h2>\n
@Configuration\npublic class RedissonConfiguration {\n  \n    \/\/ \u6b64\u5904\u66f4\u6362\u81ea\u5df1\u7684 Redis \u5730\u5740\u5373\u53ef\n    @Value(\"${redis.addr}\")\n    private String addr;\n\n    @Bean\n    public RedissonClient redisson() {\n        Config config = new Config();\n        config.useSingleServer()\n                .setAddress(String.format(\"%s%s\", \"redis:\/\/\", addr))\n                .setConnectionPoolSize(64)              \/\/ \u8fde\u63a5\u6c60\u5927\u5c0f\n                .setConnectionMinimumIdleSize(8)        \/\/ \u4fdd\u6301\u6700\u5c0f\u8fde\u63a5\u6570\n                .setConnectTimeout(1500)                \/\/ \u5efa\u7acb\u8fde\u63a5\u8d85\u65f6\u65f6\u95f4\n                .setTimeout(2000)                       \/\/ \u6267\u884c\u547d\u4ee4\u7684\u8d85\u65f6\u65f6\u95f4, \u4ece\u547d\u4ee4\u53d1\u9001\u6210\u529f\u65f6\u5f00\u59cb\u8ba1\u65f6\n                .setRetryAttempts(2)                    \/\/ \u547d\u4ee4\u6267\u884c\u5931\u8d25\u91cd\u8bd5\u6b21\u6570\n                .setRetryInterval(1000);                \/\/ \u547d\u4ee4\u91cd\u8bd5\u53d1\u9001\u65f6\u95f4\u95f4\u9694\n\n        return Redisson.create(config);\n    }\n}<\/pre>\n
\u8fd9\u6837\u6211\u4eec\u5c31\u53ef\u4ee5\u5728\u9879\u76ee\u91cc\u9762\u4f7f\u7528 Redisson \u4e86\u3002<\/p>\n
\u7f16\u5199 Redisson \u5206\u5e03\u5f0f\u9501\u5de5\u5177\u7c7b<\/h2>\n
Redis \u5206\u5e03\u5f0f\u9501\u7684\u5de5\u5177\u7c7b\uff0c\u4e3b\u8981\u662f\u8c03\u7528 Redisson \u5ba2\u6237\u7aef\u5b9e\u73b0\uff0c\u505a\u4e86\u8f7b\u5fae\u7684\u5c01\u88c5\u3002<\/p>\n
@Service\n@Slf4j\npublic class LockManager {\n    \/**\n     * \u6700\u5c0f\u9501\u7b49\u5f85\u65f6\u95f4\n     *\/\n    private static final int MIN_WAIT_TIME = 10;\n\n    @Resource\n    private RedissonClient redisson;\n\n    \/**\n     * \u52a0\u9501\uff0c\u52a0\u9501\u5931\u8d25\u629b\u9ed8\u8ba4\u5f02\u5e38 - \u64cd\u4f5c\u9891\u7e41, \u8bf7\u7a0d\u540e\u518d\u8bd5\n     *\n     * @param key        \u52a0\u9501\u552f\u4e00key\n     * @param expireTime \u9501\u8d85\u65f6\u65f6\u95f4 \u6beb\u79d2\n     * @param waitTime   \u52a0\u9501\u6700\u957f\u7b49\u5f85\u65f6\u95f4 \u6beb\u79d2\n     * @return LockResult  \u52a0\u9501\u7ed3\u679c\n     *\/\n    public LockResult lock(String key, long expireTime, long waitTime) {\n        return lock(key, expireTime, waitTime, () -> new BizException(ResponseEnum.COMMON_FREQUENT_OPERATION_ERROR));\n    }\n    \/**\n     * \u52a0\u9501\uff0c\u52a0\u9501\u5931\u8d25\u629b\u5f02\u5e38 - \u81ea\u5b9a\u4e49\u5f02\u5e38\n     *\n     * @param key               \u52a0\u9501\u552f\u4e00key\n     * @param expireTime        \u9501\u8d85\u65f6\u65f6\u95f4 \u6beb\u79d2\n     * @param waitTime          \u52a0\u9501\u6700\u957f\u7b49\u5f85\u65f6\u95f4 \u6beb\u79d2\n     * @param exceptionSupplier \u52a0\u9501\u5931\u8d25\u65f6\u629b\u8be5\u5f02\u5e38\uff0c\u4f20null\u65f6\u52a0\u9501\u5931\u8d25\u4e0d\u629b\u5f02\u5e38\n     * @return LockResult  \u52a0\u9501\u7ed3\u679c\n     *\/\n    private LockResult lock(String key, long expireTime, long waitTime, Supplier\n   \n     exceptionSupplier) {\n        if (waitTime \n\n    
\u52a0\u9501\u7ed3\u679c\u72b6\u6001\u679a\u4e3e\u7c7b\u3002<\/p>\n\n    
public enum LockResultStatus {\n    \/**\n     * \u901a\u4fe1\u6b63\u5e38\uff0c\u5e76\u4e14\u52a0\u9501\u6210\u529f\n     *\/\n    SUCCESS,\n    \/**\n     * \u901a\u4fe1\u6b63\u5e38\uff0c\u4f46\u83b7\u53d6\u9501\u5931\u8d25\n     *\/\n    FAILURE,\n    \/**\n     * \u901a\u4fe1\u5f02\u5e38\u548c\u5185\u90e8\u5f02\u5e38\uff0c\u9501\u72b6\u6001\u672a\u77e5\n     *\/\n    EXCEPTION;\n}<\/pre>\n
\u52a0\u9501\u7ed3\u679c\u7c7b\u5c01\u88c5\u4e86\u52a0\u9501\u72b6\u6001\u548cRLock\u3002<\/p>\n
@Setter\n@Getter\npublic class LockResult {\n\n    private LockResultStatus lockResultStatus;\n\n    private RLock rLock;\n}<\/pre>\n
\u81ea\u6b64\u6211\u4eec\u5c31\u53ef\u4ee5\u4f7f\u7528\u5206\u5e03\u5f0f\u9501\u4e86\uff0c\u4f7f\u7528\u65b9\u5f0f\uff1a<\/strong><\/p>\n
@Service\n@Slf4j\npublic class TestService {\n\n    @Resource\n    private LockManager lockManager;\n\n    public String test(String userId) {\n        \/\/ \u9501\uff1auserId, \u9501\u8d85\u65f6\u65f6\u95f4\uff1a5s, \u9501\u7b49\u5f85\u65f6\u95f4\uff1a50ms\n        LockResult lockResult = lockManager.lock(userId, 5000, 50);\n\n        try {\n            \/\/  \u4e1a\u52a1\u4ee3\u7801\n        } finally {\n            lockManager.unlock(lockResult.getRLock());\n        }\n\n        return \"\";\n    }\n}<\/pre>\n
\u4e3a\u4e86\u9632\u6b62\u7a0b\u5e8f\u53d1\u751f\u5f02\u5e38\uff0c\u6240\u4ee5\u6bcf\u6b21\u6211\u4eec\u90fd\u9700\u8981\u5728finally<\/code>\u4ee3\u7801\u5757\u91cc\u624b\u52a8\u91ca\u653e\u9501\u3002\u4e3a\u4e86\u66f4\u65b9\u4fbf\u4f18\u96c5\u7684\u4f7f\u7528 Redis \u5206\u5e03\u5f0f\u9501\uff0c\u6211\u4eec\u4f7f\u7528\u6ce8\u89e3\u65b9\u5f0f\u5b9e\u73b0\u4e0b\u3002<\/p>\n
\u58f0\u660e\u6ce8\u89e3 @Lock<\/h2>\n
@Target(ElementType.METHOD)\n@Retention(RetentionPolicy.RUNTIME)\npublic @interface Lock {\n    \/**\n     * lock key\n     *\/\n    String value();\n\n    \/**\n     * \u9501\u8d85\u65f6\u65f6\u95f4\uff0c\u9ed8\u8ba45000ms\n     *\/\n    long expireTime() default 5000L;\n\n    \/**\n     * \u9501\u7b49\u5f85\u65f6\u95f4\uff0c\u9ed8\u8ba450ms\n     *\/\n    long waitTime() default 50L;\n\n}<\/pre>\n
\u6ce8\u89e3\u89e3\u6790\u7c7b<\/h2>\n
@Aspect\n@Component\n@Slf4j\npublic class LockAnnotationParser {\n\n    @Resource\n    private LockManager lockManager;\n\n    \/**\n     * \u5b9a\u4e49\u5207\u70b9\n     *\/\n    @Pointcut(value = \"@annotation(Lock)\")\n    private void cutMethod() {\n    }\n\t\t\n    \/**\n     * \u5207\u70b9\u903b\u8f91\u5177\u4f53\u5b9e\u73b0\n     *\/\n    @Around(value = \"cutMethod() && @annotation(lock)\")\n    public Object parser(ProceedingJoinPoint point, Lock lock) throws Throwable {\n        String value = lock.value();\n        if (isEl(value)) {\n            value = getByEl(value, point);\n        }\n        LockResult lockResult = lockManager.lock(getRealLockKey(value), lock.expireTime(), lock.waitTime());\n        try {\n            return point.proceed();\n        } finally {\n            lockManager.unlock(lockResult.getRLock());\n        }\n    }\n\n    \/**\n     * \u89e3\u6790 SpEL \u8868\u8fbe\u5f0f\u5e76\u8fd4\u56de\u5176\u503c\n     *\/\n    private String getByEl(String el, ProceedingJoinPoint point) {\n        Method method = ((MethodSignature) point.getSignature()).getMethod();\n        String[] paramNames = getParameterNames(method);\n        Object[] arguments = point.getArgs();\n        ExpressionParser parser = new SpelExpressionParser();\n        Expression expression = parser.parseExpression(el);\n        EvaluationContext context = new StandardEvaluationContext();\n        for (int i = 0; i \n
\u4e0b\u9762\u4f7f\u7528\u6ce8\u89e3\u65b9\u5f0f\u4f7f\u7528\u5206\u5e03\u5f0f\u9501\uff1a<\/strong><\/p>\n
@Service\n@Slf4j\npublic class TestService {\n    @Lock(\"'test_'+#user.userId\")\n    public String test(User user) {\n        \/\/ \u4e1a\u52a1\u4ee3\u7801\n        return \"\";\n    }\n}<\/pre>\n
\u5f53\u7136\u4e5f\u53ef\u4ee5\u81ea\u5b9a\u4e49\u9501\u7684\u8d85\u65f6\u65f6\u95f4\u548c\u7b49\u5f85\u65f6\u95f4<\/p>\n
@Service\n@Slf4j\npublic class TestService {\n    @Lock(value = \"'test_'+#user.userId\", expireTime = 3000, waitTime = 30)\n    public String test(User user) {\n        \/\/ \u4e1a\u52a1\u4ee3\u7801\n        return \"\";\n    }\n}<\/pre>\n","protected":false},"excerpt":{"rendered":"
\u5982\u4f55\u4f7f\u7528\u6ce8\u89e3\u65b9\u5f0f\u5b9e\u73b0 ...<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[101],"tags":[],"class_list":["post-201335","post","type-post","status-publish","format-standard","hentry","category-database"],"_links":{"self":[{"href":"https:\/\/server.hk\/cnblog\/wp-json\/wp\/v2\/posts\/201335","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/server.hk\/cnblog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/server.hk\/cnblog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/server.hk\/cnblog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/server.hk\/cnblog\/wp-json\/wp\/v2\/comments?post=201335"}],"version-history":[{"count":0,"href":"https:\/\/server.hk\/cnblog\/wp-json\/wp\/v2\/posts\/201335\/revisions"}],"wp:attachment":[{"href":"https:\/\/server.hk\/cnblog\/wp-json\/wp\/v2\/media?parent=201335"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/server.hk\/cnblog\/wp-json\/wp\/v2\/categories?post=201335"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/server.hk\/cnblog\/wp-json\/wp\/v2\/tags?post=201335"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}