{"id":4338,"date":"2023-07-21T14:24:31","date_gmt":"2023-07-21T06:24:31","guid":{"rendered":"https:\/\/www.zeroheart.xyz\/wordpress\/?p=4338"},"modified":"2023-07-21T14:24:31","modified_gmt":"2023-07-21T06:24:31","slug":"springboot%e9%99%90%e6%b5%81","status":"publish","type":"post","link":"https:\/\/www.zeroheart.xyz\/wordpress\/?p=4338","title":{"rendered":"springboot\u9650\u6d41"},"content":{"rendered":"\n

\u539f\u6587\uff1amp.weixin.qq.com\/s\/8ICTZRvgJlI5F8gO13JwDA<\/a><\/p>\n\n\n\n

\u4e00\u3001\u80cc\u666f<\/strong><\/p>\n\n\n\n

\u9650\u6d41\u5bf9\u4e8e\u4e00\u4e2a\u5fae\u670d\u52a1\u67b6\u6784\u7cfb\u7edf\u6765\u8bf4\u5177\u6709\u975e\u5e38\u91cd\u8981\u7684\u610f\u4e49\uff0c\u5426\u5219\u5176\u4e2d\u7684\u67d0\u4e2a\u5fae\u670d\u52a1\u5c06\u6210\u4e3a\u6574\u4e2a\u7cfb\u7edf\u9690\u85cf\u7684\u96ea\u5d29\u56e0\u7d20\uff0c\u4e3a\u4ec0\u4e48\u8fd9\u4e48\u8bf4\uff1f<\/p>\n\n\n\n

\u4e3e\u4f8b\u6765\u8bb2\uff0c\u67d0\u4e2aSAAS\u5e73\u53f0\u6709100\u591a\u4e2a\u5fae\u670d\u52a1\u5e94\u7528\uff0c\u4f46\u662f\u4f5c\u4e3a\u5e95\u5c42\u7684\u67d0\u4e2a\u6216\u67d0\u51e0\u4e2a\u5e94\u7528\u6765\u8bf4\uff0c\u5c06\u4f1a\u88ab\u6240\u6709\u4e0a\u5c42\u5e94\u7528\u9891\u7e41\u8c03\u7528\uff0c\u4e1a\u52a1\u9ad8\u5cf0\u671f\u65f6\uff0c\u5982\u679c\u5e95\u5c42\u5e94\u7528\u4e0d\u505a\u9650\u6d41\u5904\u7406\uff0c\u8be5\u5e94\u7528\u5fc5\u5c06\u9762\u4e34\u7740\u5de8\u5927\u7684\u538b\u529b\uff0c\u5c24\u5176\u662f\u90a3\u4e9b\u4e2a\u522b\u88ab\u9ad8\u9891\u8c03\u7528\u7684\u63a5\u53e3\u6765\u8bf4\uff0c\u6700\u76f4\u63a5\u7684\u8868\u73b0\u5c31\u662f\u5bfc\u81f4\u540e\u7eed\u65b0\u8fdb\u6765\u7684\u8bf7\u6c42\u963b\u585e\u3001\u6392\u961f\u3001\u54cd\u5e94\u8d85\u65f6…\u6700\u540e\u76f4\u5230\u8be5\u670d\u52a1\u6240\u5728JVM\u8d44\u6e90\u88ab\u8017\u5c3d\u3002<\/p>\n\n\n\n

\u4e8c\u3001\u9650\u6d41\u6982\u8ff0<\/strong><\/p>\n\n\n\n

\u5728\u5927\u591a\u6570\u7684\u5fae\u670d\u52a1\u67b6\u6784\u5728\u8bbe\u8ba1\u4e4b\u521d\uff0c\u6bd4\u5982\u5728\u6280\u672f\u9009\u578b\u9636\u6bb5\uff0c\u67b6\u6784\u5e08\u4f1a\u4ece\u4e00\u4e2a\u5168\u5c40\u7684\u89c6\u89d2\u53bb\u89c4\u5212\u6280\u672f\u6808\u7684\u7ec4\u5408\uff0c\u6bd4\u5982\u7ed3\u5408\u5f53\u524d\u4ea7\u54c1\u7684\u73b0\u72b6\u8003\u8651\u662f\u4f7f\u7528dubbo\uff1f\u8fd8\u662fspringcloud\uff1f\u4f5c\u4e3a\u5fae\u670d\u52a1\u6cbb\u7406\u7684\u5e95\u5c42\u6846\u67b6\u3002\u751a\u81f3\u4e3a\u4e86\u6ee1\u8db3\u5feb\u901f\u7684\u4e0a\u7ebf\u3001\u8fed\u4ee3\u548c\u4ea4\u4ed8\uff0c\u76f4\u63a5\u4ee5springboot\u4e3a\u57fa\u5ea7\u8fdb\u884c\u5f00\u53d1\uff0c\u540e\u7eed\u518d\u5f15\u5165\u65b0\u7684\u6280\u672f\u6808\u7b49…<\/p>\n\n\n\n

\u6240\u4ee5\u5728\u8c08\u8bba\u67d0\u4e2a\u4e1a\u52a1\u573a\u666f\u5177\u4f53\u7684\u6280\u672f\u89e3\u51b3\u65b9\u6848\u65f6\u4e0d\u53ef\u4e00\u6982\u800c\u8bba\uff0c\u800c\u662f\u9700\u8981\u7ed3\u5408\u4ea7\u54c1\u548c\u4e1a\u52a1\u7684\u73b0\u72b6\u7efc\u5408\u8bc4\u4f30\uff0c\u4ee5\u9650\u6d41\u6765\u8bf4\uff0c\u5728\u4e0b\u9762\u7684\u4e0d\u540c\u7684\u6280\u672f\u67b6\u6784\u4e0b\u5177\u4f53\u5728\u9009\u62e9\u7684\u65f6\u5019\u53ef\u80fd\u4e5f\u4e0d\u4e00\u6837\u3002<\/p>\n\n\n\n

2.1 dubbo \u670d\u52a1\u6cbb\u7406\u6a21\u5f0f<\/h3>\n\n\n\n

\u9009\u62e9dubbo\u6846\u67b6\u4f5c\u4e3a\u57fa\u7840\u670d\u52a1\u6cbb\u7406\u5bf9\u4e8e\u90a3\u79cd\u504f\u5411\u5185\u90e8\u5e73\u53f0\u7684\u5e94\u7528\u8fd8\u662f\u4e0d\u9519\u7684\uff0cdubbo\u5e95\u5c42\u8d70netty\uff0c\u8fd9\u4e00\u70b9\u76f8\u6bd4http\u534f\u8bae\u6765\u8bf4\uff0c\u5728\u4e00\u5b9a\u573a\u666f\u4e0b\u8fd8\u662f\u5177\u6709\u4f18\u52bf\u7684\uff0c\u5982\u679c\u9009\u62e9dubbo\uff0c\u5728\u9009\u62e9\u9650\u6d41\u65b9\u6848\u4e0a\u53ef\u4ee5\u505a\u5982\u4e0b\u7684\u53c2\u8003\u3002<\/p>\n\n\n\n

2.1.1 dubbo\u6846\u67b6\u7ea7\u9650\u6d41<\/h5>\n\n\n\n

dubbo\u5b98\u65b9\u63d0\u4f9b\u4e86\u5b8c\u5584\u7684\u670d\u52a1\u6cbb\u7406\uff0c\u80fd\u591f\u6ee1\u8db3\u5927\u591a\u6570\u5f00\u53d1\u573a\u666f\u4e2d\u7684\u9700\u6c42\uff0c\u9488\u5bf9\u9650\u6d41\u8fd9\u4e2a\u573a\u666f\uff0c\u5177\u4f53\u6765\u8bf4\u5305\u62ec\u5982\u4e0b\u624b\u6bb5\uff0c\u5177\u4f53\u7684\u914d\u7f6e\uff0c\u53ef\u4ee5\u53c2\u8003\u5b98\u65b9\u624b\u518c\uff1b<\/p>\n\n\n\n

\u5ba2\u6237\u7aef\u9650\u6d41<\/strong><\/p>\n\n\n\n

    \n
  • \u4fe1\u53f7\u91cf\u9650\u6d41 \uff08\u901a\u8fc7\u7edf\u8ba1\u7684\u65b9\u5f0f\uff09<\/li>\n\n\n\n
  • \u8fde\u63a5\u6570\u9650\u6d41 (socket->tcp)<\/li>\n<\/ul>\n\n\n\n

    \u670d\u52a1\u7aef\u9650\u6d41<\/strong><\/p>\n\n\n\n

      \n
    • \u7ebf\u7a0b\u6c60\u9650\u6d41 (\u9694\u79bb\u624b\u6bb5)<\/li>\n\n\n\n
    • \u4fe1\u53f7\u91cf\u9650\u6d41 (\u975e\u9694\u79bb\u624b\u6bb5)<\/li>\n\n\n\n
    • \u63a5\u6536\u6570\u9650\u6d41 (socket->tcp)<\/li>\n<\/ul>\n\n\n\n
      2.1.2 \u7ebf\u7a0b\u6c60\u8bbe\u7f6e<\/h5>\n\n\n\n

      \u591a\u7ebf\u7a0b\u5e76\u53d1\u64cd\u4f5c\u4e00\u5b9a\u79bb\u4e0d\u5f00\u7ebf\u7a0b\u6c60\uff0cDubbo\u81ea\u8eab\u63d0\u4f9b\u4e86\u652f\u6301\u4e86\u56db\u79cd\u7ebf\u7a0b\u6c60\u7c7b\u578b\u652f\u6301\u3002\u751f\u4ea7\u8005<dubbo:protocol><\/code>\u6807\u7b7e\u4e2d\u53ef\u914d\u7f6e\u7ebf\u7a0b\u6c60\u5173\u952e\u53c2\u6570\uff0c\u7ebf\u7a0b\u6c60\u7c7b\u578b\u3001\u963b\u585e\u961f\u5217\u5927\u5c0f\u3001\u6838\u5fc3\u7ebf\u7a0b\u6570\u91cf\u7b49\uff0c\u901a\u8fc7\u914d\u7f6e\u751f\u4ea7\u7aef\u7684\u7ebf\u7a0b\u6c60\u6570\u91cf\u53ef\u4ee5\u5728\u4e00\u5b9a\u7a0b\u5ea6\u4e0a\u8d77\u5230\u9650\u6d41\u7684\u6548\u679c\u3002<\/p>\n\n\n\n

      2.1.3 \u96c6\u6210\u7b2c\u4e09\u65b9\u7ec4\u4ef6<\/h5>\n\n\n\n

      \u5982\u679c\u662fspringboot\u6846\u67b6\u7684\u9879\u76ee\uff0c\u53ef\u4ee5\u8003\u8651\u76f4\u63a5\u5f15\u5165\u5730\u65b9\u7684\u7ec4\u4ef6\u6216SDK\uff0c\u6bd4\u5982hystrix\uff0cguava\uff0csentinel\u539f\u751fSDK\u7b49\uff0c\u5982\u679c\u6280\u672f\u5b9e\u529b\u8db3\u591f\u5f3a\u751a\u81f3\u53ef\u4ee5\u8003\u8651\u81ea\u5df1\u9020\u8f6e\u5b50\u3002<\/p>\n\n\n\n

      2.2 springcloud \u670d\u52a1\u6cbb\u7406\u6a21\u5f0f<\/h3>\n\n\n\n

      \u5982\u679c\u4f60\u7684\u670d\u52a1\u6cbb\u7406\u6846\u67b6\u9009\u7528\u7684\u662fspringcloud\u6216springcloud-alibaba\uff0c\u5176\u6846\u67b6\u81ea\u8eab\u7684\u751f\u6001\u4e2d\u5df2\u7ecf\u5305\u542b\u4e86\u76f8\u5e94\u7684\u9650\u6d41\u7ec4\u4ef6\uff0c\u53ef\u4ee5\u5b9e\u73b0\u5f00\u7bb1\u5373\u7528\uff0c\u4e0b\u9762\u5217\u4e3e\u51e0\u79cd\u5e38\u7528\u7684\u57fa\u4e8espringcloud\u6846\u67b6\u7684\u9650\u6d41\u7ec4\u4ef6\u3002<\/p>\n\n\n\n

      2.2.1 hystrix<\/h5>\n\n\n\n

      Hystrix\u662fNetflix\u5f00\u6e90\u7684\u4e00\u6b3e\u5bb9\u9519\u6846\u67b6\uff0c\u5728springcloud\u65e9\u671f\u63a8\u51fa\u5e02\u573a\u7684\u65f6\u5019\uff0c\u4f5c\u4e3aspringcloud\u751f\u6001\u4e2d\u7528\u4e8e\u9650\u6d41\u3001\u7194\u65ad\u3001\u964d\u7ea7\u7684\u4e00\u6b3e\u7ec4\u4ef6\u3002<\/p>\n\n\n\n

      Hystrix\u63d0\u4f9b\u4e86\u9650\u6d41\u529f\u80fd\uff0c\u5728springcloud\u67b6\u6784\u7684\u7cfb\u7edf\u4e2d\uff0c\u53ef\u4ee5\u5728\u7f51\u5173\u542f\u7528Hystrix\uff0c\u8fdb\u884c\u9650\u6d41\u5904\u7406\uff0c\u6bcf\u4e2a\u5fae\u670d\u52a1\u4e5f\u53ef\u4ee5\u5404\u81ea\u542f\u7528Hystrix\u8fdb\u884c\u9650\u6d41\u3002<\/p>\n\n\n\n

      \n

      Hystrix\u9ed8\u8ba4\u4f7f\u7528\u7ebf\u7a0b\u9694\u79bb\u6a21\u5f0f\uff0c\u53ef\u4ee5\u901a\u8fc7\u7ebf\u7a0b\u6570+\u961f\u5217\u5927\u5c0f\u8fdb\u884c\u9650\u6d41\uff0c\u5177\u4f53\u53c2\u6570\u914d\u7f6e\u53ef\u4ee5\u53c2\u8003\u5b98\u7f51\u76f8\u5173\u8d44\u6599\u3002<\/p>\n<\/blockquote>\n\n\n\n

      2.2.2 sentinel<\/h5>\n\n\n\n

      Sentinel \u53f7\u79f0\u5206\u5e03\u5f0f\u7cfb\u7edf\u7684\u6d41\u91cf\u9632\u536b\u5175\uff0c\u5c5e\u4e8espringcloud-alibaba\u751f\u6001\u4e2d\u7684\u91cd\u8981\u7ec4\u4ef6\uff0c\u9762\u5411\u5206\u5e03\u5f0f\u670d\u52a1\u67b6\u6784\u7684\u6d41\u91cf\u63a7\u5236\u7ec4\u4ef6\uff0c\u4e3b\u8981\u4ee5\u6d41\u91cf\u4e3a\u5207\u5165\u70b9\uff0c\u4ece\u9650\u6d41\u3001\u6d41\u91cf\u6574\u5f62\u3001\u7194\u65ad\u964d\u7ea7\u3001\u7cfb\u7edf\u8d1f\u8f7d\u4fdd\u62a4\u3001\u70ed\u70b9\u9632\u62a4\u7b49\u591a\u4e2a\u7ef4\u5ea6\u6765\u5e2e\u52a9\u5f00\u53d1\u8005\u4fdd\u969c\u5fae\u670d\u52a1\u7684\u7a33\u5b9a\u6027\u3002<\/p>\n\n\n\n

      2.3 \u7f51\u5173\u5c42\u9650\u6d41<\/h3>\n\n\n\n

      \u968f\u7740\u5fae\u670d\u52a1\u89c4\u6a21\u7684\u589e\u52a0\uff0c\u6574\u4e2a\u7cfb\u7edf\u4e2d\u5f88\u591a\u5fae\u670d\u52a1\u90fd\u9700\u8981\u5b9e\u73b0\u9650\u6d41\u8fd9\u79cd\u9700\u6c42\u65f6\uff0c\u5c31\u53ef\u4ee5\u8003\u8651\u5728\u7f51\u5173\u8fd9\u4e00\u5c42\u8fdb\u884c\u9650\u6d41\u4e86\uff0c\u901a\u5e38\u6765\u8bf4\uff0c\u7f51\u5173\u5c42\u7684\u9650\u6d41\u9762\u5411\u7684\u662f\u901a\u7528\u7684\u4e1a\u52a1\uff0c\u6bd4\u5982\u90a3\u4e9b\u6076\u610f\u7684\u8bf7\u6c42\uff0c\u722c\u866b\uff0c\u653b\u51fb\u7b49\uff0c\u7b80\u5355\u6765\u8bf4\uff0c\u7f51\u5173\u5c42\u9762\u7684\u9650\u6d41\u63d0\u4f9b\u4e86\u4e00\u5c42\u5bf9\u7cfb\u7edf\u6574\u4f53\u7684\u4fdd\u62a4\u63aa\u65bd\u3002<\/p>\n\n\n\n

      \u4e09\u3001\u5e38\u7528\u9650\u6d41\u7b56\u7565<\/strong><\/p>\n\n\n\n

      3.1 \u9650\u6d41\u5e38\u7528\u7684\u7b97\u6cd5<\/h3>\n\n\n\n

      \u4e0d\u7ba1\u662f\u54ea\u79cd\u9650\u6d41\u7ec4\u4ef6\uff0c\u5176\u5e95\u5c42\u7684\u9650\u6d41\u5b9e\u73b0\u7b97\u6cd5\u5927\u540c\u5c0f\u5f02\uff0c\u8fd9\u91cc\u5217\u4e3e\u51e0\u79cd\u5e38\u7528\u7684\u9650\u6d41\u7b97\u6cd5\u4ee5\u4f9b\u4e86\u89e3\u3002<\/p>\n\n\n\n

      3.1.1 \u4ee4\u724c\u6876\u7b97\u6cd5<\/h5>\n\n\n\n

      \u4ee4\u724c\u6876\u7b97\u6cd5\u662f\u76ee\u524d\u5e94\u7528\u6700\u4e3a\u5e7f\u6cdb\u7684\u9650\u6d41\u7b97\u6cd5\uff0c\u987e\u540d\u601d\u4e49\uff0c\u5b83\u6709\u4ee5\u4e0b\u4e24\u4e2a\u5173\u952e\u89d2\u8272\uff1a<\/p>\n\n\n\n

        \n
      • \u4ee4\u724c \uff1a\u83b7\u53d6\u5230\u4ee4\u724c\u7684Request\u624d\u4f1a\u88ab\u5904\u7406\uff0c\u5176\u4ed6Requests\u8981\u4e48\u6392\u961f\u8981\u4e48\u88ab\u76f4\u63a5\u4e22\u5f03\uff1b<\/li>\n\n\n\n
      • \u6876 \uff1a\u7528\u6765\u88c5\u4ee4\u724c\u7684\u5730\u65b9\uff0c\u6240\u6709Request\u90fd\u4ece\u8fd9\u4e2a\u6876\u91cc\u9762\u83b7\u53d6\u4ee4\u724c<\/li>\n<\/ul>\n\n\n\n
        \"\"<\/figure>\n\n\n\n

        \u4ee4\u724c\u6876\u4e3b\u8981\u6d89\u53ca\u52302\u4e2a\u8fc7\u7a0b\uff0c\u5373\u4ee4\u724c\u7684\u751f\u6210\uff0c\u4ee4\u724c\u7684\u83b7\u53d6<\/p>\n\n\n\n

        3.1.2 \u6f0f\u6876\u7b97\u6cd5<\/h5>\n\n\n\n

        \u6f0f\u6876\u7b97\u6cd5\u7684\u524d\u534a\u6bb5\u548c\u4ee4\u724c\u6876\u7c7b\u4f3c\uff0c\u4f46\u662f\u64cd\u4f5c\u7684\u5bf9\u8c61\u4e0d\u540c\uff0c\u7ed3\u5408\u4e0b\u56fe\u8fdb\u884c\u7406\u89e3\u3002<\/p>\n\n\n\n

        \u4ee4\u724c\u6876\u662f\u5c06\u4ee4\u724c\u653e\u5165\u6876\u91cc\uff0c\u800c\u6f0f\u6876\u662f\u5c06\u8bbf\u95ee\u8bf7\u6c42\u7684\u6570\u636e\u5305\u653e\u5230\u6876\u91cc\u3002\u540c\u6837\u7684\u662f\uff0c\u5982\u679c\u6876\u6ee1\u4e86\uff0c\u90a3\u4e48\u540e\u9762\u65b0\u6765\u7684\u6570\u636e\u5305\u5c06\u88ab\u4e22\u5f03\u3002<\/p>\n\n\n\n

        \"\"<\/figure>\n\n\n\n
        3.1.3 \u6ed1\u52a8\u65f6\u95f4\u7a97\u53e3<\/h5>\n\n\n\n

        \u6839\u636e\u4e0b\u56fe\uff0c\u7b80\u5355\u63cf\u8ff0\u4e0b\u6ed1\u52a8\u65f6\u95f4\u7a97\u53e3\u8fd9\u79cd\u8fc7\u7a0b\uff1a<\/p>\n\n\n\n

          \n
        • \u9ed1\u8272\u5927\u6846\u4e3a\u65f6\u95f4\u7a97\u53e3\uff0c\u53ef\u4ee5\u8bbe\u5b9a\u7a97\u53e3\u65f6\u95f4\u5355\u4f4d\u4e3a5\u79d2\uff0c\u5b83\u4f1a\u968f\u7740\u65f6\u95f4\u63a8\u79fb\u5411\u540e\u6ed1\u52a8\u3002\u6211\u4eec\u5c06\u7a97\u53e3\u5185\u7684\u65f6\u95f4\u5212\u5206\u4e3a\u4e94\u4e2a\u5c0f\u683c\u5b50\uff0c\u6bcf\u4e2a\u683c\u5b50\u4ee3\u88681\u79d2\u949f\uff0c\u540c\u65f6\u8fd9\u4e2a\u683c\u5b50\u8fd8\u5305\u542b\u4e00\u4e2a\u8ba1\u6570\u5668\uff0c\u7528\u6765\u8ba1\u7b97\u5728\u5f53\u524d\u65f6\u95f4\u5185\u8bbf\u95ee\u7684\u8bf7\u6c42\u6570\u91cf\u3002\u90a3\u4e48\u8fd9\u4e2a\u65f6\u95f4\u7a97\u53e3\u5185\u7684\u603b\u8bbf\u95ee\u91cf\u5c31\u662f\u6240\u6709\u683c\u5b50\u8ba1\u6570\u5668\u7d2f\u52a0\u540e\u7684\u6570\u503c\uff1b<\/li>\n\n\n\n
        • \u6bd4\u5982\u8bf4\uff0c\u6211\u4eec\u5728\u6bcf\u4e00\u79d2\u5185\u67095\u4e2a\u7528\u6237\u8bbf\u95ee\uff0c\u7b2c5\u79d2\u5185\u670910\u4e2a\u7528\u6237\u8bbf\u95ee\uff0c\u90a3\u4e48\u57280\u52305\u79d2\u8fd9\u4e2a\u65f6\u95f4\u7a97\u53e3\u5185\u8bbf\u95ee\u91cf\u5c31\u662f15\u3002\u5982\u679c\u6211\u4eec\u7684\u63a5\u53e3\u8bbe\u7f6e\u4e86\u65f6\u95f4\u7a97\u53e3\u5185\u8bbf\u95ee\u4e0a\u9650\u662f20\uff0c\u90a3\u4e48\u5f53\u65f6\u95f4\u5230\u7b2c\u516d\u79d2\u7684\u65f6\u5019\uff0c\u8fd9\u4e2a\u65f6\u95f4\u7a97\u53e3\u5185\u7684\u8ba1\u6570\u603b\u548c\u5c31\u53d8\u6210\u4e8610\uff0c\u56e0\u4e3a1\u79d2\u7684\u683c\u5b50\u5df2\u7ecf\u9000\u51fa\u4e86\u65f6\u95f4\u7a97\u53e3\uff0c\u56e0\u6b64\u5728\u7b2c\u516d\u79d2\u5185\u53ef\u4ee5\u63a5\u6536\u7684\u8bbf\u95ee\u91cf\u5c31\u662f20-10=10\u4e2a\uff1b<\/li>\n<\/ul>\n\n\n\n
          \"\"<\/figure>\n\n\n\n

          \u6ed1\u52a8\u7a97\u53e3\u5176\u5b9e\u4e5f\u662f\u4e00\u79cd\u8ba1\u7b97\u5668\u7b97\u6cd5\uff0c\u5b83\u6709\u4e00\u4e2a\u663e\u8457\u7279\u70b9\uff0c\u5f53\u65f6\u95f4\u7a97\u53e3\u7684\u8de8\u5ea6\u8d8a\u957f\u65f6\uff0c\u9650\u6d41\u6548\u679c\u5c31\u8d8a\u5e73\u6ed1\u3002\u6253\u4e2a\u6bd4\u65b9\uff0c\u5982\u679c\u5f53\u524d\u65f6\u95f4\u7a97\u53e3\u53ea\u6709\u4e24\u79d2\uff0c\u800c\u8bbf\u95ee\u8bf7\u6c42\u5168\u90e8\u96c6\u4e2d\u5728\u7b2c\u4e00\u79d2\u7684\u65f6\u5019\uff0c\u5f53\u65f6\u95f4\u5411\u540e\u6ed1\u52a8\u4e00\u79d2\u540e\uff0c\u5f53\u524d\u7a97\u53e3\u7684\u8ba1\u6570\u91cf\u5c06\u53d1\u751f\u8f83\u5927\u7684\u53d8\u5316\uff0c\u62c9\u957f\u65f6\u95f4\u7a97\u53e3\u53ef\u4ee5\u964d\u4f4e\u8fd9\u79cd\u60c5\u51b5\u7684\u53d1\u751f\u6982\u7387<\/p>\n\n\n\n

          \u56db\u3001\u901a\u7528\u9650\u6d41\u5b9e\u73b0\u65b9\u6848<\/strong><\/p>\n\n\n\n

          \u629b\u5f00\u7f51\u5173\u5c42\u7684\u9650\u6d41\u5148\u4e0d\u8bf4\uff0c\u5728\u5fae\u670d\u52a1\u5e94\u7528\u4e2d\uff0c\u8003\u8651\u5230\u6280\u672f\u6808\u7684\u7ec4\u5408\uff0c\u56e2\u961f\u4eba\u5458\u7684\u5f00\u53d1\u6c34\u5e73\uff0c\u4ee5\u53ca\u6613\u7ef4\u62a4\u6027\u7b49\u56e0\u7d20\uff0c\u4e00\u4e2a\u6bd4\u8f83\u901a\u7528\u7684\u505a\u6cd5\u662f\uff0c\u5229\u7528AOP\u6280\u672f+\u81ea\u5b9a\u4e49\u6ce8\u89e3\u5b9e\u73b0\u5bf9\u7279\u5b9a\u7684\u65b9\u6cd5\u6216\u63a5\u53e3\u8fdb\u884c\u9650\u6d41\uff0c\u4e0b\u9762\u57fa\u4e8e\u8fd9\u4e2a\u601d\u8def\u6765\u5206\u522b\u4ecb\u7ecd\u4e0b\u51e0\u79cd\u5e38\u7528\u7684\u9650\u6d41\u65b9\u6848\u7684\u5b9e\u73b0\u3002<\/p>\n\n\n\n

          4.1 \u57fa\u4e8eguava\u9650\u6d41\u5b9e\u73b0<\/h3>\n\n\n\n

          guava\u4e3a\u8c37\u6b4c\u5f00\u6e90\u7684\u4e00\u4e2a\u6bd4\u8f83\u5b9e\u7528\u7684\u7ec4\u4ef6\uff0c\u5229\u7528\u8fd9\u4e2a\u7ec4\u4ef6\u53ef\u4ee5\u5e2e\u52a9\u5f00\u53d1\u4eba\u5458\u5b8c\u6210\u5e38\u89c4\u7684\u9650\u6d41\u64cd\u4f5c\uff0c\u63a5\u4e0b\u6765\u770b\u5177\u4f53\u7684\u5b9e\u73b0\u6b65\u9aa4\u3002<\/p>\n\n\n\n

          4.1.1 \u5f15\u5165guava\u4f9d\u8d56<\/h5>\n\n\n\n

          \u7248\u672c\u53ef\u4ee5\u9009\u62e9\u66f4\u9ad8\u7684\u6216\u5176\u4ed6\u7248\u672c<\/p>\n\n\n\n

          <dependency>
              <groupId>com.google.guava<\/groupId>
              <artifactId>guava<\/artifactId>
              <version>23.0<\/version>
          <\/dependency><\/code><\/pre>\n\n\n\n
          4.1.2 \u81ea\u5b9a\u4e49\u9650\u6d41\u6ce8\u89e3<\/h5>\n\n\n\n
          \u81ea\u5b9a\u4e49\u4e00\u4e2a\u9650\u6d41\u7528\u7684\u6ce8\u89e3\uff0c\u540e\u9762\u5728\u9700\u8981\u9650\u6d41\u7684\u65b9\u6cd5\u6216\u63a5\u53e3\u4e0a\u9762\u53ea\u9700\u6dfb\u52a0\u8be5\u6ce8\u89e3\u5373\u53ef\uff1b<\/p>\n\n\n\n
          import java.lang.annotation.ElementType;
          import java.lang.annotation.Retention;
          import java.lang.annotation.RetentionPolicy;
          import java.lang.annotation.Target;
           
          @Target(value = ElementType.METHOD)
          @Retention(value = RetentionPolicy.RUNTIME)
          public @interface RateConfigAnno {
           
              String limitType();
           
              double limitCount() default 5d;
          }<\/code><\/pre>\n\n\n\n
          4.1.3 \u9650\u6d41AOP\u7c7b<\/h5>\n\n\n\n
          \u901a\u8fc7AOP\u524d\u7f6e\u901a\u77e5\u7684\u65b9\u5f0f\u62e6\u622a\u6dfb\u52a0\u4e86\u4e0a\u8ff0\u81ea\u5b9a\u4e49\u9650\u6d41\u6ce8\u89e3\u7684\u65b9\u6cd5\uff0c\u89e3\u6790\u6ce8\u89e3\u4e2d\u7684\u5c5e\u6027\u503c\uff0c\u5e76\u4ee5\u8be5\u5c5e\u6027\u503c\u4f5c\u4e3aguava\u63d0\u4f9b\u7684\u9650\u6d41\u53c2\u6570\uff0c\u8be5\u7c7b\u4e3a\u6574\u4e2a\u5b9e\u73b0\u7684\u6838\u5fc3\u6240\u5728\u3002<\/p>\n\n\n\n
          import com.alibaba.fastjson2.JSONObject;
          import com.google.common.util.concurrent.RateLimiter;
          import org.aspectj.lang.JoinPoint;
          import org.aspectj.lang.annotation.Aspect;
          import org.aspectj.lang.annotation.Before;
          import org.slf4j.Logger;
          import org.slf4j.LoggerFactory;
          import org.springframework.stereotype.Component;
          import org.springframework.web.context.request.RequestContextHolder;
          import org.springframework.web.context.request.ServletRequestAttributes;
           
          import javax.servlet.ServletOutputStream;
          import javax.servlet.http.HttpServletResponse;
          import java.io.IOException;
          import java.lang.reflect.Method;
          import java.util.Objects;
           
          @Aspect
          @Component
          public class GuavaLimitAop {
           
              private static Logger logger = LoggerFactory.getLogger(GuavaLimitAop.class);
           
              @Before(\"execution(@RateConfigAnno * *(..))\")
              public void limit(JoinPoint joinPoint) {
                  \/\/1\u3001\u83b7\u53d6\u5f53\u524d\u7684\u8c03\u7528\u65b9\u6cd5<\/em>
                  Method currentMethod = getCurrentMethod(joinPoint);
                  if (Objects.isNull(currentMethod)) {
                      return;
                  }
                  \/\/2\u3001\u4ece\u65b9\u6cd5\u6ce8\u89e3\u5b9a\u4e49\u4e0a\u83b7\u53d6\u9650\u6d41\u7684\u7c7b\u578b<\/em>
                  String limitType = currentMethod.getAnnotation(RateConfigAnno.class).limitType();
                  double limitCount = currentMethod.getAnnotation(RateConfigAnno.class).limitCount();
                  \/\/\u4f7f\u7528guava\u7684\u4ee4\u724c\u6876\u7b97\u6cd5\u83b7\u53d6\u4e00\u4e2a\u4ee4\u724c\uff0c\u83b7\u53d6\u4e0d\u5230\u5148\u7b49\u5f85<\/em>
                  RateLimiter rateLimiter = RateLimitHelper.getRateLimiter(limitType, limitCount);
                  boolean b = rateLimiter.tryAcquire();
                  if (b) {
                      System.out.println(\"\u83b7\u53d6\u5230\u4ee4\u724c\");
                  }else {
                      HttpServletResponse resp = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getResponse();
                      JSONObject jsonObject=new JSONObject();
                      jsonObject.put(\"success\",false);
                      jsonObject.put(\"msg\",\"\u9650\u6d41\u4e2d\");
                      try {
                          output(resp, jsonObject.toJSONString());
                      }catch (Exception e){
                          logger.error(\"error,e:{}\",e);
                      }
                  }
              }
           
              private Method getCurrentMethod(JoinPoint joinPoint) {
                  Method[] methods = joinPoint.getTarget().getClass().getMethods();
                  Method target = null;
                  for (Method method : methods) {
                      if (method.getName().equals(joinPoint.getSignature().getName())) {
                          target = method;
                          break;
                      }
                  }
                  return target;
              }
           
              public void output(HttpServletResponse response, String msg) throws IOException {
                  response.setContentType(\"application\/json;charset=UTF-8\");
                  ServletOutputStream outputStream = null;
                  try {
                      outputStream = response.getOutputStream();
                      outputStream.write(msg.getBytes(\"UTF-8\"));
                  } catch (IOException e) {
                      e.printStackTrace();
                  } finally {
                      outputStream.flush();
                      outputStream.close();
                  }
              }
          }<\/code><\/pre>\n\n\n\n
          \u5176\u4e2d\u9650\u6d41\u7684\u6838\u5fc3API\u5373\u4e3aRateLimiter\u8fd9\u4e2a\u5bf9\u8c61\uff0c\u6d89\u53ca\u5230\u7684RateLimitHelper\u7c7b\u5982\u4e0b<\/p>\n\n\n\n
          import com.google.common.util.concurrent.RateLimiter;
           
          import java.util.HashMap;
          import java.util.Map;
           
          public class RateLimitHelper {
           
              private RateLimitHelper(){}
           
              private static Map<String,RateLimiter> rateMap = new HashMap<>();
           
              public static RateLimiter getRateLimiter(String limitType,double limitCount ){
                  RateLimiter rateLimiter = rateMap.get(limitType);
                  if(rateLimiter == null){
                      rateLimiter = RateLimiter.create(limitCount);
                      rateMap.put(limitType,rateLimiter);
                  }
                  return rateLimiter;
              }
           
          }<\/code><\/pre>\n\n\n\n
          4.1.4 \u6d4b\u8bd5\u63a5\u53e3<\/h5>\n\n\n\n
          \u4e0b\u9762\u6dfb\u52a0\u4e00\u4e2a\u6d4b\u8bd5\u63a5\u53e3\uff0c\u6d4b\u8bd5\u4e00\u4e0b\u4e0a\u9762\u7684\u4ee3\u7801\u662f\u5426\u751f\u6548<\/p>\n\n\n\n
          @RestController
          public class OrderController {
           
              \/\/localhost:8081\/save<\/em>
              @GetMapping(\"\/save\")
              @RateConfigAnno(limitType = \"saveOrder\",limitCount = 1)
              public String save(){
                  return \"success\";
              }
           
          }<\/code><\/pre>\n\n\n\n
          \u5728\u63a5\u53e3\u4e2d\u4e3a\u4e86\u6a21\u62df\u51fa\u6548\u679c\uff0c\u6211\u4eec\u5c06\u53c2\u6570\u8bbe\u7f6e\u7684\u975e\u5e38\u5c0f\uff0c\u5373QPS\u4e3a1\uff0c\u53ef\u4ee5\u9884\u60f3\u5f53\u6bcf\u79d2\u8bf7\u6c42\u8d85\u8fc71\u65f6\u5c06\u4f1a\u51fa\u73b0\u88ab\u9650\u6d41\u7684\u63d0\u793a\uff0c\u542f\u52a8\u5de5\u7a0b\u5e76\u9a8c\u8bc1\u63a5\u53e3\uff0c\u6bcf\u79d21\u6b21\u7684\u8bf7\u6c42\uff0c\u53ef\u4ee5\u6b63\u5e38\u5f97\u5230\u7ed3\u679c\uff0c\u6548\u679c\u5982\u4e0b\uff1a<\/p>\n\n\n\n
          \"\"<\/figure>\n\n\n\n
          \u5feb\u901f\u5237\u63a5\u53e3\uff0c\u5c06\u4f1a\u770b\u5230\u4e0b\u9762\u7684\u6548\u679c<\/p>\n\n\n\n
          \"\"<\/figure>\n\n\n\n
          4.2 \u57fa\u4e8esentinel\u9650\u6d41\u5b9e\u73b0<\/h3>\n\n\n\n
          \u5728\u4e0d\u5c11\u540c\u5b66\u7684\u610f\u8bc6\u4e2d\uff0csentinel\u901a\u5e38\u662f\u9700\u8981\u7ed3\u5408springcloud-alibaba\u6846\u67b6\u4e00\u8d77\u5b9e\u7528\u7684\uff0c\u800c\u4e14\u4e0e\u6846\u67b6\u96c6\u6210\u4e4b\u540e\uff0c\u53ef\u4ee5\u914d\u5408\u63a7\u5236\u53f0\u4e00\u8d77\u4f7f\u7528\u8fbe\u5230\u66f4\u597d\u7684\u6548\u679c\uff0c\u5b9e\u9645\u4e0a\uff0csentinel\u5b98\u65b9\u4e5f\u63d0\u4f9b\u4e86\u76f8\u5bf9\u539f\u751f\u7684SDK\u53ef\u4f9b\u4f7f\u7528\uff0c\u63a5\u4e0b\u6765\u5c31\u4ee5\u8fd9\u79cd\u65b9\u5f0f\u8fdb\u884c\u6574\u5408\u3002<\/p>\n\n\n\n
          4.2.1 \u5f15\u5165sentinel\u6838\u5fc3\u4f9d\u8d56\u5305<\/h3>\n\n\n\n
          <dependency>
              <groupId>com.alibaba.csp<\/groupId>
              <artifactId>sentinel-core<\/artifactId>
              <version>1.8.0<\/version>
          <\/dependency><\/code><\/pre>\n\n\n\n
          4.2.2 \u81ea\u5b9a\u4e49\u9650\u6d41\u6ce8\u89e3<\/h5>\n\n\n\n
          \u53ef\u4ee5\u6839\u636e\u9700\u8981\uff0c\u6dfb\u52a0\u66f4\u591a\u7684\u5c5e\u6027<\/p>\n\n\n\n
          import java.lang.annotation.ElementType;
          import java.lang.annotation.Retention;
          import java.lang.annotation.RetentionPolicy;
          import java.lang.annotation.Target;
           
          @Target(value = ElementType.METHOD)
          @Retention(value = RetentionPolicy.RUNTIME)
          public @interface SentinelLimitAnnotation {
           
              String resourceName();
           
              int limitCount() default 5;
           
          }<\/code><\/pre>\n\n\n\n
          4.2.3 \u81ea\u5b9a\u4e49AOP\u7c7b\u5b9e\u73b0\u9650\u6d41<\/h5>\n\n\n\n
          \u8be5\u7c7b\u7684\u5b9e\u73b0\u601d\u8def\u4e0e\u4e0a\u8ff0\u4f7f\u7528guava\u7c7b\u4f3c\uff0c\u4e0d\u540c\u7684\u662f\uff0c\u8fd9\u91cc\u4f7f\u7528\u7684\u662fsentinel\u539f\u751f\u7684\u9650\u6d41\u76f8\u5173\u7684API\uff0c\u5bf9\u6b64\u4e0d\u591f\u5c5e\u6027\u7684\u53ef\u4ee5\u67e5\u9605\u5b98\u65b9\u7684\u6587\u6863\u8fdb\u884c\u5b66\u4e60\uff0c\u8fd9\u91cc\u5c31\u4e0d\u5c55\u5f00\u6765\u8bf4\u4e86\u3002<\/p>\n\n\n\n
          import com.alibaba.csp.sentinel.Entry;
          import com.alibaba.csp.sentinel.SphU;
          import com.alibaba.csp.sentinel.Tracer;
          import com.alibaba.csp.sentinel.slots.block.BlockException;
          import com.alibaba.csp.sentinel.slots.block.RuleConstant;
          import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;
          import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;
          import org.apache.commons.lang3.StringUtils;
          import org.aspectj.lang.JoinPoint;
          import org.aspectj.lang.ProceedingJoinPoint;
          import org.aspectj.lang.annotation.Around;
          import org.aspectj.lang.annotation.Aspect;
          import org.aspectj.lang.annotation.Pointcut;
          import org.springframework.stereotype.Component;
           
          import java.lang.reflect.Method;
          import java.util.ArrayList;
          import java.util.List;
          import java.util.Objects;
           
          @Aspect
          @Component
          public class SentinelMethodLimitAop {
           
              private static void initFlowRule(String resourceName,int limitCount) {
                  List<FlowRule> rules = new ArrayList<>();
                  FlowRule rule = new FlowRule();
                  \/\/\u8bbe\u7f6e\u53d7\u4fdd\u62a4\u7684\u8d44\u6e90<\/em>
                  rule.setResource(resourceName);
                  \/\/\u8bbe\u7f6e\u6d41\u63a7\u89c4\u5219 QPS<\/em>
                  rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
                  \/\/\u8bbe\u7f6e\u53d7\u4fdd\u62a4\u7684\u8d44\u6e90\u9608\u503c<\/em>
                  rule.setCount(limitCount);
                  rules.add(rule);
                  \/\/\u52a0\u8f7d\u914d\u7f6e\u597d\u7684\u89c4\u5219<\/em>
                  FlowRuleManager.loadRules(rules);
              }
           
              @Pointcut(value = \"@annotation(com.congge.sentinel.SentinelLimitAnnotation)\")
              public void rateLimit() {
           
              }
           
              @Around(\"rateLimit()\")
              public Object around(ProceedingJoinPoint joinPoint) {
                  \/\/1\u3001\u83b7\u53d6\u5f53\u524d\u7684\u8c03\u7528\u65b9\u6cd5<\/em>
                  Method currentMethod = getCurrentMethod(joinPoint);
                  if (Objects.isNull(currentMethod)) {
                      return null;
                  }
                  \/\/2\u3001\u4ece\u65b9\u6cd5\u6ce8\u89e3\u5b9a\u4e49\u4e0a\u83b7\u53d6\u9650\u6d41\u7684\u7c7b\u578b<\/em>
                  String resourceName = currentMethod.getAnnotation(SentinelLimitAnnotation.class).resourceName();
                  if(StringUtils.isEmpty(resourceName)){
                      throw new RuntimeException(\"\u8d44\u6e90\u540d\u79f0\u4e3a\u7a7a\");
                  }
                  int limitCount = currentMethod.getAnnotation(SentinelLimitAnnotation.class).limitCount();
                  initFlowRule(resourceName,limitCount);
           
                  Entry entry = null;
                  Object result = null;
                  try {
                      entry = SphU.entry(resourceName);
                      try {
                          result = joinPoint.proceed();
                      } catch (Throwable throwable) {
                          throwable.printStackTrace();
                      }
                  } catch (BlockException ex) {
                      \/\/ \u8d44\u6e90\u8bbf\u95ee\u963b\u6b62\uff0c\u88ab\u9650\u6d41\u6216\u88ab\u964d\u7ea7<\/em>
                      \/\/ \u5728\u6b64\u5904\u8fdb\u884c\u76f8\u5e94\u7684\u5904\u7406\u64cd\u4f5c<\/em>
                      System.out.println(\"blocked\");
                      return \"\u88ab\u9650\u6d41\u4e86\";
                  } catch (Exception e) {
                      Tracer.traceEntry(e, entry);
                  } finally {
                      if (entry != null) {
                          entry.exit();
                      }
                  }
                  return result;
              }
           
              private Method getCurrentMethod(JoinPoint joinPoint) {
                  Method[] methods = joinPoint.getTarget().getClass().getMethods();
                  Method target = null;
                  for (Method method : methods) {
                      if (method.getName().equals(joinPoint.getSignature().getName())) {
                          target = method;
                          break;
                      }
                  }
                  return target;
              }
          }<\/code><\/pre>\n\n\n\n
          4.2.4 \u81ea\u5b9a\u4e49\u6d4b\u8bd5\u63a5\u53e3<\/h5>\n\n\n\n
          \u4e3a\u4e86\u6a21\u62df\u6548\u679c\uff0c\u8fd9\u91cc\u5c06QPS\u7684\u6570\u91cf\u8bbe\u7f6e\u4e3a1<\/p>\n\n\n\n
          \/\/localhost:8081\/limit<\/em>
          @GetMapping(\"\/limit\")
          @SentinelLimitAnnotation(limitCount = 1,resourceName = \"sentinelLimit\")
          public String sentinelLimit(){
              return \"sentinelLimit\";
          }<\/code><\/pre>\n\n\n\n
          \u542f\u52a8\u5de5\u7a0b\u4e4b\u540e\uff0c\u6d4f\u89c8\u5668\u8c03\u7528\u63a5\u53e3\u6d4b\u8bd5\u4e00\u4e0b\uff0c\u6bcf\u79d2\u4e00\u4e2a\u8bf7\u6c42\uff0c\u53ef\u4ee5\u6b63\u5e38\u901a\u8fc7<\/p>\n\n\n\n
          \"\"<\/figure>\n\n\n\n
          \u5feb\u901f\u5237\u63a5\u53e3\uff0c\u8d85\u8fc7\u6bcf\u79d21\u6b21\u65f6\uff0c\u6548\u679c\u5982\u4e0b<\/p>\n\n\n\n
          \"\"<\/figure>\n\n\n\n
          \u8fd9\u91cc\u53ea\u662f\u4e3a\u4e86\u6f14\u793a\u51fa\u6548\u679c\uff0c\u5efa\u8bae\u5728\u771f\u5b9e\u7684\u9879\u76ee\u4e2d\u4f7f\u7528\u65f6\uff0c\u5bf9\u8fd4\u56de\u7ed3\u679c\u505a\u4e00\u4e2a\u5c01\u88c5\u3002<\/p>\n\n\n\n
          4.3 \u57fa\u4e8eredis+lua\u9650\u6d41\u5b9e\u73b0<\/h3>\n\n\n\n
          redis\u662f\u7ebf\u7a0b\u5b89\u5168\u7684\uff0c\u5929\u7136\u5177\u6709\u7ebf\u7a0b\u5b89\u5168\u7684\u7279\u6027\uff0c\u652f\u6301\u539f\u5b50\u6027\u64cd\u4f5c\uff0c\u9650\u6d41\u670d\u52a1\u4e0d\u4ec5\u9700\u8981\u627f\u63a5\u8d85\u9ad8QPS\uff0c\u8fd8\u8981\u4fdd\u8bc1\u9650\u6d41\u903b\u8f91\u7684\u6267\u884c\u5c42\u9762\u5177\u5907\u7ebf\u7a0b\u5b89\u5168\u7684\u7279\u6027\uff0c\u5229\u7528Redis\u8fd9\u4e9b\u7279\u6027\u505a\u9650\u6d41\uff0c\u65e2\u80fd\u4fdd\u8bc1\u7ebf\u7a0b\u5b89\u5168\uff0c\u4e5f\u80fd\u4fdd\u8bc1\u6027\u80fd\u3002\u57fa\u4e8eredis\u7684\u9650\u6d41\u5b9e\u73b0\u5b8c\u6574\u6d41\u7a0b\u5982\u4e0b\u56fe\uff1a<\/p>\n\n\n\n
          \"\"<\/figure>\n\n\n\n
          \u7ed3\u5408\u4e0a\u9762\u7684\u6d41\u7a0b\u56fe\uff0c\u8fd9\u91cc\u68b3\u7406\u51fa\u4e00\u4e2a\u6574\u4f53\u7684\u5b9e\u73b0\u601d\u8def\uff1a<\/p>\n\n\n\n
            \n
          • \u7f16\u5199lua\u811a\u672c\uff0c\u6307\u5b9a\u5165\u53c2\u7684\u9650\u6d41\u89c4\u5219\uff0c\u6bd4\u5982\u5bf9\u7279\u5b9a\u7684\u63a5\u53e3\u9650\u6d41\u65f6\uff0c\u53ef\u4ee5\u6839\u636e\u67d0\u4e2a\u6216\u51e0\u4e2a\u53c2\u6570\u8fdb\u884c\u5224\u5b9a\uff0c\u8c03\u7528\u8be5\u63a5\u53e3\u7684\u8bf7\u6c42\uff0c\u5728\u4e00\u5b9a\u7684\u65f6\u95f4\u7a97\u53e3\u5185\u76d1\u63a7\u8bf7\u6c42\u6b21\u6570\uff1b<\/li>\n\n\n\n
          • \u65e2\u7136\u662f\u9650\u6d41\uff0c\u6700\u597d\u80fd\u591f\u901a\u7528\uff0c\u53ef\u5c06\u9650\u6d41\u89c4\u5219\u5e94\u7528\u5230\u4efb\u4f55\u63a5\u53e3\u4e0a\uff0c\u90a3\u4e48\u6700\u5408\u9002\u7684\u65b9\u5f0f\u5c31\u662f\u901a\u8fc7\u81ea\u5b9a\u4e49\u6ce8\u89e3\u5f62\u5f0f\u5207\u5165\uff1b<\/li>\n\n\n\n
          • \u63d0\u4f9b\u4e00\u4e2a\u914d\u7f6e\u7c7b\uff0c\u88abspring\u7684\u5bb9\u5668\u7ba1\u7406\uff0credisTemplate\u4e2d\u63d0\u4f9b\u4e86DefaultRedisScript\u8fd9\u4e2abean\uff1b<\/li>\n\n\n\n
          • \u63d0\u4f9b\u4e00\u4e2a\u80fd\u52a8\u6001\u89e3\u6790\u63a5\u53e3\u53c2\u6570\u7684\u7c7b\uff0c\u6839\u636e\u63a5\u53e3\u53c2\u6570\u8fdb\u884c\u89c4\u5219\u5339\u914d\u540e\u89e6\u53d1\u9650\u6d41\uff1b<\/li>\n<\/ul>\n\n\n\n
            4.3.1 \u5f15\u5165redis\u4f9d\u8d56<\/h5>\n\n\n\n
            <dependency>
                <groupId>org.springframework.boot<\/groupId>
                <artifactId>spring-boot-starter-data-redis<\/artifactId>
            <\/dependency><\/code><\/pre>\n\n\n\n
            4.3.2 \u81ea\u5b9a\u4e49\u6ce8\u89e3<\/h5>\n\n\n\n
            @Target({ElementType.METHOD, ElementType.TYPE})
            @Retention(RetentionPolicy.RUNTIME)
            @Inherited
            @Documented
            public @interface RedisLimitAnnotation {
             
                \/**
                 * key
                 *\/<\/em>
                String key() default \"\";
                \/**
                 * Key\u7684\u524d\u7f00
                 *\/<\/em>
                String prefix() default \"\";
                \/**
                 * \u4e00\u5b9a\u65f6\u95f4\u5185\u6700\u591a\u8bbf\u95ee\u6b21\u6570
                 *\/<\/em>
                int count();
                \/**
                 * \u7ed9\u5b9a\u7684\u65f6\u95f4\u8303\u56f4 \u5355\u4f4d(\u79d2)
                 *\/<\/em>
                int period();
                \/**
                 * \u9650\u6d41\u7684\u7c7b\u578b(\u7528\u6237\u81ea\u5b9a\u4e49key\u6216\u8005\u8bf7\u6c42ip)
                 *\/<\/em>
                LimitType limitType() default LimitType.CUSTOMER;
             
            }<\/code><\/pre>\n\n\n\n
            4.3.3 \u81ea\u5b9a\u4e49redis\u914d\u7f6e\u7c7b<\/h5>\n\n\n\n
            import org.springframework.context.annotation.Bean;
            import org.springframework.core.io.ClassPathResource;
            import org.springframework.data.redis.connection.RedisConnectionFactory;
            import org.springframework.data.redis.core.RedisTemplate;
            import org.springframework.data.redis.core.script.DefaultRedisScript;
            import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
            import org.springframework.data.redis.serializer.StringRedisSerializer;
            import org.springframework.scripting.support.ResourceScriptSource;
            import org.springframework.stereotype.Component;
             
            import java.io.Serializable;
             
            @Component
            public class RedisConfiguration {
             
                @Bean
                public DefaultRedisScript<Number> redisluaScript() {
                    DefaultRedisScript<Number> redisScript = new DefaultRedisScript<>();
                    redisScript.setScriptSource(new ResourceScriptSource(new ClassPathResource(\"limit.lua\")));
                    redisScript.setResultType(Number.class);
                    return redisScript;
                }
             
                @Bean(\"redisTemplate\")
                public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
                    RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
                    redisTemplate.setConnectionFactory(redisConnectionFactory);
                    Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
             
                    \/\/\u8bbe\u7f6evalue\u7684\u5e8f\u5217\u5316\u65b9\u5f0f\u4e3aJSOn<\/em>
                    redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
                    \/\/\u8bbe\u7f6ekey\u7684\u5e8f\u5217\u5316\u65b9\u5f0f\u4e3aString<\/em>
                    redisTemplate.setKeySerializer(new StringRedisSerializer());
             
                    redisTemplate.setHashKeySerializer(new StringRedisSerializer());
                    redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);
                    redisTemplate.afterPropertiesSet();
             
                    return redisTemplate;
                }
             
            }<\/code><\/pre>\n\n\n\n
            4.3.4 \u81ea\u5b9a\u4e49\u9650\u6d41AOP\u7c7b<\/h5>\n\n\n\n
            import org.aspectj.lang.ProceedingJoinPoint;
            import org.aspectj.lang.annotation.Around;
            import org.aspectj.lang.annotation.Aspect;
            import org.aspectj.lang.annotation.Pointcut;
            import org.aspectj.lang.reflect.MethodSignature;
            import org.slf4j.Logger;
            import org.slf4j.LoggerFactory;
            import org.springframework.beans.factory.annotation.Autowired;
            import org.springframework.context.annotation.Configuration;
            import org.springframework.data.redis.core.RedisTemplate;
            import org.springframework.data.redis.core.script.DefaultRedisScript;
            import org.springframework.web.context.request.RequestContextHolder;
            import org.springframework.web.context.request.ServletRequestAttributes;
             
            import javax.servlet.http.HttpServletRequest;
            import java.io.Serializable;
            import java.lang.reflect.Method;
            import java.util.Collections;
            import java.util.List;
             
            @Aspect
            @Configuration
            public class LimitRestAspect {
             
                private static final Logger logger = LoggerFactory.getLogger(LimitRestAspect.class);
             
                @Autowired
                private RedisTemplate<String, Object> redisTemplate;
             
                @Autowired
                private DefaultRedisScript<Number> redisluaScript;
             
             
                @Pointcut(value = \"@annotation(com.congge.config.limit.RedisLimitAnnotation)\")
                public void rateLimit() {
             
                }
             
                @Around(\"rateLimit()\")
                public Object interceptor(ProceedingJoinPoint joinPoint) throws Throwable {
                    MethodSignature signature = (MethodSignature) joinPoint.getSignature();
                    Method method = signature.getMethod();
                    Class<?> targetClass = method.getDeclaringClass();
                    RedisLimitAnnotation rateLimit = method.getAnnotation(RedisLimitAnnotation.class);
                    if (rateLimit != null) {
                        HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
                        String ipAddress = getIpAddr(request);
                        StringBuffer stringBuffer = new StringBuffer();
                        stringBuffer.append(ipAddress).append(\"-\")
                                .append(targetClass.getName()).append(\"- \")
                                .append(method.getName()).append(\"-\")
                                .append(rateLimit.key());
                        List<String> keys = Collections.singletonList(stringBuffer.toString());
                        \/\/\u8c03\u7528lua\u811a\u672c\uff0c\u83b7\u53d6\u8fd4\u56de\u7ed3\u679c\uff0c\u8fd9\u91cc\u5373\u4e3a\u8bf7\u6c42\u7684\u6b21\u6570<\/em>
                        Number number = redisTemplate.execute(
                                redisluaScript,
                                keys,
                                rateLimit.count(),
                                rateLimit.period()
                        );
                        if (number != null && number.intValue() != 0 && number.intValue() <= rateLimit.count()) {
                            logger.info(\"\u9650\u6d41\u65f6\u95f4\u6bb5\u5185\u8bbf\u95ee\u4e86\u7b2c\uff1a{} \u6b21\", number.toString());
                            return joinPoint.proceed();
                        }
                    } else {
                        return joinPoint.proceed();
                    }
                    throw new RuntimeException(\"\u8bbf\u95ee\u9891\u7387\u8fc7\u5feb\uff0c\u88ab\u9650\u6d41\u4e86\");
                }
             
                \/**
                 * \u83b7\u53d6\u8bf7\u6c42\u7684IP\u65b9\u6cd5
                 * @param request
                 * @return
                 *\/<\/em>
                private static String getIpAddr(HttpServletRequest request) {
                    String ipAddress = null;
                    try {
                        ipAddress = request.getHeader(\"x-forwarded-for\");
                        if (ipAddress == null || ipAddress.length() == 0 || \"unknown\".equalsIgnoreCase(ipAddress)) {
                            ipAddress = request.getHeader(\"Proxy-Client-IP\");
                        }
                        if (ipAddress == null || ipAddress.length() == 0 || \"unknown\".equalsIgnoreCase(ipAddress)) {
                            ipAddress = request.getHeader(\"WL-Proxy-Client-IP\");
                        }
                        if (ipAddress == null || ipAddress.length() == 0 || \"unknown\".equalsIgnoreCase(ipAddress)) {
                            ipAddress = request.getRemoteAddr();
                        }
                        \/\/ \u5bf9\u4e8e\u901a\u8fc7\u591a\u4e2a\u4ee3\u7406\u7684\u60c5\u51b5\uff0c\u7b2c\u4e00\u4e2aIP\u4e3a\u5ba2\u6237\u7aef\u771f\u5b9eIP,\u591a\u4e2aIP\u6309\u7167','\u5206\u5272<\/em>
                        if (ipAddress != null && ipAddress.length() > 15) {
                            if (ipAddress.indexOf(\",\") > 0) {
                                ipAddress = ipAddress.substring(0, ipAddress.indexOf(\",\"));
                            }
                        }
                    } catch (Exception e) {
                        ipAddress = \"\";
                    }
                    return ipAddress;
                }
             
            }<\/code><\/pre>\n\n\n\n
            \u8be5\u7c7b\u8981\u505a\u7684\u4e8b\u60c5\u548c\u4e0a\u9762\u7684\u4e24\u79cd\u9650\u6d41\u63aa\u65bd\u7c7b\u4f3c\uff0c\u4e0d\u8fc7\u5728\u8fd9\u91cc\u6838\u5fc3\u7684\u9650\u6d41\u662f\u901a\u8fc7\u8bfb\u53d6lua\u811a\u6b65\uff0c\u901a\u8fc7\u53c2\u6570\u4f20\u9012\u7ed9lua\u811a\u6b65\u5b9e\u73b0\u7684\u3002<\/p>\n\n\n\n
            4.3.5 \u81ea\u5b9a\u4e49lua\u811a\u672c<\/h5>\n\n\n\n
            \u5728\u5de5\u7a0b\u7684resources\u76ee\u5f55\u4e0b\uff0c\u6dfb\u52a0\u5982\u4e0b\u7684lua\u811a\u672c<\/p>\n\n\n\n
            local key = \"rate.limit:\" .. KEYS[1]
             
            local limit = tonumber(ARGV[1])
             
            local current = tonumber(redis.call('get', key) or \"0\")
             
            if current + 1 > limit then
              return 0
            else
               -- \u6ca1\u6709\u8d85\u9608\u503c\uff0c\u5c06\u5f53\u524d\u8bbf\u95ee\u6570\u91cf+1\uff0c\u5e76\u8bbe\u7f6e2\u79d2\u8fc7\u671f\uff08\u53ef\u6839\u636e\u81ea\u5df1\u7684\u4e1a\u52a1\u60c5\u51b5\u8c03\u6574\uff09<\/em>
               redis.call(\"INCRBY\", key,\"1\")
               redis.call(\"expire\", key,\"2\")
               return current + 1
            end<\/code><\/pre>\n\n\n\n
            4.3.6 \u6dfb\u52a0\u6d4b\u8bd5\u63a5\u53e3<\/h5>\n\n\n\n
            @RestController
            public class RedisController {
             
                \/\/localhost:8081\/redis\/limit<\/em>
                @GetMapping(\"\/redis\/limit\")
                @RedisLimitAnnotation(key = \"queryFromRedis\",period = 1, count = 1)
                public String queryFromRedis(){
                    return \"success\";
                }
             
            }<\/code><\/pre>\n\n\n\n
            \u4e3a\u4e86\u6a21\u62df\u6548\u679c\uff0c\u8fd9\u91cc\u5c06QPS\u8bbe\u7f6e\u4e3a1 \uff0c\u542f\u52a8\u5de5\u7a0b\u540e\uff08\u63d0\u524d\u542f\u52a8redis\u670d\u52a1\uff09\uff0c\u8c03\u7528\u4e00\u4e0b\u63a5\u53e3\uff0c\u6b63\u5e38\u7684\u6548\u679c\u5982\u4e0b\uff1a<\/p>\n\n\n\n
            \"\"<\/figure>\n\n\n\n
            \u5feb\u901f\u5237\u63a5\u53e3\uff0c\u8d85\u8fc7\u6bcf\u79d21\u6b21\u7684\u8bf7\u6c42\u65f6\u770b\u5230\u5982\u4e0b\u6548\u679c<\/p>\n\n\n\n
            \"\"<\/figure>\n\n\n\n
            \u4e0a\u9762\u901a\u8fc7\u6848\u4f8b\u4ecb\u7ecd\u4e86\u51e0\u79cd\u5e38\u7528\u7684\u9650\u6d41\u5b9e\u73b0\uff0c\u4e0d\u8fc7\u7ec6\u5fc3\u7684\u540c\u5b66\u53ef\u4ee5\u770b\u5230\uff0c\u8fd9\u4e9b\u9650\u6d41\u7684\u5b9e\u73b0\u90fd\u662f\u5728\u5177\u4f53\u7684\u5de5\u7a0b\u6a21\u5757\u4e2d\u5d4c\u5165\u7684\uff0c\u4e8b\u5b9e\u4e0a\uff0c\u5728\u771f\u5b9e\u7684\u5fae\u670d\u52a1\u5f00\u53d1\u4e2d\uff0c\u4e00\u4e2a\u9879\u76ee\u53ef\u80fd\u5305\u542b\u4e86\u4f17\u591a\u7684\u5fae\u670d\u52a1\u6a21\u5757\uff0c\u4e3a\u4e86\u51cf\u5c11\u91cd\u590d\u9020\u8f6e\u5b50\uff0c\u907f\u514d\u6bcf\u4e2a\u5fae\u670d\u52a1\u6a21\u5757\u4e2d\u5355\u72ec\u5b9e\u73b0\uff0c\u53ef\u4ee5\u8003\u8651\u5c06\u9650\u6d41\u7684\u903b\u8f91\u5b9e\u73b0\u5c01\u88c5\u6210\u4e00\u4e2aSDK\uff0c\u5373\u4f5c\u4e3a\u4e00\u4e2aspringboot\u7684starter\u7684\u65b9\u5f0f\u88ab\u5176\u4ed6\u5fae\u670d\u52a1\u6a21\u5757\u8fdb\u884c\u5f15\u7528\u5373\u53ef\u3002\u8fd9\u4e5f\u662f\u76ee\u524d\u5f88\u591a\u751f\u4ea7\u5b9e\u8df5\u4e2d\u6bd4\u8f83\u901a\u7528\u7684\u505a\u6cd5\uff0c\u63a5\u4e0b\u6765\u770b\u770b\u5177\u4f53\u7684\u5b9e\u73b0\u5427\u3002<\/p>\n\n\n\n
            5.1 \u524d\u7f6e\u51c6\u5907<\/h3>\n\n\n\n
            \u521b\u5efa\u4e00\u4e2a\u7a7a\u7684springboot\u5de5\u7a0b\uff0c\u5de5\u7a0b\u76ee\u5f55\u7ed3\u6784\u5982\u4e0b\u56fe\uff0c\u76ee\u5f55\u8bf4\u660e\uff1a<\/p>\n\n\n\n
              \n
            • annotation<\/code>\uff1a\u5b58\u653e\u81ea\u5b9a\u4e49\u7684\u9650\u6d41\u76f8\u5173\u7684\u6ce8\u89e3\uff1b<\/li>\n\n\n\n
            • aop<\/code>\uff1a\u5b58\u653e\u4e0d\u540c\u7684\u9650\u6d41\u5b9e\u73b0\uff0c\u6bd4\u5982\u57fa\u4e8eguava\u7684aop\uff0c\u57fa\u4e8esentinel\u7684aop\u5b9e\u73b0\u7b49\uff1b<\/li>\n\n\n\n
            • spring.factories<\/code>\uff1a\u81ea\u5b9a\u4e49\u5f85\u88c5\u914d\u7684aop\u5b9e\u73b0\u7c7b\uff1b<\/li>\n<\/ul>\n\n\n\n
              \"\"<\/figure>\n\n\n\n
              5.2 \u4ee3\u7801\u6574\u5408\u5b8c\u6210\u6b65\u9aa4<\/h3>\n\n\n\n
              5.2.1 \u5bfc\u5165\u57fa\u7840\u7684\u4f9d\u8d56<\/h5>\n\n\n\n
              \u8fd9\u91cc\u5305\u62ec\u5982\u4e0b\u51e0\u4e2a\u5fc5\u987b\u7684\u4f9d\u8d56\uff0c\u5176\u4ed6\u7684\u4f9d\u8d56\u53ef\u4ee5\u7ed3\u5408\u81ea\u8eab\u7684\u60c5\u51b5\u5408\u7406\u9009\u62e9\uff1b<\/p>\n\n\n\n
                \n
              • spring-boot-starter\uff1b<\/li>\n\n\n\n
              • guava\uff1b<\/li>\n\n\n\n
              • spring-boot-autoconfigure\uff1b<\/li>\n\n\n\n
              • sentinel-core\uff1b<\/li>\n<\/ul>\n\n\n\n
                    <parent>
                        <groupId>org.springframework.boot<\/groupId>
                        <artifactId>spring-boot-starter-parent<\/artifactId>
                        <version>2.2.1.RELEASE<\/version>
                        <relativePath\/>
                    <\/parent>
                 
                    <properties>
                        <project.build.sourceEncoding>UTF-8<\/project.build.sourceEncoding>
                        <project.reporting.outputEncoding>UTF-8<\/project.reporting.outputEncoding>
                        <java.version>1.8<\/java.version>
                    <\/properties>
                 
                    <dependencies>
                 
                        <dependency>
                            <groupId>org.springframework.boot<\/groupId>
                            <artifactId>spring-boot-starter-aop<\/artifactId>
                        <\/dependency>
                 
                        <dependency>
                            <groupId>log4j<\/groupId>
                            <artifactId>log4j<\/artifactId>
                            <version>1.2.17<\/version>
                        <\/dependency>
                 
                        <dependency>
                            <groupId>org.springframework.boot<\/groupId>
                            <artifactId>spring-boot-starter<\/artifactId>
                        <\/dependency>
                 
                        <dependency>
                            <groupId>org.springframework.boot<\/groupId>
                            <artifactId>spring-boot-starter-web<\/artifactId>
                        <\/dependency>
                 
                        <dependency>
                            <groupId>org.projectlombok<\/groupId>
                            <artifactId>lombok<\/artifactId>
                        <\/dependency>
                 
                        <!-- guava--><\/em>
                        <dependency>
                            <groupId>com.google.guava<\/groupId>
                            <artifactId>guava<\/artifactId>
                            <version>23.0<\/version>
                        <\/dependency>
                 
                        <dependency>
                            <groupId>org.springframework.boot<\/groupId>
                            <artifactId>spring-boot-autoconfigure<\/artifactId>
                            <version>2.2.1.RELEASE<\/version>
                        <\/dependency>
                 
                        <dependency>
                            <groupId>org.springframework.boot<\/groupId>
                            <artifactId>spring-boot-configuration-processor<\/artifactId>
                            <version>2.2.1.RELEASE<\/version>
                        <\/dependency>
                 
                        <dependency>
                            <groupId>com.alibaba.csp<\/groupId>
                            <artifactId>sentinel-core<\/artifactId>
                            <version>1.8.0<\/version>
                        <\/dependency>
                 
                        <dependency>
                            <groupId>org.apache.commons<\/groupId>
                            <artifactId>commons-lang3<\/artifactId>
                            <version>3.4<\/version>
                        <\/dependency>
                 
                        <dependency>
                            <groupId>com.alibaba.fastjson2<\/groupId>
                            <artifactId>fastjson2<\/artifactId>
                            <version>2.0.22<\/version>
                        <\/dependency>
                 
                    <\/dependencies>
                 
                    <build>
                        <resources>
                            <resource>
                                <directory>src\/main\/resources<\/directory>
                                <includes>
                                    <include>**\/**<\/include>
                                <\/includes>
                            <\/resource>
                        <\/resources>
                    <\/build><\/code><\/pre>\n\n\n\n
                5.2.2 \u81ea\u5b9a\u4e49\u6ce8\u89e3<\/h5>\n\n\n\n
                \u76ee\u524d\u8be5SDK\u652f\u6301\u4e09\u79cd\u9650\u6d41\u65b9\u5f0f\uff0c\u5373\u540e\u7eed\u5176\u4ed6\u5fae\u670d\u52a1\u5de5\u7a0b\u4e2d\u53ef\u4ee5\u901a\u8fc7\u6dfb\u52a0\u8fd93\u79cd\u6ce8\u89e3\u5373\u53ef\u5b9e\u73b0\u9650\u6d41\uff0c\u5206\u522b\u662f\u57fa\u4e8eguava\u7684\u4ee4\u724c\u6876\uff0c\u57fa\u4e8esentinel\u7684\u9650\u6d41\uff0c\u57fa\u4e8ejava\u81ea\u5e26\u7684Semaphore\u9650\u6d41\uff0c\u4e09\u4e2a\u81ea\u5b9a\u4e49\u6ce8\u89e3\u7c7b\u5982\u4e0b\uff1a<\/p>\n\n\n\n
                \u4ee4\u724c\u6876<\/p>\n\n\n\n
                @Documented
                @Target(ElementType.METHOD)
                @Retention(RetentionPolicy.RUNTIME)
                 
                public @interface TokenBucketLimiter {
                    int value() default 50;
                }<\/code><\/pre>\n\n\n\n
                Semaphore<\/p>\n\n\n\n
                @Documented
                @Target(ElementType.METHOD)
                @Retention(RetentionPolicy.RUNTIME)
                public @interface ShLimiter {
                    int value() default 50;
                }<\/code><\/pre>\n\n\n\n
                sentinel<\/p>\n\n\n\n
                @Target(value = ElementType.METHOD)
                @Retention(value = RetentionPolicy.RUNTIME)
                public @interface SentinelLimiter {
                 
                    String resourceName();
                 
                    int limitCount() default 50;
                 
                }<\/code><\/pre>\n\n\n\n
                5.2.3 \u9650\u6d41\u5b9e\u73b0AOP\u7c7b<\/h5>\n\n\n\n
                \u5177\u4f53\u7684\u9650\u6d41\u5728AOP\u4e2d\u8fdb\u884c\u5b9e\u73b0\uff0c\u601d\u8def\u548c\u4e0a\u4e00\u7ae0\u8282\u7c7b\u4f3c\uff0c\u5373\u901a\u8fc7\u73af\u7ed5\u901a\u77e5\u7684\u65b9\u5f0f\uff0c\u5148\u89e3\u6790\u90a3\u4e9b\u6dfb\u52a0\u4e86\u9650\u6d41\u6ce8\u89e3\u7684\u65b9\u6cd5\uff0c\u7136\u540e\u89e3\u6790\u91cc\u9762\u7684\u53c2\u6570\uff0c\u8fdb\u884c\u9650\u6d41\u7684\u4e1a\u52a1\u5b9e\u73b0\u3002<\/p>\n\n\n\n
                \u57fa\u4e8eguava\u7684aop\u5b9e\u73b0<\/p>\n\n\n\n
                import com.alibaba.fastjson2.JSONObject;
                import com.congge.annotation.TokenBucketLimiter;
                import com.google.common.util.concurrent.RateLimiter;
                import lombok.extern.slf4j.Slf4j;
                import org.aspectj.lang.ProceedingJoinPoint;
                import org.aspectj.lang.annotation.Around;
                import org.aspectj.lang.annotation.Aspect;
                import org.aspectj.lang.annotation.Pointcut;
                import org.springframework.cglib.core.ReflectUtils;
                import org.springframework.stereotype.Component;
                import org.springframework.web.context.request.RequestContextHolder;
                import org.springframework.web.context.request.ServletRequestAttributes;
                 
                import javax.servlet.ServletOutputStream;
                import javax.servlet.http.HttpServletResponse;
                import java.io.IOException;
                import java.lang.reflect.Method;
                import java.util.Arrays;
                import java.util.Map;
                import java.util.concurrent.ConcurrentHashMap;
                 
                @Aspect
                @Component
                @Slf4j
                public class GuavaLimiterAop {
                 
                    private final Map<String, RateLimiter> rateLimiters = new ConcurrentHashMap<String, RateLimiter>();
                 
                    @Pointcut(\"@annotation(com.congge.annotation.TokenBucketLimiter)\")
                    public void aspect() {
                    }
                 
                    @Around(value = \"aspect()\")
                    public Object around(ProceedingJoinPoint point) throws Throwable {
                        log.debug(\"\u51c6\u5907\u9650\u6d41\");
                        Object target = point.getTarget();
                        String targetName = target.getClass().getName();
                        String methodName = point.getSignature().getName();
                        Object[] arguments = point.getArgs();
                        Class<?> targetClass = Class.forName(targetName);
                        Class<?>[] argTypes = ReflectUtils.getClasses(arguments);
                        Method method = targetClass.getDeclaredMethod(methodName, argTypes);
                        \/\/ \u83b7\u53d6\u76ee\u6807method\u4e0a\u7684\u9650\u6d41\u6ce8\u89e3@Limiter<\/em>
                        TokenBucketLimiter limiter = method.getAnnotation(TokenBucketLimiter.class);
                        RateLimiter rateLimiter = null;
                        Object result = null;
                        if (null != limiter) {
                            \/\/ \u4ee5 class + method + parameters\u4e3akey\uff0c\u907f\u514d\u91cd\u8f7d\u3001\u91cd\u5199\u5e26\u6765\u7684\u6df7\u4e71<\/em>
                            String key = targetName + \".\" + methodName + Arrays.toString(argTypes);
                            rateLimiter = rateLimiters.get(key);
                            if (null == rateLimiter) {
                                \/\/ \u83b7\u53d6\u9650\u5b9a\u7684\u6d41\u91cf<\/em>
                                \/\/ \u4e3a\u4e86\u9632\u6b62\u5e76\u53d1<\/em>
                                rateLimiters.putIfAbsent(key, RateLimiter.create(limiter.value()));
                                rateLimiter = rateLimiters.get(key);
                            }
                            boolean b = rateLimiter.tryAcquire();
                            if(b){
                                log.debug(\"\u5f97\u5230\u4ee4\u724c\uff0c\u51c6\u5907\u6267\u884c\u4e1a\u52a1\");
                                result = point.proceed();
                            }else {
                                HttpServletResponse resp = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getResponse();
                                JSONObject jsonObject=new JSONObject();
                                jsonObject.put(\"success\",false);
                                jsonObject.put(\"msg\",\"\u9650\u6d41\u4e2d\");
                                try {
                                    output(resp, jsonObject.toJSONString());
                                }catch (Exception e){
                                    log.error(\"error,e:{}\",e);
                                }
                            }
                        } else {
                            result = point.proceed();
                        }
                        log.debug(\"\u9000\u51fa\u9650\u6d41\");
                        return result;
                    }
                 
                    public void output(HttpServletResponse response, String msg) throws IOException {
                        response.setContentType(\"application\/json;charset=UTF-8\");
                        ServletOutputStream outputStream = null;
                        try {
                            outputStream = response.getOutputStream();
                            outputStream.write(msg.getBytes(\"UTF-8\"));
                        } catch (IOException e) {
                            e.printStackTrace();
                        } finally {
                            outputStream.flush();
                            outputStream.close();
                        }
                    }
                }<\/code><\/pre>\n\n\n\n
                \u57fa\u4e8eSemaphore\u7684aop\u5b9e\u73b0<\/p>\n\n\n\n
                import com.congge.annotation.ShLimiter;
                import lombok.extern.slf4j.Slf4j;
                import org.aspectj.lang.ProceedingJoinPoint;
                import org.aspectj.lang.annotation.Around;
                import org.aspectj.lang.annotation.Aspect;
                import org.aspectj.lang.annotation.Pointcut;
                import org.slf4j.Logger;
                import org.slf4j.LoggerFactory;
                import org.springframework.cglib.core.ReflectUtils;
                import org.springframework.stereotype.Component;
                 
                import java.lang.reflect.Method;
                import java.util.Arrays;
                import java.util.Map;
                import java.util.concurrent.ConcurrentHashMap;
                import java.util.concurrent.Semaphore;
                 
                @Aspect
                @Component
                @Slf4j
                public class SemaphoreLimiterAop {
                 
                    private final Map<String, Semaphore> semaphores = new ConcurrentHashMap<String, Semaphore>();
                    private final static Logger LOG = LoggerFactory.getLogger(SemaphoreLimiterAop.class);
                 
                    @Pointcut(\"@annotation(com.congge.annotation.ShLimiter)\")
                    public void aspect() {
                 
                    }
                 
                    @Around(value = \"aspect()\")
                    public Object around(ProceedingJoinPoint point) throws Throwable {
                        log.debug(\"\u8fdb\u5165\u9650\u6d41aop\");
                        Object target = point.getTarget();
                        String targetName = target.getClass().getName();
                        String methodName = point.getSignature().getName();
                        Object[] arguments = point.getArgs();
                        Class<?> targetClass = Class.forName(targetName);
                        Class<?>[] argTypes = ReflectUtils.getClasses(arguments);
                        Method method = targetClass.getDeclaredMethod(methodName, argTypes);
                        \/\/ \u83b7\u53d6\u76ee\u6807method\u4e0a\u7684\u9650\u6d41\u6ce8\u89e3@Limiter<\/em>
                        ShLimiter limiter = method.getAnnotation(ShLimiter.class);
                        Object result = null;
                        if (null != limiter) {
                            \/\/ \u4ee5 class + method + parameters\u4e3akey\uff0c\u907f\u514d\u91cd\u8f7d\u3001\u91cd\u5199\u5e26\u6765\u7684\u6df7\u4e71<\/em>
                            String key = targetName + \".\" + methodName + Arrays.toString(argTypes);
                            \/\/ \u83b7\u53d6\u9650\u5b9a\u7684\u6d41\u91cf<\/em>
                            Semaphore semaphore = semaphores.get(key);
                            if (null == semaphore) {
                                semaphores.putIfAbsent(key, new Semaphore(limiter.value()));
                                semaphore = semaphores.get(key);
                            }
                            try {
                                semaphore.acquire();
                                result = point.proceed();
                            } finally {
                                if (null != semaphore) {
                                    semaphore.release();
                                }
                            }
                        } else {
                            result = point.proceed();
                        }
                        log.debug(\"\u9000\u51fa\u9650\u6d41\");
                        return result;
                    }
                 
                }<\/code><\/pre>\n\n\n\n
                \u57fa\u4e8esentinel\u7684aop\u5b9e\u73b0<\/p>\n\n\n\n
                import com.alibaba.csp.sentinel.Entry;
                import com.alibaba.csp.sentinel.SphU;
                import com.alibaba.csp.sentinel.Tracer;
                import com.alibaba.csp.sentinel.slots.block.BlockException;
                import com.alibaba.csp.sentinel.slots.block.RuleConstant;
                import com.alibaba.csp.sentinel.slots.block.flow.FlowRule;
                import com.alibaba.csp.sentinel.slots.block.flow.FlowRuleManager;
                import com.congge.annotation.SentinelLimiter;
                import org.apache.commons.lang3.StringUtils;
                import org.aspectj.lang.JoinPoint;
                import org.aspectj.lang.ProceedingJoinPoint;
                import org.aspectj.lang.annotation.Around;
                import org.aspectj.lang.annotation.Aspect;
                import org.aspectj.lang.annotation.Pointcut;
                import org.springframework.stereotype.Component;
                 
                import java.lang.reflect.Method;
                import java.util.ArrayList;
                import java.util.List;
                import java.util.Objects;
                 
                @Aspect
                @Component
                public class SentinelLimiterAop {
                 
                    private static void initFlowRule(String resourceName,int limitCount) {
                        List<FlowRule> rules = new ArrayList<>();
                        FlowRule rule = new FlowRule();
                        \/\/\u8bbe\u7f6e\u53d7\u4fdd\u62a4\u7684\u8d44\u6e90<\/em>
                        rule.setResource(resourceName);
                        \/\/\u8bbe\u7f6e\u6d41\u63a7\u89c4\u5219 QPS<\/em>
                        rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
                        \/\/\u8bbe\u7f6e\u53d7\u4fdd\u62a4\u7684\u8d44\u6e90\u9608\u503c<\/em>
                        rule.setCount(limitCount);
                        rules.add(rule);
                        \/\/\u52a0\u8f7d\u914d\u7f6e\u597d\u7684\u89c4\u5219<\/em>
                        FlowRuleManager.loadRules(rules);
                    }
                 
                    @Pointcut(value = \"@annotation(com.congge.annotation.SentinelLimiter)\")
                    public void rateLimit() {
                 
                    }
                 
                    @Around(\"rateLimit()\")
                    public Object around(ProceedingJoinPoint joinPoint) {
                        \/\/1\u3001\u83b7\u53d6\u5f53\u524d\u7684\u8c03\u7528\u65b9\u6cd5<\/em>
                        Method currentMethod = getCurrentMethod(joinPoint);
                        if (Objects.isNull(currentMethod)) {
                            return null;
                        }
                        \/\/2\u3001\u4ece\u65b9\u6cd5\u6ce8\u89e3\u5b9a\u4e49\u4e0a\u83b7\u53d6\u9650\u6d41\u7684\u7c7b\u578b<\/em>
                        String resourceName = currentMethod.getAnnotation(SentinelLimiter.class).resourceName();
                        if(StringUtils.isEmpty(resourceName)){
                            throw new RuntimeException(\"\u8d44\u6e90\u540d\u79f0\u4e3a\u7a7a\");
                        }
                        int limitCount = currentMethod.getAnnotation(SentinelLimiter.class).limitCount();
                        initFlowRule(resourceName,limitCount);
                 
                        Entry entry = null;
                        Object result = null;
                        try {
                            entry = SphU.entry(resourceName);
                            try {
                                result = joinPoint.proceed();
                            } catch (Throwable throwable) {
                                throwable.printStackTrace();
                            }
                        } catch (BlockException ex) {
                            \/\/ \u8d44\u6e90\u8bbf\u95ee\u963b\u6b62\uff0c\u88ab\u9650\u6d41\u6216\u88ab\u964d\u7ea7<\/em>
                            \/\/ \u5728\u6b64\u5904\u8fdb\u884c\u76f8\u5e94\u7684\u5904\u7406\u64cd\u4f5c<\/em>
                            System.out.println(\"blocked\");
                            return \"\u88ab\u9650\u6d41\u4e86\";
                        } catch (Exception e) {
                            Tracer.traceEntry(e, entry);
                        } finally {
                            if (entry != null) {
                                entry.exit();
                            }
                        }
                        return result;
                    }
                 
                    private Method getCurrentMethod(JoinPoint joinPoint) {
                        Method[] methods = joinPoint.getTarget().getClass().getMethods();
                        Method target = null;
                        for (Method method : methods) {
                            if (method.getName().equals(joinPoint.getSignature().getName())) {
                                target = method;
                                break;
                            }
                        }
                        return target;
                    }
                 
                }<\/code><\/pre>\n\n\n\n
                5.2.4 \u914d\u7f6e\u81ea\u52a8\u88c5\u914dAOP\u5b9e\u73b0<\/h5>\n\n\n\n
                \u5728resources\u76ee\u5f55\u4e0b\u521b\u5efa\u4e0a\u8ff0\u7684spring.factories<\/code>\u6587\u4ef6\uff0c\u5185\u5bb9\u5982\u4e0b\uff0c\u901a\u8fc7\u8fd9\u79cd\u65b9\u5f0f\u914d\u7f6e\u540e\uff0c\u5176\u4ed6\u5e94\u7528\u6a21\u5757\u5f15\u5165\u4e86\u5f53\u524d\u7684SDK\u7684jar\u4e4b\u540e\uff0c\u5c31\u53ef\u4ee5\u5b9e\u73b0\u5f00\u7bb1\u5373\u7528\u4e86\uff1b<\/p>\n\n\n\n
                org.springframework.boot.autoconfigure.EnableAutoConfiguration=\\
                  com.congge.aop.SemaphoreLimiterAop,\\
                  com.congge.aop.GuavaLimiterAop,\\
                  com.congge.aop.SemaphoreLimiterAop<\/code><\/pre>\n\n\n\n
                5.2.5 \u5c06\u5de5\u7a0b\u6253\u6210jar\u8fdb\u884c\u5b89\u88c5<\/h5>\n\n\n\n
                \u8fd9\u4e00\u6b65\u6bd4\u8f83\u7b80\u5355\u5c31\u8df3\u8fc7\u4e86<\/p>\n\n\n\n
                \"\"<\/figure>\n\n\n\n
                5.2.6 \u5728\u5176\u4ed6\u7684\u5de5\u7a0b\u4e2d\u5f15\u5165\u4e0a\u8ff0SDK<\/h5>\n\n\n\n
                <dependency>
                    <groupId>cm.congge<\/groupId>
                    <artifactId>biz-limit<\/artifactId>
                    <version>1.0-SNAPSHOT<\/version>
                <\/dependency><\/code><\/pre>\n\n\n\n
                5.2.7 \u7f16\u5199\u6d4b\u8bd5\u63a5\u53e3<\/h5>\n\n\n\n
                \u5728\u5176\u4ed6\u5de5\u7a0b\u4e2d\uff0c\u7f16\u5199\u4e00\u4e2a\u6d4b\u8bd5\u63a5\u53e3\uff0c\u5e76\u4f7f\u7528\u4e0a\u9762\u7684\u6ce8\u89e3\uff0c\u8fd9\u91cc\u4ee5guava\u7684\u9650\u6d41\u6ce8\u89e3\u4e3a\u4f8b\u8fdb\u884c\u8bf4\u660e<\/p>\n\n\n\n
                import com.congge.annotation.TokenBucketLimiter;
                import org.springframework.web.bind.annotation.GetMapping;
                import org.springframework.web.bind.annotation.RestController;
                 
                @RestController
                public class SdkController {
                 
                    \/\/localhost:8081\/query<\/em>
                    @GetMapping(\"\/query\")
                    @TokenBucketLimiter(1)
                    public String queryUser(){
                        return \"queryUser\";
                    }
                 
                }<\/code><\/pre>\n\n\n\n
                5.2.8 \u529f\u80fd\u6d4b\u8bd5<\/h5>\n\n\n\n
                \u542f\u52a8\u5f53\u524d\u7684\u5de5\u7a0b\u540e\uff0c\u6b63\u5e38\u8c03\u7528\u63a5\u53e3\uff0c\u6bcf\u79d2\u4e00\u6b21\u7684\u8bf7\u6c42\uff0c\u53ef\u4ee5\u6b63\u5e38\u5f97\u5230\u7ed3\u679c<\/p>\n\n\n\n
                \"\"<\/figure>\n\n\n\n
                \u5feb\u901f\u5237\u63a5\u53e3\uff0cQPS\u8d85\u8fc71\u4e4b\u540e\uff0c\u5c06\u4f1a\u89e6\u53d1\u9650\u6d41\uff0c\u770b\u5230\u5982\u4e0b\u6548\u679c<\/p>\n\n\n\n
                \"\"<\/figure>\n\n\n\n
                \u901a\u8fc7\u4e0a\u9762\u8fd9\u79cd\u65b9\u5f0f\uff0c\u4e5f\u53ef\u4ee5\u5f97\u5230\u9884\u671f\u7684\u6548\u679c\uff0c\u5176\u4ed6\u4e24\u79cd\u9650\u6d41\u6ce8\u89e3\u6709\u5174\u8da3\u7684\u540c\u5b66\u4e5f\u53ef\u4ee5\u7ee7\u7eed\u6d4b\u8bd5\u9a8c\u8bc1\uff0c\u7bc7\u5e45\u539f\u56e0\u5c31\u4e0d\u518d\u8d58\u8ff0\u4e86\u3002<\/p>\n\n\n\n
                \n
                \u4e0a\u8ff0\u901a\u8fc7starter\u7684\u65b9\u5f0f\u5b9e\u73b0\u4e86\u4e00\u79cd\u66f4\u4f18\u96c5\u7684\u9650\u6d41\u96c6\u6210\u65b9\u5f0f\uff0c\u4e5f\u662f\u751f\u4ea7\u4e2d\u6bd4\u8f83\u63a8\u8350\u7684\u4e00\u79cd\u65b9\u5f0f\uff0c\u4e0d\u8fc7\u5f53\u524d\u7684\u6848\u4f8b\u8fd8\u6bd4\u8f83\u7c97\u7cd9\uff0c\u9700\u8981\u4f7f\u7528\u7684\u540c\u5b66\u8fd8\u9700\u6839\u636e\u81ea\u5df1\u7684\u60c5\u51b5\u5b8c\u5584\u91cc\u9762\u7684\u903b\u8f91\uff0c\u8fdb\u4e00\u6b65\u7684\u5c01\u88c5\u4ee5\u671f\u5f97\u5230\u66f4\u597d\u7684\u6548\u679c\u3002<\/p>\n\n\n\n
                <\/p>\n<\/blockquote>\n","protected":false},"excerpt":{"rendered":"
                \u539f\u6587\uff1amp.weixin.qq.com\/s\/8ICTZRvgJlI5F8gO13JwDA \u4e00\u3001\u80cc\u666f \u9650\u6d41\u5bf9\u4e8e\u4e00 […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[6],"tags":[267],"_links":{"self":[{"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=\/wp\/v2\/posts\/4338"}],"collection":[{"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=4338"}],"version-history":[{"count":4,"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=\/wp\/v2\/posts\/4338\/revisions"}],"predecessor-version":[{"id":4360,"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=\/wp\/v2\/posts\/4338\/revisions\/4360"}],"wp:attachment":[{"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=4338"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=4338"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.zeroheart.xyz\/wordpress\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=4338"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}