{"id":10021122,"date":"2025-12-16T23:38:28","date_gmt":"2025-12-16T15:38:28","guid":{"rendered":"https:\/\/itmax.cn\/?p=10021122"},"modified":"2025-12-16T23:38:28","modified_gmt":"2025-12-16T15:38:28","slug":"go%e8%af%ad%e8%a8%80%e5%9c%a8%e9%ab%98%e5%b9%b6%e5%8f%91%e9%ab%98%e5%8f%af%e7%94%a8%e7%b3%bb%e7%bb%9f%e4%b8%ad%e7%9a%84%e5%ae%9e%e8%b7%b5%e4%b8%8e%e8%a7%a3%e5%86%b3%e6%96%b9%e6%a1%88%ef%bd%9c%e5%be%97","status":"publish","type":"post","link":"https:\/\/itmax.cn\/?p=10021122","title":{"rendered":"Go\u8bed\u8a00\u5728\u9ad8\u5e76\u53d1\u9ad8\u53ef\u7528\u7cfb\u7edf\u4e2d\u7684\u5b9e\u8df5\u4e0e\u89e3\u51b3\u65b9\u6848\uff5c\u5f97\u7269\u6280\u672f"},"content":{"rendered":"

\u4e00\u3001\u5f15\u8a00<\/h2>\n

\u968f\u7740\u4e92\u8054\u7f51\u6280\u672f\u7684\u98de\u901f\u53d1\u5c55\uff0c\u73b0\u4ee3\u7cfb\u7edf\u9762\u4e34\u7740\u524d\u6240\u672a\u6709\u7684\u5e76\u53d1\u538b\u529b\u548c\u53ef\u7528\u6027\u8981\u6c42\u3002\u4ece\u7535\u5546\u79d2\u6740\u5230\u793e\u4ea4\u5a92\u4f53\u76f4\u64ad\uff0c\u4ece\u91d1\u878d\u4ea4\u6613\u5230\u7269\u8054\u7f51\u8bbe\u5907\u63a5\u5165\uff0c\u7cfb\u7edf\u9700\u8981\u5904\u7406\u767e\u4e07\u7ea7\u751a\u81f3\u5343\u4e07\u7ea7\u7684\u5e76\u53d1\u8bf7\u6c42\uff0c\u540c\u65f6\u4fdd\u8bc199.999%\u7684\u53ef\u7528\u6027\u3002\u5728\u8fd9\u79cd\u80cc\u666f\u4e0b\uff0cGo\u8bed\u8a00\u51ed\u501f\u5176\u72ec\u7279\u7684\u8bbe\u8ba1\u54f2\u5b66\u548c\u6280\u672f\u7279\u6027\uff0c\u6210\u4e3a\u4e86\u6784\u5efa\u9ad8\u5e76\u53d1\u9ad8\u53ef\u7528\u7cfb\u7edf\u7684\u9996\u9009\u8bed\u8a00\u4e4b\u4e00\u3002<\/strong><\/p>\n

Go\u8bed\u8a00\u81ea2009\u5e74\u8bde\u751f\u4ee5\u6765\uff0c\u5c31\u4ee5 “\u5e76\u53d1\u6027\u80fd\u4f18\u5f02\u3001\u5f00\u53d1\u6548\u7387\u9ad8\u3001\u90e8\u7f72\u7b80\u5355”\u7b49\u7279\u70b9\u53d7\u5230\u5f00\u53d1\u8005\u7684\u9752\u7750<\/strong>\u3002\u5176\u6838\u5fc3\u4f18\u52bf\u5305\u62ec\uff1a\u8f7b\u91cf\u7ea7\u534f\u7a0b\uff08Goroutine\uff09\u3001\u9ad8\u6548\u7684\u8c03\u5ea6\u5668\u3001\u539f\u751f\u652f\u6301\u5e76\u53d1\u7f16\u7a0b\u3001\u9ad8\u6027\u80fd\u7f51\u7edc\u5e93\u7b49\u3002<\/strong> \u8fd9\u4e9b\u7279\u6027\u4f7f\u5f97Go\u8bed\u8a00\u5728\u5904\u7406\u9ad8\u5e76\u53d1\u573a\u666f\u65f6\u5177\u6709\u5929\u7136\u4f18\u52bf\u3002<\/p>\n

\u672c\u6587\u5c06\u901a\u8fc7\u4e94\u4e2a\u5178\u578b\u7684\u9ad8\u5e76\u53d1\u9ad8\u53ef\u7528\u573a\u666f\uff0c\u6df1\u5165\u5206\u6790\u4f20\u7edf\u67b6\u6784\u9762\u4e34\u7684\u95ee\u9898\u77db\u76fe\u70b9\uff0c\u5e76\u8be6\u7ec6\u9610\u8ff0Go\u8bed\u8a00\u7684\u89e3\u51b3\u65b9\u6848\uff0c\u5305\u62ec\u6838\u5fc3\u6280\u672f\u3001\u4ee3\u7801\u5b9e\u73b0\u548c\u7406\u8bba\u77e5\u8bc6\u652f\u6491\uff0c\u5c55\u793aGo\u8bed\u8a00\u5728\u6784\u5efa\u9ad8\u5e76\u53d1\u9ad8\u53ef\u7528\u7cfb\u7edf\u4e2d\u7684\u5f3a\u5927\u80fd\u529b\u3002<\/p>\n

\u4e8c\u3001\u573a\u666f1\uff1a\u5fae\u670d\u52a1\u9ad8\u5e76\u53d1\u901a\u4fe1\uff08gRPC\uff09<\/h2>\n

\u573a\u666f\u63cf\u8ff0<\/h3>\n

\u5728\u73b0\u4ee3\u5fae\u670d\u52a1\u67b6\u6784\u4e2d\uff0c\u670d\u52a1\u95f4\u901a\u4fe1\u662f\u7cfb\u7edf\u7684\u6838\u5fc3\u7ec4\u6210\u90e8\u5206\u3002\u968f\u7740\u670d\u52a1\u6570\u91cf\u7684\u589e\u52a0\u548c\u4e1a\u52a1\u590d\u6742\u5ea6\u7684\u63d0\u5347\uff0c\u670d\u52a1\u95f4\u901a\u4fe1\u7684\u6027\u80fd\u548c\u53ef\u9760\u6027\u76f4\u63a5\u5f71\u54cd\u5230\u6574\u4e2a\u7cfb\u7edf\u7684\u541e\u5410\u91cf\u548c\u54cd\u5e94\u65f6\u95f4\u3002<\/strong> \u4f8b\u5982\uff0c\u4e00\u4e2a\u7535\u5546\u7cfb\u7edf\u53ef\u80fd\u5305\u542b\u7528\u6237\u670d\u52a1\u3001\u5546\u54c1\u670d\u52a1\u3001\u8ba2\u5355\u670d\u52a1\u3001\u652f\u4ed8\u670d\u52a1\u7b49\u6570\u5341\u4e2a\u5fae\u670d\u52a1\uff0c\u8fd9\u4e9b\u670d\u52a1\u4e4b\u95f4\u9700\u8981\u8fdb\u884c\u5927\u91cf\u7684\u6570\u636e\u4ea4\u4e92\u3002\u5f53\u7cfb\u7edf\u9762\u4e34\u9ad8\u5cf0\u671f\uff08\u5982\u5927\u4fc3\u6d3b\u52a8\uff09\u65f6\uff0c\u670d\u52a1\u95f4\u901a\u4fe1\u7684\u5e76\u53d1\u91cf\u53ef\u80fd\u8fbe\u5230\u6bcf\u79d2\u6570\u4e07\u6b21\u751a\u81f3\u6570\u5341\u4e07\u6b21\u3002<\/p>\n

\u95ee\u9898\u77db\u76fe\u70b9<\/h3>\n

\u4f20\u7edf\u5fae\u670d\u52a1\u67b6\u6784\u4e2d\uff0c\u670d\u52a1\u95f4\u901a\u4fe1\u5e38\u9762\u4e34\u4ee5\u4e0b\u51e0\u5927\u77db\u76fe\uff1a<\/p>\n

    \n
  1. \u540c\u6b65\u963b\u585eI\/O vs \u9ad8\u5e76\u53d1\u9700\u6c42\uff1a<\/strong> \u4f20\u7edfHTTP\/1.1\u534f\u8bae\u91c7\u7528\u540c\u6b65\u963b\u585e\u6a21\u578b\uff0c\u6bcf\u4e2a\u8bf7\u6c42\u9700\u8981\u5360\u7528\u4e00\u4e2a\u7ebf\u7a0b\u3002\u5f53QPS\u8fbe\u5230\u6570\u4e07\u7ea7\u65f6\uff0c\u7ebf\u7a0b\u6c60\u8d44\u6e90\u8fc5\u901f\u8017\u5c3d\uff08\u5982Java\u7684Tomcat\u9ed8\u8ba4200\u7ebf\u7a0b\uff09\uff0c\u5bfc\u81f4\u8bf7\u6c42\u5806\u79ef\u3001\u5ef6\u8fdf\u98d9\u5347\u3002\u867d\u7136\u53ef\u4ee5\u901a\u8fc7\u589e\u52a0\u7ebf\u7a0b\u6570\u6765\u7f13\u89e3\uff0c\u4f46\u7ebf\u7a0b\u7684\u521b\u5efa\u548c\u4e0a\u4e0b\u6587\u5207\u6362\u5f00\u9500\u5de8\u5927\uff0c\u7cfb\u7edf\u6027\u80fd\u4f1a\u6025\u5267\u4e0b\u964d\u3002<\/li>\n
  2. \u5e8f\u5217\u5316\/\u53cd\u5e8f\u5217\u5316\u5f00\u9500\u5927\uff1a<\/strong> JSON\/XML\u7b49\u6587\u672c\u534f\u8bae\u5728\u6570\u636e\u91cf\u5927\u65f6\uff0c\u5e8f\u5217\u5316\u548c\u53cd\u5e8f\u5217\u5316\u8017\u65f6\u663e\u8457\u589e\u52a0\uff0c\u6210\u4e3a\u6027\u80fd\u74f6\u9888\u3002\u4f8b\u5982\uff0c\u5bf9\u4e8e\u5305\u542b\u590d\u6742\u7ed3\u6784\u7684\u6570\u636e\uff0cJSON\u5e8f\u5217\u5316\u53ef\u80fd\u6bd4\u4e8c\u8fdb\u5236\u534f\u8bae\u61625-10\u500d\uff0c\u540c\u65f6\u6570\u636e\u4f53\u79ef\u4e5f\u4f1a\u592730%-50%\uff0c\u589e\u52a0\u4e86\u7f51\u7edc\u4f20\u8f93\u5f00\u9500\u3002<\/li>\n
  3. \u670d\u52a1\u6cbb\u7406\u590d\u6742\u5ea6\u9ad8\uff1a<\/strong> \u968f\u7740\u670d\u52a1\u6570\u91cf\u7684\u589e\u52a0\uff0c\u670d\u52a1\u53d1\u73b0\u3001\u8d1f\u8f7d\u5747\u8861\u3001\u7194\u65ad\u964d\u7ea7\u7b49\u670d\u52a1\u6cbb\u7406\u529f\u80fd\u53d8\u5f97\u8d8a\u6765\u8d8a\u590d\u6742\u3002\u4f20\u7edf\u7684HTTP\u5ba2\u6237\u7aef\uff08\u5982Java\u7684RestTemplate\uff09\u7f3a\u4e4f\u5bf9\u8fd9\u4e9b\u529f\u80fd\u7684\u539f\u751f\u652f\u6301\uff0c\u9700\u8981\u4f9d\u8d56\u989d\u5916\u7684\u6846\u67b6\uff08\u5982Spring Cloud\uff09\uff0c\u589e\u52a0\u4e86\u7cfb\u7edf\u7684\u590d\u6742\u6027\u548c\u5b66\u4e60\u6210\u672c\u3002<\/li>\n
  4. \u8de8\u8bed\u8a00\u517c\u5bb9\u6027\u5dee\uff1a<\/strong> \u5728\u591a\u8bed\u8a00\u73af\u5883\u4e0b\uff0c\u4e0d\u540c\u670d\u52a1\u53ef\u80fd\u4f7f\u7528\u4e0d\u540c\u7684\u7f16\u7a0b\u8bed\u8a00\u5f00\u53d1\uff0c\u4f20\u7edf\u7684HTTP+JSON\u65b9\u6848\u867d\u7136\u901a\u7528\u6027\u5f3a\uff0c\u4f46\u5728\u7c7b\u578b\u5b89\u5168\u548c\u63a5\u53e3\u4e00\u81f4\u6027\u65b9\u9762\u5b58\u5728\u95ee\u9898\uff0c\u5bb9\u6613\u5bfc\u81f4\u670d\u52a1\u95f4\u8c03\u7528\u9519\u8bef\u3002
    1.<\/li>\n<\/ol>\n

    Go\u89e3\u51b3\u65b9\u6848\u6838\u5fc3\u6280\u672f<\/h3>\n

    gRPC + Protocol Buffers<\/strong><\/p>\n

    gRPC\u662fGoogle\u5f00\u6e90\u7684\u9ad8\u6027\u80fdRPC\u6846\u67b6\uff0c\u57fa\u4e8eHTTP\/2\u534f\u8bae\u548cProtocol Buffers\u5e8f\u5217\u5316\u534f\u8bae\uff0c\u4e3a\u5fae\u670d\u52a1\u901a\u4fe1\u63d0\u4f9b\u4e86\u9ad8\u6548\u3001\u53ef\u9760\u7684\u89e3\u51b3\u65b9\u6848\u3002Go\u8bed\u8a00\u539f\u751f\u652f\u6301gRPC\uff0c\u901a\u8fc7google.golang.org\/grpc\u5305\u53ef\u4ee5\u8f7b\u677e\u5b9e\u73b0gRPC\u670d\u52a1\u7aef\u548c\u5ba2\u6237\u7aef\u3002<\/p>\n

    HTTP\/2\u591a\u8def\u590d\u7528<\/strong><\/p>\n

    HTTP\/2\u534f\u8bae\u652f\u6301\u5355\u8fde\u63a5\u591a\u8def\u590d\u7528\uff0c\u5141\u8bb8\u5728\u4e00\u4e2aTCP\u8fde\u63a5\u4e0a\u540c\u65f6\u4f20\u8f93\u591a\u4e2a\u8bf7\u6c42\u548c\u54cd\u5e94\u3002\u8fd9\u610f\u5473\u7740\u53ef\u4ee5\u901a\u8fc7\u4e00\u4e2a\u8fde\u63a5\u5904\u7406\u6210\u767e\u4e0a\u5343\u4e2a\u5e76\u53d1\u8bf7\u6c42\uff0c\u907f\u514d\u4e86\u4f20\u7edfHTTP\/1.1\u534f\u8bae\u4e2d”\u8fde\u63a5\u6570\u7206\u70b8”\u7684\u95ee\u9898\u3002Go\u7684net\/http2\u5e93\u539f\u751f\u652f\u6301HTTP\/2\u534f\u8bae\uff0c\u914d\u5408Goroutine\u8c03\u5ea6\uff0c\u53ef\u4ee5\u8f7b\u677e\u5904\u7406\u767e\u4e07\u7ea7\u5e76\u53d1\u8fde\u63a5\u3002<\/p>\n

    Protocol Buffers\u5e8f\u5217\u5316<\/strong><\/p>\n

    Protocol Buffers\u662f\u4e00\u79cd\u9ad8\u6548\u7684\u4e8c\u8fdb\u5236\u5e8f\u5217\u5316\u534f\u8bae\uff0c\u76f8\u6bd4JSON\/XML\u5177\u6709\u4ee5\u4e0b\u4f18\u52bf\uff1a<\/p>\n

      \n
    • \u4f53\u79ef\u5c0f\uff1a<\/strong> \u4e8c\u8fdb\u5236\u683c\u5f0f\uff0c\u76f8\u6bd4JSON\u8282\u770130%-50%\u7684\u5e26\u5bbd<\/li>\n
    • \u89e3\u6790\u901f\u5ea6\u5feb\uff1a<\/strong> \u4f7f\u7528\u9884\u7f16\u8bd1\u7684\u4ee3\u7801\u751f\u6210\u5668\uff0c\u89e3\u6790\u901f\u5ea6\u6bd4JSON\u5feb5-10\u500d<\/li>\n
    • \u7c7b\u578b\u5b89\u5168\uff1a<\/strong> \u5f3a\u7c7b\u578b\u5b9a\u4e49\uff0c\u7f16\u8bd1\u65f6\u68c0\u67e5\uff0c\u907f\u514d\u8fd0\u884c\u65f6\u9519\u8bef<\/li>\n
    • \u8de8\u8bed\u8a00\u517c\u5bb9\uff1a<\/strong> \u652f\u6301\u591a\u79cd\u7f16\u7a0b\u8bed\u8a00\uff0c\u5305\u62ecGo\u3001Java\u3001Python\u3001C++\u7b49<\/li>\n<\/ul>\n

      Goroutine\u6c60\u5316\u4e0e\u590d\u7528<\/strong><\/p>\n

      \u867d\u7136Goroutine\u7684\u521b\u5efa\u5f00\u9500\u6bd4\u7ebf\u7a0b\u4f4e\u5f88\u591a\uff0c\u4f46\u5728\u6781\u9ad8\u5e76\u53d1\u573a\u666f\u4e0b\uff08\u5982\u6bcf\u79d2\u6570\u5341\u4e07\u8bf7\u6c42\uff09\uff0c\u9891\u7e41\u521b\u5efa\u548c\u9500\u6bc1Goroutine\u4ecd\u7136\u4f1a\u5e26\u6765\u4e00\u5b9a\u7684\u6027\u80fd\u5f00\u9500\u3002Go\u8bed\u8a00\u63d0\u4f9b\u4e86sync.Pool\u5305\uff0c\u53ef\u4ee5\u5b9e\u73b0Goroutine\u7684\u590d\u7528\uff0c\u51cf\u5c11\u8c03\u5ea6\u5f00\u9500\u3002<\/p>\n

      \u4ee3\u7801\u5b9e\u73b0<\/h3>\n

      \"\"<\/p>\n

      gRPC\u670d\u52a1\u5b9a\u4e49<\/strong><\/p>\n

      \/\/ service.proto\nsyntax = "proto3";\npackage example;\n\/\/ \u5b9a\u4e49\u670d\u52a1\n service UserService {\n  \/\/ \u5b9a\u4e49\u65b9\u6cd5\n  rpc GetUser(GetUserRequest) returns (GetUserResponse) {}\n}\n\/\/ \u8bf7\u6c42\u6d88\u606f\nmessage GetUserRequest {\n  int64 user_id = 1;\n}\n\/\/ \u54cd\u5e94\u6d88\u606f\nmessage GetUserResponse {\n  int64 user_id = 1;\n  string username = 2;\n  string email = 3;\n}<\/code><\/pre>\n
      gRPC\u670d\u52a1\u7aef\u5b9e\u73b0<\/strong><\/p>\n
      \/\/ \u5b9a\u4e49\u670d\u52a1\u7ed3\u6784\u4f53\ntype server struct {\n    pb.UnimplementedUserServiceServer\n}\n\/\/ \u5b9e\u73b0GetUser\u65b9\u6cd5\nfunc (s *server) GetUser(ctx context.Context, in *pb.GetUserRequest) (*pb.GetUserResponse, error) {\n    \/\/ \u6a21\u62df\u6570\u636e\u5e93\u67e5\u8be2\n    user := &pb.GetUserResponse{\n        UserId:   in.UserId,\n        Username: fmt.Sprintf("user_%d", in.UserId),\n        Email:    fmt.Sprintf("user_%d@example.com", in.UserId),\n    }\n    return user, nil\n}\nfunc main() {\n    \/\/ \u76d1\u542c\u7aef\u53e3\n    listener, err := net.Listen("tcp", ":50051")\n    if err != nil {\n        log.Fatalf("failed to listen: %v", err)\n    }\n    \/\/ \u521b\u5efagRPC\u670d\u52a1\u5668\n    s := grpc.NewServer(\n        grpc.MaxConcurrentStreams(1000), \/\/ \u8bbe\u7f6e\u6700\u5927\u5e76\u53d1\u6d41\u6570\n        grpc.InitialWindowSize(65536),   \/\/ \u8bbe\u7f6e\u521d\u59cb\u7a97\u53e3\u5927\u5c0f\n    )\n    \/\/ \u6ce8\u518c\u670d\u52a1\n    pb.RegisterUserServiceServer(s, &server{})\n    \/\/ \u6ce8\u518c\u53cd\u5c04\u670d\u52a1\n    reflection.Register(s)\n    \/\/ \u542f\u52a8\u670d\u52a1\u5668\n    log.Printf("server listening at %v", listener.Addr())\n    if err := s.Serve(listener); err != nil {\n        log.Fatalf("failed to serve: %v", err)\n    }\n}<\/code><\/pre>\n
      gRPC\u5ba2\u6237\u7aef\u5b9e\u73b0<\/strong><\/p>\n
      \n\nfunc main() {\n    \/\/ \u8fde\u63a5\u670d\u52a1\u5668\n    conn, err := grpc.Dial(":50051", \n        grpc.WithTransportCredentials(insecure.NewCredentials()),\n        grpc.WithBlock(),\n        grpc.WithTimeout(5*time.Second),\n        grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(1024*1024)), \/\/ \u8bbe\u7f6e\u6700\u5927\u63a5\u6536\u6d88\u606f\u5927\u5c0f\n    )\n    if err != nil {\n        log.Fatalf("did not connect: %v", err)\n    }\n    defer conn.Close()\n    \/\/ \u521b\u5efa\u5ba2\u6237\u7aef\n    c := pb.NewUserServiceClient(conn)\n    \/\/ \u8c03\u7528GetUser\u65b9\u6cd5\n    ctx, cancel := context.WithTimeout(context.Background(), time.Second)\n    defer cancel()\n    \/\/ \u6279\u91cf\u8bf7\u6c42\u793a\u4f8b\n    for i := 0; i < 100; i++ {\n        go func(userID int64) {\n            resp, err := c.GetUser(ctx, &pb.GetUserRequest{UserId: userID})\n            if err != nil {\n                log.Printf("could not get user: %v", err)\n                return\n            }\n            log.Printf("User: %d, %s, %s", resp.UserId, resp.Username, resp.Email)\n        }(int64(i))\n    }\n    \/\/ \u7b49\u5f85\u6240\u6709\u8bf7\u6c42\u5b8c\u6210\n    time.Sleep(2 * time.Second)\n}<\/code><\/pre>\n
      \u7406\u8bba\u77e5\u8bc6\u652f\u6491<\/h3>\n
      Reactor\u6a21\u5f0f<\/strong><\/p>\n
      gRPC\u670d\u52a1\u5668\u4f7f\u7528Reactor\u6a21\u5f0f\u76d1\u542c\u8fde\u63a5\u4e8b\u4ef6\uff0c\u5c06I\/O\u64cd\u4f5c\u5f02\u6b65\u5316\u3002Reactor\u6a21\u5f0f\u7684\u6838\u5fc3\u601d\u60f3\u662f\u5c06\u4e8b\u4ef6\u76d1\u542c\u548c\u4e8b\u4ef6\u5904\u7406\u5206\u79bb\uff0c\u901a\u8fc7\u4e00\u4e2a\u6216\u591a\u4e2a\u7ebf\u7a0b\u76d1\u542c\u4e8b\u4ef6\uff0c\u5f53\u4e8b\u4ef6\u53d1\u751f\u65f6\uff0c\u5c06\u4e8b\u4ef6\u5206\u53d1\u7ed9\u5bf9\u5e94\u7684\u5904\u7406\u5668\u5904\u7406\u3002Go\u8bed\u8a00\u7684gRPC\u5b9e\u73b0\u57fa\u4e8eepoll\/kqueue\u7b49\u4e8b\u4ef6\u9a71\u52a8\u673a\u5236\uff0c\u914d\u5408Goroutine\u8c03\u5ea6\uff0c\u5b9e\u73b0\u4e86\u9ad8\u6548\u7684\u4e8b\u4ef6\u5904\u7406\u3002<\/p>\n
      \u96f6\u62f7\u8d1d\u6280\u672f<\/strong><\/p>\n
      Go\u7684Protocol Buffers\u5e93\u76f4\u63a5\u64cd\u4f5c\u5b57\u8282\u5207\u7247\uff0c\u907f\u514d\u4e86\u4e0d\u5fc5\u8981\u7684\u5185\u5b58\u5206\u914d\u548c\u62f7\u8d1d\u3002\u5728\u5e8f\u5217\u5316\u548c\u53cd\u5e8f\u5217\u5316\u8fc7\u7a0b\u4e2d\uff0c\u5e93\u4f1a\u76f4\u63a5\u5c06\u6570\u636e\u5199\u5165\u9884\u5206\u914d\u7684\u7f13\u51b2\u533a\uff0c\u6216\u8005\u4ece\u7f13\u51b2\u533a\u4e2d\u76f4\u63a5\u8bfb\u53d6\u6570\u636e\uff0c\u51cf\u5c11\u4e86\u5185\u5b58\u62f7\u8d1d\u6b21\u6570\uff0c\u63d0\u9ad8\u4e86\u6027\u80fd\u3002<\/p>\n
      Hertz-Burst\u7406\u8bba<\/strong><\/p>\n
      Hertz-Burst\u7406\u8bba\u662f\u6307\u7cfb\u7edf\u5728\u5904\u7406\u7a81\u53d1\u6d41\u91cf\u65f6\uff0c\u9700\u8981\u5728\u5ef6\u8fdf\u548c\u541e\u5410\u91cf\u4e4b\u95f4\u8fdb\u884c\u6743\u8861\u3002gRPC\u901a\u8fc7\u8fde\u63a5\u6c60\u548c\u9650\u6d41\u7b97\u6cd5\uff08\u5982\u4ee4\u724c\u6876\uff09\uff0c\u53ef\u4ee5\u5e73\u8861\u77ac\u65f6\u6d41\u91cf\u9ad8\u5cf0\u4e0e\u7cfb\u7edf\u541e\u5410\u91cf\uff0c\u907f\u514d\u7cfb\u7edf\u56e0\u7a81\u53d1\u6d41\u91cf\u800c\u5d29\u6e83\u3002<\/p>\n
      \u670d\u52a1\u7f51\u683c\u96c6\u6210<\/strong><\/p>\n
      gRPC\u53ef\u4ee5\u4e0e\u670d\u52a1\u7f51\u683c\uff08\u5982Istio\u3001Linkerd\uff09\u65e0\u7f1d\u96c6\u6210\uff0c\u5b9e\u73b0\u9ad8\u7ea7\u670d\u52a1\u6cbb\u7406\u529f\u80fd\uff0c\u5982\u6d41\u91cf\u7ba1\u7406\u3001\u5b89\u5168\u8ba4\u8bc1\u3001\u53ef\u89c2\u5bdf\u6027\u7b49\u3002\u670d\u52a1\u7f51\u683c\u901a\u8fc7\u900f\u660e\u4ee3\u7406\u7684\u65b9\u5f0f\uff0c\u5c06\u670d\u52a1\u6cbb\u7406\u903b\u8f91\u4ece\u5e94\u7528\u4ee3\u7801\u4e2d\u5206\u79bb\u51fa\u6765\uff0c\u964d\u4f4e\u4e86\u5f00\u53d1\u590d\u6742\u5ea6\u3002<\/p>\n
      \u4e09\u3001\u573a\u666f2\uff1a\u5b9e\u65f6\u6d88\u606f\u63a8\u9001\uff08WebSocket\uff09<\/h2>\n
      \u573a\u666f\u63cf\u8ff0<\/h3>\n
      \u5b9e\u65f6\u6d88\u606f\u63a8\u9001\u662f\u73b0\u4ee3Web\u5e94\u7528\u7684\u91cd\u8981\u529f\u80fd\u4e4b\u4e00\uff0c\u5e7f\u6cdb\u5e94\u7528\u4e8e\u793e\u4ea4\u5a92\u4f53\u3001\u5728\u7ebf\u804a\u5929\u3001\u5b9e\u65f6\u76d1\u63a7\u3001\u534f\u540c\u529e\u516c\u7b49\u573a\u666f\u3002\u4f8b\u5982\uff0c\u793e\u4ea4\u5a92\u4f53\u5e73\u53f0\u9700\u8981\u5b9e\u65f6\u63a8\u9001\u65b0\u6d88\u606f\u3001\u70b9\u8d5e\u901a\u77e5\uff1b\u5728\u7ebf\u6e38\u620f\u9700\u8981\u5b9e\u65f6\u540c\u6b65\u73a9\u5bb6\u72b6\u6001\uff1b\u91d1\u878d\u4ea4\u6613\u7cfb\u7edf\u9700\u8981\u5b9e\u65f6\u63a8\u9001\u884c\u60c5\u6570\u636e\u3002\u8fd9\u4e9b\u573a\u666f\u5bf9\u6d88\u606f\u63a8\u9001\u7684\u5b9e\u65f6\u6027\u3001\u53ef\u9760\u6027\u548c\u5e76\u53d1\u80fd\u529b\u8981\u6c42\u6781\u9ad8\u3002<\/p>\n
      \u95ee\u9898\u77db\u76fe\u70b9<\/h3>\n
      \u4f20\u7edf\u7684HTTP\u8f6e\u8be2\u65b9\u6848\u5728\u5b9e\u65f6\u6d88\u606f\u63a8\u9001\u573a\u666f\u4e0b\u9762\u4e34\u4ee5\u4e0b\u51e0\u5927\u77db\u76fe\uff1a<\/p>\n
        \n
      • \u957f\u8f6e\u8be2\u8d44\u6e90\u6d6a\u8d39\uff1a<\/strong> \u5ba2\u6237\u7aef\u901a\u8fc7\u5b9a\u671f\u53d1\u8d77HTTP\u8bf7\u6c42\u6765\u83b7\u53d6\u65b0\u6d88\u606f\uff0c\u5373\u4f7f\u6ca1\u6709\u65b0\u6d88\u606f\uff0c\u670d\u52a1\u5668\u4e5f\u9700\u8981\u5904\u7406\u8fd9\u4e9b\u8bf7\u6c42\u3002\u5728\u5927\u89c4\u6a21\u7528\u6237\u573a\u666f\u4e0b\uff0c\u8fd9\u4f1a\u5bfc\u81f4\u670d\u52a1\u5668\u8d44\u6e90\u5229\u7528\u7387\u4e0d\u8db35%\uff0c\u9020\u6210\u4e25\u91cd\u7684\u8d44\u6e90\u6d6a\u8d39\u3002<\/li>\n
      • \u6d88\u606f\u5ef6\u8fdf\u4e0d\u53ef\u63a7\uff1a<\/strong> HTTP\u8bf7\u6c42-\u54cd\u5e94\u6a21\u578b\u65e0\u6cd5\u4fdd\u8bc1\u5b9e\u65f6\u6027\uff0c\u6d88\u606f\u5ef6\u8fdf\u53d6\u51b3\u4e8e\u8f6e\u8be2\u95f4\u9694\u3002\u5982\u679c\u8f6e\u8be2\u95f4\u9694\u8fc7\u77ed\uff0c\u4f1a\u589e\u52a0\u670d\u52a1\u5668\u8d1f\u62c5\uff1b\u5982\u679c\u8f6e\u8be2\u95f4\u9694\u8fc7\u957f\uff0c\u4f1a\u5bfc\u81f4\u6d88\u606f\u5ef6\u8fdf\u589e\u52a0\uff0c\u6781\u7aef\u60c5\u51b5\u4e0b\u5ef6\u8fdf\u53ef\u8fbe\u79d2\u7ea7\u3002<\/li>\n
      • \u8fde\u63a5\u6570\u9650\u5236\uff1a<\/strong> Nginx\u7b49\u53cd\u5411\u4ee3\u7406\u9ed8\u8ba4\u9650\u5236\u5355\u4e2aIP\u7684\u5e76\u53d1\u8fde\u63a5\u6570\uff08\u59821024\uff09\uff0c\u5927\u89c4\u6a21\u7528\u6237\u573a\u666f\u4e0b\u9700\u8981\u9891\u7e41\u6269\u5bb9\uff0c\u589e\u52a0\u4e86\u8fd0\u7ef4\u6210\u672c\u3002<\/li>\n
      • \u534f\u8bae\u5f00\u9500\u5927\uff1a<\/strong> HTTP\u534f\u8bae\u5305\u542b\u5927\u91cf\u7684\u5934\u90e8\u4fe1\u606f\uff0c\u6bcf\u4e2a\u8bf7\u6c42\u548c\u54cd\u5e94\u90fd\u9700\u8981\u4f20\u8f93\u8fd9\u4e9b\u5934\u90e8\uff0c\u589e\u52a0\u4e86\u7f51\u7edc\u5e26\u5bbd\u5f00\u9500\u3002<\/li>\n
      • \u72b6\u6001\u7ba1\u7406\u590d\u6742\uff1a<\/strong> \u670d\u52a1\u5668\u9700\u8981\u7ef4\u62a4\u6bcf\u4e2a\u5ba2\u6237\u7aef\u7684\u8fde\u63a5\u72b6\u6001\u548c\u6d88\u606f\u961f\u5217\uff0c\u4f20\u7edf\u7684HTTP\u65e0\u72b6\u6001\u6a21\u578b\u96be\u4ee5\u5904\u7406\u3002
        –<\/li>\n<\/ul>\n
        Go\u89e3\u51b3\u65b9\u6848\u6838\u5fc3\u6280\u672f<\/h3>\n
        WebSocket\u957f\u8fde\u63a5 + Goroutine\u590d\u7528<\/strong><\/p>\n
        WebSocket\u662f\u4e00\u79cd\u5168\u53cc\u5de5\u901a\u4fe1\u534f\u8bae\uff0c\u5141\u8bb8\u670d\u52a1\u5668\u548c\u5ba2\u6237\u7aef\u4e4b\u95f4\u5efa\u7acb\u6301\u4e45\u8fde\u63a5\uff0c\u5b9e\u73b0\u53cc\u5411\u5b9e\u65f6\u901a\u4fe1\u3002Go\u8bed\u8a00\u63d0\u4f9b\u4e86net\/http\/websocket\u5305\uff0c\u539f\u751f\u652f\u6301WebSocket\u534f\u8bae\uff0c\u53ef\u4ee5\u8f7b\u677e\u5b9e\u73b0WebSocket\u670d\u52a1\u7aef\u548c\u5ba2\u6237\u7aef\u3002<\/p>\n
        \u5355\u534f\u7a0b\u5904\u7406\u591a\u8fde\u63a5<\/strong><\/p>\n
        Go\u8bed\u8a00\u7684select\u8bed\u53e5\u53ef\u4ee5\u540c\u65f6\u76d1\u542c\u591a\u4e2a\u901a\u9053\u548cI\/O\u64cd\u4f5c\uff0c\u8fd9\u4f7f\u5f97\u5355\u4e2aGoroutine\u53ef\u4ee5\u5904\u7406\u591a\u4e2aWebSocket\u8fde\u63a5\u7684\u8bfb\u5199\u4e8b\u4ef6\u3002\u901a\u8fc7\u8fd9\u79cd\u65b9\u5f0f\uff0c\u53ef\u4ee5\u907f\u514d\u4e3a\u6bcf\u4e2a\u8fde\u63a5\u521b\u5efa\u72ec\u7acb\u7684Goroutine\uff0c\u51cf\u5c11\u5185\u5b58\u5360\u7528\u548c\u8c03\u5ea6\u5f00\u9500\u3002<\/p>\n
        \u6279\u91cf\u6d88\u606f\u63a8\u9001<\/strong><\/p>\n
        \u4f7f\u7528sync.Map\u7ef4\u62a4\u5ba2\u6237\u7aef\u8fde\u63a5\u6c60\uff0c\u5c06\u76f8\u540c\u9891\u9053\u7684\u5ba2\u6237\u7aef\u5206\u7ec4\u7ba1\u7406\u3002\u5f53\u6709\u65b0\u6d88\u606f\u9700\u8981\u63a8\u9001\u65f6\uff0c\u53ef\u4ee5\u6279\u91cf\u83b7\u53d6\u8be5\u9891\u9053\u7684\u6240\u6709\u5ba2\u6237\u7aef\uff0c\u7136\u540e\u5e76\u53d1\u63a8\u9001\u6d88\u606f\uff0c\u51cf\u5c11\u7f51\u7edcI\/O\u6b21\u6570\u3002<\/p>\n
        \u5f02\u6b65\u5199\u5165\u7f13\u51b2<\/strong><\/p>\n
        \u5229\u7528bufio.Writer\u7684\u7f13\u51b2\u673a\u5236\uff0c\u5408\u5e76\u5c0f\u6570\u636e\u5305\uff0c\u964d\u4f4e\u7cfb\u7edf\u8c03\u7528\u9891\u7387\u3002\u540c\u65f6\uff0c\u4f7f\u7528\u975e\u963b\u585e\u5199\u5165\u65b9\u5f0f\uff0c\u907f\u514d\u56e0\u5355\u4e2a\u5ba2\u6237\u7aef\u8fde\u63a5\u7f13\u6162\u800c\u5f71\u54cd\u5176\u4ed6\u5ba2\u6237\u7aef\u3002<\/p>\n
        \u4ee3\u7801\u5b9e\u73b0<\/h3>\n
        \"\"
        WebSocket\u670d\u52a1\u7aef\u5b9e\u73b0<\/strong><\/p>\n
        \/\/ \u5ba2\u6237\u7aef\u7ba1\u7406\u5668\u8fd0\u884c\nfunc (manager *ClientManager) run() {\n    for {\n        select {\n        case client := <-manager.register:\n            \/\/ \u6ce8\u518c\u65b0\u5ba2\u6237\u7aef\n            manager.mu.Lock()\n            manager.clients[client] = true\n            manager.mu.Unlock()\n            log.Printf("Client connected: %s", client.userID)\n        case client := <-manager.unregister:\n            \/\/ \u6ce8\u9500\u5ba2\u6237\u7aef\n            if _, ok := manager.clients[client]; ok {\n                close(client.send)\n                manager.mu.Lock()\n                delete(manager.clients, client)\n                \/\/ \u4ece\u6240\u6709\u9891\u9053\u4e2d\u79fb\u9664\u5ba2\u6237\u7aef\n                client.mu.RLock()\n                for channel := range client.channels {\n                    if _, ok := manager.channels[channel]; ok {\n                        delete(manager.channels[channel], client)\n                        \/\/ \u5982\u679c\u9891\u9053\u4e3a\u7a7a\uff0c\u5220\u9664\u9891\u9053\n                        if len(manager.channels[channel]) == 0 {\n                            delete(manager.channels, channel)\n                        }\n                    }\n                }\n                client.mu.RUnlock()\n                manager.mu.Unlock()\n                log.Printf("Client disconnected: %s", client.userID)\n            }\n        case message := <-manager.broadcast:\n            \/\/ \u5e7f\u64ad\u6d88\u606f\u5230\u6307\u5b9a\u9891\u9053\n            manager.mu.RLock()\n            if clients, ok := manager.channels[message.Channel]; ok {\n                for client := range clients {\n                    select {\n                    case client.send <- message.Content:\n                    default:\n                        \/\/ \u5982\u679c\u5ba2\u6237\u7aef\u53d1\u9001\u7f13\u51b2\u533a\u6ee1\uff0c\u5173\u95ed\u8fde\u63a5\n                        close(client.send)\n                        delete(manager.clients, client)\n                        \/\/ \u4ece\u6240\u6709\u9891\u9053\u4e2d\u79fb\u9664\u5ba2\u6237\u7aef\n                        client.mu.RLock()\n                        for channel := range client.channels {\n                            if _, ok := manager.channels[channel]; ok {\n                                delete(manager.channels[channel], client)\n                                if len(manager.channels[channel]) == 0 {\n                                    delete(manager.channels, channel)\n                                }\n                            }\n                        }\n                        client.mu.RUnlock()\n                    }\n                }\n            }\n            manager.mu.RUnlock()\n        }\n    }\n}\n\/\/ \u5ba2\u6237\u7aef\u8bfb\u5199\u534f\u7a0b\nfunc (c *Client) readPump(manager *ClientManager) {\n    defer func() {\n        manager.unregister <- c\n        c.conn.Close()\n    }()\n    \/\/ \u8bbe\u7f6e\u8bfb\u53d6\u8d85\u65f6\n    c.conn.SetReadDeadline(time.Now().Add(60 * time.Second))\n    c.conn.SetPongHandler(func(string) error {\n        \/\/ \u91cd\u7f6e\u8bfb\u53d6\u8d85\u65f6\n        c.conn.SetReadDeadline(time.Now().Add(60 * time.Second))\n        return nil\n    })\n    for {\n        _, message, err := c.conn.ReadMessage()\n        if err != nil {\n            if websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway, websocket.CloseAbnormalClosure) {\n                log.Printf("error: %v", err)\n            }\n            break\n        }\n        \/\/ \u89e3\u6790\u6d88\u606f\n        var msg Message\n        if err := json.Unmarshal(message, &msg); err != nil {\n            log.Printf("error parsing message: %v", err)\n            continue\n        }\n        msg.UserID = c.userID\n        \/\/ \u5904\u7406\u4e0d\u540c\u7c7b\u578b\u7684\u6d88\u606f\n        switch msg.Type {\n        case "subscribe":\n            \/\/ \u8ba2\u9605\u9891\u9053\n            c.mu.Lock()\n            c.channels[msg.Channel] = true\n            c.mu.Unlock()\n            manager.mu.Lock()\n            if _, ok := manager.channels[msg.Channel]; !ok {\n                manager.channels[msg.Channel] = make(map[*Client]bool)\n            }\n            manager.channels[msg.Channel][c] = true\n            manager.mu.Unlock()\n            log.Printf("Client %s subscribed to channel %s", c.userID, msg.Channel)\n        case "unsubscribe":\n            \/\/ \u53d6\u6d88\u8ba2\u9605\n            c.mu.Lock()\n            delete(c.channels, msg.Channel)\n            c.mu.Unlock()\n            manager.mu.Lock()\n            if clients, ok := manager.channels[msg.Channel]; ok {\n                delete(clients, c)\n                \/\/ \u5982\u679c\u9891\u9053\u4e3a\u7a7a\uff0c\u5220\u9664\u9891\u9053\n                if len(clients) == 0 {\n                    delete(manager.channels, msg.Channel)\n                }\n            }\n            manager.mu.Unlock()\n            log.Printf("Client %s unsubscribed from channel %s", c.userID, msg.Channel)\n        case "message":\n            \/\/ \u5e7f\u64ad\u6d88\u606f\n            if msg.Channel != "" {\n                manager.broadcast <- &msg\n            }\n        }\n    }\n}\nfunc (c *Client) writePump() {\n    \/\/ \u8bbe\u7f6e\u5199\u5165\u7f13\u51b2\n    writer := bufio.NewWriter(c.conn.UnderlyingConn())\n    defer func() {\n        c.conn.Close()\n    }()\n    \/\/ \u5b9a\u65f6\u53d1\u9001ping\u6d88\u606f\n    ticker := time.NewTicker(30 * time.Second)\n    defer ticker.Stop()\n    for {\n        select {\n        case message, ok := <-c.send:\n            \/\/ \u8bbe\u7f6e\u5199\u5165\u8d85\u65f6\n            c.conn.SetWriteDeadline(time.Now().Add(10 * time.Second))\n            if !ok {\n                \/\/ \u53d1\u9001\u5173\u95ed\u6d88\u606f\n                c.conn.WriteMessage(websocket.CloseMessage, []byte{})\n                return\n            }\n            \/\/ \u83b7\u53d6\u5199\u5165\u5668\n            w, err := c.conn.NextWriter(websocket.TextMessage)\n            if err != nil {\n                return\n            }\n            \/\/ \u5199\u5165\u6d88\u606f\n            w.Write(message)\n            \/\/ \u6279\u91cf\u5199\u5165\u5f85\u53d1\u9001\u6d88\u606f\n            n := len(c.send)\n            for i := 0; i < n; i++ {\n                w.Write([]byte("\/n"))\n                w.Write(<-c.send)\n            }\n            \/\/ \u5237\u65b0\u7f13\u51b2\u533a\n            if err := w.Close(); err != nil {\n                return\n            }\n        case <-ticker.C:\n            \/\/ \u53d1\u9001ping\u6d88\u606f\n            c.conn.SetWriteDeadline(time.Now().Add(10 * time.Second))\n            if err := c.conn.WriteMessage(websocket.PingMessage, nil); err != nil {\n                return\n            }\n        }\n    }\n}<\/code><\/pre>\n
        WebSocket\u5ba2\u6237\u7aef\u5b9e\u73b0<\/strong><\/p>\n
        func main() {\n    \/\/ \u89e3\u6790\u547d\u4ee4\u884c\u53c2\u6570\n    userID := "client1"\n    if len(os.Args) > 1 {\n        userID = os.Args[1]\n    }\n    \/\/ \u6784\u5efaWebSocket URL\n    u := url.URL{\n        Scheme: "ws",\n        Host:   "localhost:8080",\n        Path:   "\/ws",\n    }\n    q := u.Query()\n    q.Add("user_id", userID)\n    u.RawQuery = q.Encode()\n    log.Printf("Connecting to %s", u.String())\n    \/\/ \u8fde\u63a5WebSocket\u670d\u52a1\u5668\n    conn, _, err := websocket.DefaultDialer.Dial(u.String(), nil)\n    if err != nil {\n        log.Fatal("dial:", err)\n    }\n    defer conn.Close()\n    \/\/ \u4e0a\u4e0b\u6587\u7528\u4e8e\u53d6\u6d88\u64cd\u4f5c\n    ctx, cancel := context.WithCancel(context.Background())\n    defer cancel()\n    \/\/ \u5904\u7406\u4e2d\u65ad\u4fe1\u53f7\n    interrupt := make(chan os.Signal, 1)\n    signal.Notify(interrupt, os.Interrupt)\n    \/\/ \u542f\u52a8\u8bfb\u53d6\u534f\u7a0b\n    go func() {\n        defer cancel()\n        for {\n            _, message, err := conn.ReadMessage()\n            if err != nil {\n                log.Println("read:", err)\n                return\n            }\n            log.Printf("Received: %s", message)\n        }\n    }()\n    \/\/ \u53d1\u9001\u8ba2\u9605\u6d88\u606f\n    subscribeMsg := Message{\n        Type:    "subscribe",\n        Channel: "test",\n    }\n    subscribeData, err := json.Marshal(subscribeMsg)\n    if err != nil {\n        log.Fatal("marshal subscribe message:", err)\n    }\n    if err := conn.WriteMessage(websocket.TextMessage, subscribeData); err != nil {\n        log.Fatal("write subscribe message:", err)\n    }\n    \/\/ \u5b9a\u65f6\u53d1\u9001\u6d88\u606f\n    ticker := time.NewTicker(5 * time.Second)\n    defer ticker.Stop()\n    for {\n        select {\n        case <-ticker.C:\n            \/\/ \u53d1\u9001\u6d4b\u8bd5\u6d88\u606f\n            testMsg := Message{\n                Type:    "message",\n                Channel: "test",\n                Content: json.RawMessage(`{"text":"Test message from ` + userID + `","time":"` + time.Now().Format(time.RFC3339) + `"}`),\n            }\n            testData, err := json.Marshal(testMsg)\n            if err != nil {\n                log.Println("marshal test message:", err)\n                continue\n            }\n            if err := conn.WriteMessage(websocket.TextMessage, testData); err != nil {\n                log.Println("write test message:", err)\n                return\n            }\n        case <-interrupt:\n            log.Println("interrupt")\n            \/\/ \u53d1\u9001\u5173\u95ed\u6d88\u606f\n            if err := conn.WriteMessage(websocket.CloseMessage, websocket.FormatCloseMessage(websocket.CloseNormalClosure, "")); err != nil {\n                log.Println("write close:", err)\n                return\n            }\n            select {\n            case <-ctx.Done():\n            case <-time.After(time.Second):\n            }\n            return\n        case <-ctx.Done():\n            return\n        }\n    }\n}<\/code><\/pre>\n
        \u7406\u8bba\u77e5\u8bc6\u652f\u6491<\/h3>\n
        \u4e8b\u4ef6\u9a71\u52a8\u6a21\u578b<\/strong><\/p>\n
        Go\u7684WebSocket\u5b9e\u73b0\u57fa\u4e8e\u4e8b\u4ef6\u9a71\u52a8\u6a21\u578b\uff0c\u901a\u8fc7epoll\/kqueue\u7b49\u7cfb\u7edf\u8c03\u7528\u76d1\u542cI\/O\u4e8b\u4ef6\u3002\u5f53\u6709\u65b0\u8fde\u63a5\u5efa\u7acb\u3001\u6570\u636e\u5230\u8fbe\u6216\u8fde\u63a5\u5173\u95ed\u65f6\uff0c\u7cfb\u7edf\u4f1a\u89e6\u53d1\u76f8\u5e94\u7684\u4e8b\u4ef6\uff0c\u7136\u540e\u7531Go\u8fd0\u884c\u65f6\u5c06\u4e8b\u4ef6\u5206\u53d1\u7ed9\u5bf9\u5e94\u7684\u5904\u7406\u51fd\u6570\u3002\u8fd9\u79cd\u6a21\u578b\u907f\u514d\u4e86\u4f20\u7edf\u7684\u963b\u585eI\/O\u6a21\u578b\u4e2d\u7ebf\u7a0b\u963b\u585e\u7684\u95ee\u9898\uff0c\u63d0\u9ad8\u4e86\u7cfb\u7edf\u7684\u5e76\u53d1\u5904\u7406\u80fd\u529b\u3002<\/p>\n
        \u53d1\u5e03-\u8ba2\u9605\u6a21\u5f0f<\/strong><\/p>\n
        \u53d1\u5e03-\u8ba2\u9605\u6a21\u5f0f\u662f\u4e00\u79cd\u6d88\u606f\u4f20\u9012\u6a21\u5f0f\uff0c\u5176\u4e2d\u53d1\u5e03\u8005\u5c06\u6d88\u606f\u53d1\u9001\u5230\u7279\u5b9a\u7684\u9891\u9053\uff0c\u8ba2\u9605\u8005\u901a\u8fc7\u8ba2\u9605\u9891\u9053\u6765\u63a5\u6536\u6d88\u606f\u3002\u5728WebSocket\u573a\u666f\u4e2d\uff0c\u53d1\u5e03-\u8ba2\u9605\u6a21\u5f0f\u53ef\u4ee5\u5b9e\u73b0\u6d88\u606f\u7684\u9ad8\u6548\u5206\u53d1\uff0c\u652f\u6301\u591a\u5bf9\u591a\u901a\u4fe1\u3002Go\u8bed\u8a00\u7684Channel\u548csync.Map\u4e3a\u5b9e\u73b0\u53d1\u5e03-\u8ba2\u9605\u6a21\u5f0f\u63d0\u4f9b\u4e86\u9ad8\u6548\u7684\u5de5\u5177\u3002<\/p>\n
        TCP\u7c98\u5305\u5904\u7406<\/strong><\/p>\n
        \u5728TCP\u901a\u4fe1\u4e2d\uff0c\u7531\u4e8eTCP\u662f\u6d41\u5f0f\u534f\u8bae\uff0c\u6d88\u606f\u53ef\u80fd\u4f1a\u88ab\u62c6\u5206\u4e3a\u591a\u4e2a\u6570\u636e\u5305\uff0c\u6216\u8005\u591a\u4e2a\u6d88\u606f\u88ab\u5408\u5e76\u4e3a\u4e00\u4e2a\u6570\u636e\u5305\uff0c\u8fd9\u5c31\u662fTCP\u7c98\u5305\u95ee\u9898\u3002Go\u7684WebSocket\u5e93\u5185\u90e8\u5df2\u7ecf\u5904\u7406\u4e86TCP\u7c98\u5305\u95ee\u9898\uff0c\u901a\u8fc7\u6d88\u606f\u5934\u4e2d\u7684\u957f\u5ea6\u5b57\u6bb5\u6765\u786e\u5b9a\u6d88\u606f\u8fb9\u754c\uff0c\u786e\u4fdd\u6d88\u606f\u7684\u5b8c\u6574\u6027\u3002<\/p>\n
        \u80cc\u538b\u673a\u5236<\/strong><\/p>\n
        \u80cc\u538b\u673a\u5236\u662f\u6307\u5f53\u7cfb\u7edf\u5904\u7406\u80fd\u529b\u4e0d\u8db3\u65f6\uff0c\u4e0a\u6e38\u7cfb\u7edf\u4f1a\u611f\u77e5\u5230\u4e0b\u6e38\u7cfb\u7edf\u7684\u538b\u529b\uff0c\u5e76\u8c03\u6574\u53d1\u9001\u901f\u7387\uff0c\u907f\u514d\u7cfb\u7edf\u5d29\u6e83\u3002\u5728WebSocket\u5b9e\u73b0\u4e2d\uff0c\u6211\u4eec\u4f7f\u7528\u5e26\u7f13\u51b2\u7684Channel\u548c\u975e\u963b\u585e\u5199\u5165\u65b9\u5f0f\u6765\u5b9e\u73b0\u80cc\u538b\u673a\u5236\u3002\u5f53\u5ba2\u6237\u7aef\u7684\u53d1\u9001\u7f13\u51b2\u533a\u6ee1\u65f6\uff0c\u670d\u52a1\u5668\u4f1a\u505c\u6b62\u5411\u8be5\u5ba2\u6237\u7aef\u53d1\u9001\u6d88\u606f\uff0c\u907f\u514d\u5185\u5b58\u6ea2\u51fa\u3002<\/p>\n
        \u56db\u3001\u573a\u666f3\uff1aAPI\u7f51\u5173\u9650\u6d41\u4e0e\u7194\u65ad<\/h2>\n
        \u573a\u666f\u63cf\u8ff0<\/h3>\n
        API\u7f51\u5173\u662f\u5fae\u670d\u52a1\u67b6\u6784\u4e2d\u7684\u91cd\u8981\u7ec4\u4ef6\uff0c\u8d1f\u8d23\u8bf7\u6c42\u8def\u7531\u3001\u8d1f\u8f7d\u5747\u8861\u3001\u8ba4\u8bc1\u6388\u6743\u3001\u9650\u6d41\u7194\u65ad\u7b49\u529f\u80fd\u3002\u5728\u9ad8\u5e76\u53d1\u573a\u666f\u4e0b\uff0cAPI\u7f51\u5173\u9700\u8981\u5904\u7406\u5927\u91cf\u7684\u8bf7\u6c42\uff0c\u540c\u65f6\u4fdd\u62a4\u540e\u7aef\u670d\u52a1\u4e0d\u88ab\u8fc7\u8f7d\u3002<\/strong> \u4f8b\u5982\uff0c\u7535\u5546\u7cfb\u7edf\u7684API\u7f51\u5173\u5728\u5927\u4fc3\u671f\u95f4\u53ef\u80fd\u9700\u8981\u5904\u7406\u6bcf\u79d2\u6570\u5341\u4e07\u7684\u8bf7\u6c42\uff0c\u6b64\u65f6\u9650\u6d41\u548c\u7194\u65ad\u673a\u5236\u5c31\u663e\u5f97\u5c24\u4e3a\u91cd\u8981\u3002<\/p>\n
        \u95ee\u9898\u77db\u76fe\u70b9<\/h3>\n
        \u4f20\u7edf\u7684API\u7f51\u5173\u9650\u6d41\u65b9\u6848\u9762\u4e34\u4ee5\u4e0b\u51e0\u5927\u6311\u6218\uff1a<\/p>\n
          \n
        • \u5168\u5c40\u9501\u7ade\u4e89\uff1a<\/strong> \u57fa\u4e8eRedis\u7684\u5206\u5e03\u5f0f\u9501\uff08\u5982SETNX\uff09\u5728\u9ad8\u5e76\u53d1\u4e0b\u4f1a\u4ea7\u751f\u5927\u91cf\u7ade\u4e89\uff0cQPS\u4e0a\u9650\u4ec5\u6570\u5343\u3002\u8fd9\u662f\u56e0\u4e3a\u6240\u6709\u8bf7\u6c42\u90fd\u9700\u8981\u8bbf\u95ee\u540c\u4e00\u4e2aRedis\u952e\uff0c\u5bfc\u81f4Redis\u6210\u4e3a\u6027\u80fd\u74f6\u9888\u3002<\/li>\n
        • \u51b7\u542f\u52a8\u95ee\u9898\uff1a<\/strong> \u5728\u7cfb\u7edf\u542f\u52a8\u521d\u671f\uff0c\u7531\u4e8e\u7edf\u8ba1\u6570\u636e\u4e0d\u8db3\uff0c\u9650\u6d41\u7b97\u6cd5\u53ef\u80fd\u4f1a\u8bef\u5224\uff0c\u5bfc\u81f4\u6b63\u5e38\u8bf7\u6c42\u88ab\u62d2\u7edd\u3002\u4f8b\u5982\uff0c\u4ee4\u724c\u6876\u7b97\u6cd5\u5728\u521d\u59cb\u72b6\u6001\u4e0b\u6ca1\u6709\u4ee4\u724c\uff0c\u9700\u8981\u4e00\u6bb5\u65f6\u95f4\u624d\u80fd\u79ef\u7d2f\u8db3\u591f\u7684\u4ee4\u724c\u3002<\/li>\n
        • \u56fa\u5b9a\u9608\u503c\u7f3a\u4e4f\u7075\u6d3b\u6027\uff1a<\/strong> \u4f20\u7edf\u7684\u9650\u6d41\u65b9\u6848\u901a\u5e38\u4f7f\u7528\u56fa\u5b9a\u7684\u9608\u503c\uff0c\u65e0\u6cd5\u6839\u636e\u7cfb\u7edf\u8d1f\u8f7d\u52a8\u6001\u8c03\u6574\u3002\u5728\u7cfb\u7edf\u8d1f\u8f7d\u4f4e\u65f6\uff0c\u56fa\u5b9a\u9608\u503c\u4f1a\u6d6a\u8d39\u8d44\u6e90\uff1b\u5728\u7cfb\u7edf\u8d1f\u8f7d\u9ad8\u65f6\uff0c\u56fa\u5b9a\u9608\u503c\u53ef\u80fd\u65e0\u6cd5\u6709\u6548\u4fdd\u62a4\u7cfb\u7edf\u3002<\/li>\n
        • \u7194\u65ad\u673a\u5236\u4e0d\u5b8c\u5584\uff1a<\/strong> \u4f20\u7edf\u7684\u7194\u65ad\u673a\u5236\u901a\u5e38\u57fa\u4e8e\u9519\u8bef\u7387\u6216\u54cd\u5e94\u65f6\u95f4\uff0c\u4f46\u7f3a\u4e4f\u4e0a\u4e0b\u6587\u4fe1\u606f\uff0c\u53ef\u80fd\u4f1a\u5bfc\u81f4\u8bef\u5224\u3002\u4f8b\u5982\uff0c\u5f53\u67d0\u4e2a\u540e\u7aef\u670d\u52a1\u53ea\u662f\u6682\u65f6\u5ef6\u8fdf\u9ad8\u65f6\uff0c\u7194\u65ad\u673a\u5236\u53ef\u80fd\u4f1a\u9519\u8bef\u5730\u5c06\u5176\u7194\u65ad\uff0c\u5f71\u54cd\u7cfb\u7edf\u53ef\u7528\u6027\u3002<\/li>\n
        • \u5206\u5e03\u5f0f\u9650\u6d41\u4e00\u81f4\u6027\u95ee\u9898\uff1a<\/strong> \u5728\u5206\u5e03\u5f0f\u73af\u5883\u4e0b\uff0c\u591a\u4e2aAPI\u7f51\u5173\u5b9e\u4f8b\u4e4b\u95f4\u9700\u8981\u5171\u4eab\u9650\u6d41\u72b6\u6001\uff0c\u786e\u4fdd\u5168\u5c40\u9650\u6d41\u7684\u51c6\u786e\u6027\u3002\u4f20\u7edf\u7684\u57fa\u4e8eRedis\u7684\u65b9\u6848\u5b58\u5728\u4e00\u81f4\u6027\u95ee\u9898\uff0c\u53ef\u80fd\u5bfc\u81f4\u5b9e\u9645\u8bf7\u6c42\u6570\u8d85\u8fc7\u9650\u6d41\u9608\u503c\u3002
          –<\/li>\n<\/ul>\n
          Go\u89e3\u51b3\u65b9\u6848\u6838\u5fc3\u6280\u672f<\/h3>\n
          \u4ee4\u724c\u6876\u7b97\u6cd5 + \u672c\u5730\u7f13\u5b58<\/strong><\/p>\n
          \u4ee4\u724c\u6876\u7b97\u6cd5\u662f\u4e00\u79cd\u5e38\u7528\u7684\u9650\u6d41\u7b97\u6cd5\uff0c\u901a\u8fc7\u5b9a\u671f\u5411\u6876\u4e2d\u6dfb\u52a0\u4ee4\u724c\uff0c\u8bf7\u6c42\u9700\u8981\u83b7\u53d6\u4ee4\u724c\u624d\u80fd\u6267\u884c\u3002Go\u8bed\u8a00\u53ef\u4ee5\u9ad8\u6548\u5730\u5b9e\u73b0\u4ee4\u724c\u6876\u7b97\u6cd5\uff0c\u7ed3\u5408\u672c\u5730\u7f13\u5b58\u53ef\u4ee5\u51cf\u5c11\u5bf9Redis\u7b49\u5916\u90e8\u5b58\u50a8\u7684\u4f9d\u8d56\uff0c\u63d0\u9ad8\u6027\u80fd\u3002<\/p>\n
          \u6ed1\u52a8\u7a97\u53e3\u9650\u6d41<\/strong><\/p>\n
          \u6ed1\u52a8\u7a97\u53e3\u9650\u6d41\u662f\u4e00\u79cd\u66f4\u7cbe\u786e\u7684\u9650\u6d41\u7b97\u6cd5\uff0c\u901a\u8fc7\u7ef4\u62a4\u4e00\u4e2a\u6ed1\u52a8\u7684\u65f6\u95f4\u7a97\u53e3\uff0c\u7edf\u8ba1\u7a97\u53e3\u5185\u7684\u8bf7\u6c42\u6570\u3002\u5f53\u8bf7\u6c42\u6570\u8d85\u8fc7\u9608\u503c\u65f6\uff0c\u62d2\u7edd\u65b0\u7684\u8bf7\u6c42\u3002Go\u8bed\u8a00\u7684\u539f\u5b50\u64cd\u4f5c\u548c\u65f6\u95f4\u5305\u4e3a\u5b9e\u73b0\u6ed1\u52a8\u7a97\u53e3\u9650\u6d41\u63d0\u4f9b\u4e86\u9ad8\u6548\u7684\u5de5\u5177\u3002<\/p>\n
          \u7194\u65ad\u964d\u7ea7\u673a\u5236<\/strong><\/p>\n
          \u7ed3\u5408context.WithTimeout\u548c\u4fe1\u53f7\u91cf\uff08semaphore\uff09\uff0c\u53ef\u4ee5\u5b9e\u73b0\u5feb\u901f\u5931\u8d25\u548c\u7194\u65ad\u964d\u7ea7\u3002\u5f53\u540e\u7aef\u670d\u52a1\u54cd\u5e94\u65f6\u95f4\u8d85\u8fc7\u9608\u503c\u6216\u9519\u8bef\u7387\u8fc7\u9ad8\u65f6\uff0c\u81ea\u52a8\u7194\u65ad\u8be5\u670d\u52a1\uff0c\u907f\u514d\u7ea7\u8054\u5931\u8d25\u3002<\/p>\n
          \u5206\u5e03\u5f0f\u9650\u6d41\u534f\u540c<\/strong><\/p>\n
          \u4f7f\u7528Redis\u7b49\u5206\u5e03\u5f0f\u5b58\u50a8\u5b9e\u73b0\u591a\u4e2aAPI\u7f51\u5173\u5b9e\u4f8b\u4e4b\u95f4\u7684\u9650\u6d41\u72b6\u6001\u5171\u4eab\uff0c\u7ed3\u5408\u672c\u5730\u7f13\u5b58\u51cf\u5c11\u5bf9Redis\u7684\u8bbf\u95ee\u9891\u7387\uff0c\u63d0\u9ad8\u6027\u80fd\u3002<\/p>\n
          \u4ee3\u7801\u5b9e\u73b0<\/h3>\n
          \"\"<\/p>\n
          \u4ee4\u724c\u6876\u9650\u6d41\u5b9e\u73b0<\/strong><\/p>\n
          \/\/ NewTokenBucket \u521b\u5efa\u65b0\u7684\u4ee4\u724c\u6876\nfunc NewTokenBucket(capacity int64, rate float64) *TokenBucket {\n    tb := &TokenBucket{\n        capacity:   capacity,\n        rate:       rate,\n        tokens:     capacity, \/\/ \u521d\u59cb\u586b\u6ee1\u4ee4\u724c\n        lastRefill: time.Now(),\n        stopRefill: make(chan struct{}),\n    }\n    \/\/ \u542f\u52a8\u4ee4\u724c\u586b\u5145\u534f\u7a0b\n    tb.startRefill()\n    return tb\n}\n\/\/ startRefill \u542f\u52a8\u4ee4\u724c\u586b\u5145\u534f\u7a0b\nfunc (tb *TokenBucket) startRefill() {\n    \/\/ \u8ba1\u7b97\u586b\u5145\u95f4\u9694\n    interval := time.Duration(float64(time.Second) \/ tb.rate)\n    tb.refillTicker = time.NewTicker(interval)\n    go func() {\n        for {\n            select {\n            case <-tb.refillTicker.C:\n                tb.mu.Lock()\n                \/\/ \u586b\u5145\u4e00\u4e2a\u4ee4\u724c\n                if tb.tokens < tb.capacity {\n                    tb.tokens++\n                }\n                tb.mu.Unlock()\n            case <-tb.stopRefill:\n                tb.refillTicker.Stop()\n                return\n            }\n        }\n    }()\n}\n\/\/ Allow \u68c0\u67e5\u662f\u5426\u5141\u8bb8\u8bf7\u6c42\nfunc (tb *TokenBucket) Allow() bool {\n    tb.mu.Lock()\n    defer tb.mu.Unlock()\n    if tb.tokens > 0 {\n        tb.tokens--\n        return true\n    }\n    return false\n}\n\/\/ AllowN \u68c0\u67e5\u662f\u5426\u5141\u8bb8N\u4e2a\u8bf7\u6c42\nfunc (tb *TokenBucket) AllowN(n int64) bool {\n    tb.mu.Lock()\n    defer tb.mu.Unlock()\n    if tb.tokens >= n {\n        tb.tokens -= n\n        return true\n    }\n    return false\n}\n\/\/ Close \u5173\u95ed\u4ee4\u724c\u6876\uff0c\u505c\u6b62\u586b\u5145\u4ee4\u724c\nfunc (tb *TokenBucket) Close() {\n    close(tb.stopRefill)\n}<\/code><\/pre>\n
          \u6ed1\u52a8\u7a97\u53e3\u9650\u6d41\u5b9e\u73b0<\/strong><\/p>\n
          \/\/ NewSlidingWindow \u521b\u5efa\u65b0\u7684\u6ed1\u52a8\u7a97\u53e3\nfunc NewSlidingWindow(windowSize time.Duration, splitCount int, threshold int64) *SlidingWindow {\n    if splitCount <= 0 {\n        splitCount = 10 \/\/ \u9ed8\u8ba4\u5206\u5272\u4e3a10\u4e2a\u5b50\u7a97\u53e3\n    }\n    return &SlidingWindow{\n        windowSize:  windowSize,\n        splitCount:  splitCount,\n        threshold:   threshold,\n        segments:    make([]int64, splitCount),\n        currentIdx:  0,\n        lastUpdate:  time.Now(),\n        segmentSize: windowSize \/ time.Duration(splitCount),\n    }\n}\n\/\/ updateSegments \u66f4\u65b0\u5b50\u7a97\u53e3\u8ba1\u6570\nfunc (sw *SlidingWindow) updateSegments() {\n    now := time.Now()\n    duration := now.Sub(sw.lastUpdate)\n    \/\/ \u5982\u679c\u65f6\u95f4\u95f4\u9694\u5c0f\u4e8e\u5b50\u7a97\u53e3\u5927\u5c0f\uff0c\u4e0d\u9700\u8981\u66f4\u65b0\n    if duration < sw.segmentSize {\n        return\n    }\n    \/\/ \u8ba1\u7b97\u9700\u8981\u66f4\u65b0\u7684\u5b50\u7a97\u53e3\u6570\u91cf\n    segmentsToUpdate := int(duration \/ sw.segmentSize)\n    if segmentsToUpdate > sw.splitCount {\n        segmentsToUpdate = sw.splitCount\n    }\n    \/\/ \u91cd\u7f6e\u9700\u8981\u66f4\u65b0\u7684\u5b50\u7a97\u53e3\n    for i := 0; i < segmentsToUpdate; i++ {\n        sw.currentIdx = (sw.currentIdx + 1) % sw.splitCount\n        sw.segments[sw.currentIdx] = 0\n    }\n    \/\/ \u66f4\u65b0\u4e0a\u6b21\u66f4\u65b0\u65f6\u95f4\n    sw.lastUpdate = now\n}\n\/\/ Allow \u68c0\u67e5\u662f\u5426\u5141\u8bb8\u8bf7\u6c42\nfunc (sw *SlidingWindow) Allow() bool {\n    sw.mu.Lock()\n    defer sw.mu.Unlock()\n    \/\/ \u66f4\u65b0\u5b50\u7a97\u53e3\u8ba1\u6570\n    sw.updateSegments()\n    \/\/ \u8ba1\u7b97\u5f53\u524d\u7a97\u53e3\u5185\u7684\u8bf7\u6c42\u6570\n    total := int64(0)\n    for _, count := range sw.segments {\n        total += count\n    }\n    \/\/ \u68c0\u67e5\u662f\u5426\u8d85\u8fc7\u9608\u503c\n    if total >= sw.threshold {\n        return false\n    }\n    \/\/ \u589e\u52a0\u5f53\u524d\u5b50\u7a97\u53e3\u8ba1\u6570\n    sw.segments[sw.currentIdx]++\n    return true\n}\n\/\/ GetCurrentCount \u83b7\u53d6\u5f53\u524d\u7a97\u53e3\u5185\u7684\u8bf7\u6c42\u6570\nfunc (sw *SlidingWindow) GetCurrentCount() int64 {\n    sw.mu.RLock()\n    defer sw.mu.RUnlock()\n    \/\/ \u66f4\u65b0\u5b50\u7a97\u53e3\u8ba1\u6570\n    sw.updateSegments()\n    \/\/ \u8ba1\u7b97\u5f53\u524d\u7a97\u53e3\u5185\u7684\u8bf7\u6c42\u6570\n    total := int64(0)\n    for _, count := range sw.segments {\n        total += count\n    }\n    return total\n}<\/code><\/pre>\n
          \u7194\u65ad\u964d\u7ea7\u5b9e\u73b0<\/strong><\/p>\n
          \/\/ NewCircuitBreaker \u521b\u5efa\u65b0\u7684\u7194\u65ad\u5668\nfunc NewCircuitBreaker(failureThreshold, successThreshold int64, timeout time.Duration) *CircuitBreaker {\n    return &CircuitBreaker{\n        state:            StateClosed,\n        failureThreshold: failureThreshold,\n        successThreshold: successThreshold,\n        timeout:          timeout,\n        stateChanged:     make(chan State, 1),\n    }\n}\n\/\/ Execute \u6267\u884c\u51fd\u6570\uff0c\u5e26\u7194\u65ad\u4fdd\u62a4\nfunc (cb *CircuitBreaker) Execute(fn func() error) error {\n    \/\/ \u68c0\u67e5\u7194\u65ad\u72b6\u6001\n    if !cb.allowRequest() {\n        return errors.New("circuit breaker is open")\n    }\n    \/\/ \u6267\u884c\u51fd\u6570\n    err := fn()\n    \/\/ \u8bb0\u5f55\u6267\u884c\u7ed3\u679c\n    if err != nil {\n        cb.recordFailure()\n    } else {\n        cb.recordSuccess()\n    }\n    return err\n}\n\/\/ allowRequest \u68c0\u67e5\u662f\u5426\u5141\u8bb8\u8bf7\u6c42\nfunc (cb *CircuitBreaker) allowRequest() bool {\n    cb.mu.Lock()\n    defer cb.mu.Unlock()\n    now := time.Now()\n    switch cb.state {\n    case StateClosed:\n        \/\/ \u5173\u95ed\u72b6\u6001\uff0c\u5141\u8bb8\u8bf7\u6c42\n        return true\n    case StateOpen:\n        \/\/ \u6253\u5f00\u72b6\u6001\uff0c\u68c0\u67e5\u662f\u5426\u8d85\u65f6\n        if now.Sub(cb.lastFailure) >= cb.timeout {\n            \/\/ \u8d85\u65f6\uff0c\u5207\u6362\u5230\u534a\u5f00\u72b6\u6001\n            cb.setState(StateHalfOpen)\n            return true\n        }\n        \/\/ \u672a\u8d85\u65f6\uff0c\u62d2\u7edd\u8bf7\u6c42\n        return false\n    case StateHalfOpen:\n        \/\/ \u534a\u5f00\u72b6\u6001\uff0c\u5141\u8bb8\u8bf7\u6c42\n        return true\n    default:\n        return true\n    }\n}\n\/\/ recordFailure \u8bb0\u5f55\u5931\u8d25\nfunc (cb *CircuitBreaker) recordFailure() {\n    cb.mu.Lock()\n    defer cb.mu.Unlock()\n    switch cb.state {\n    case StateClosed:\n        \/\/ \u5173\u95ed\u72b6\u6001\uff0c\u589e\u52a0\u5931\u8d25\u8ba1\u6570\n        cb.failureCount++\n        cb.lastFailure = time.Now()\n        \/\/ \u68c0\u67e5\u662f\u5426\u8fbe\u5230\u5931\u8d25\u9608\u503c\n        if cb.failureCount >= cb.failureThreshold {\n            cb.setState(StateOpen)\n        }\n    case StateHalfOpen:\n        \/\/ \u534a\u5f00\u72b6\u6001\uff0c\u5931\u8d25\u540e\u5207\u6362\u5230\u6253\u5f00\u72b6\u6001\n        cb.setState(StateOpen)\n    case StateOpen:\n        \/\/ \u6253\u5f00\u72b6\u6001\uff0c\u66f4\u65b0\u4e0a\u6b21\u5931\u8d25\u65f6\u95f4\n        cb.lastFailure = time.Now()\n    }\n}\n\/\/ recordSuccess \u8bb0\u5f55\u6210\u529f\nfunc (cb *CircuitBreaker) recordSuccess() {\n    cb.mu.Lock()\n    defer cb.mu.Unlock()\n    switch cb.state {\n    case StateClosed:\n        \/\/ \u5173\u95ed\u72b6\u6001\uff0c\u91cd\u7f6e\u5931\u8d25\u8ba1\u6570\n        cb.failureCount = 0\n    case StateHalfOpen:\n        \/\/ \u534a\u5f00\u72b6\u6001\uff0c\u589e\u52a0\u6210\u529f\u8ba1\u6570\n        cb.successCount++\n        \/\/ \u68c0\u67e5\u662f\u5426\u8fbe\u5230\u6210\u529f\u9608\u503c\n        if cb.successCount >= cb.successThreshold {\n            cb.setState(StateClosed)\n        }\n    case StateOpen:\n        \/\/ \u6253\u5f00\u72b6\u6001\uff0c\u4e0d\u5904\u7406\n    }\n}\n\/\/ setState \u8bbe\u7f6e\u72b6\u6001\nfunc (cb *CircuitBreaker) setState(state State) {\n    if cb.state != state {\n        cb.state = state\n\n\n        \/\/ \u91cd\u7f6e\u8ba1\u6570\n        switch state {\n        case StateClosed:\n            cb.failureCount = 0\n            cb.successCount = 0\n        case StateOpen:\n            cb.failureCount = 0\n            cb.successCount = 0\n        case StateHalfOpen:\n            cb.successCount = 0\n        }\n        \/\/ \u901a\u77e5\u72b6\u6001\u53d8\u5316\n        select {\n        case cb.stateChanged <- state:\n        default:\n            \/\/ \u901a\u9053\u5df2\u6ee1\uff0c\u4e22\u5f03\n        }\n    }\n}\n\/\/ GetState \u83b7\u53d6\u5f53\u524d\u72b6\u6001\nfunc (cb *CircuitBreaker) GetState() State {\n    cb.mu.Lock()\n    defer cb.mu.Unlock()\n    return cb.state\n}\n\/\/ StateChanged \u8fd4\u56de\u72b6\u6001\u53d8\u5316\u901a\u77e5\u901a\u9053\nfunc (cb *CircuitBreaker) StateChanged() <-chan State {\n    return cb.stateChanged\n}<\/code><\/pre>\n
          API\u7f51\u5173\u96c6\u6210\u793a\u4f8b<\/strong><\/p>\n
          \/\/ NewAPIGateway \u521b\u5efa\u65b0\u7684API\u7f51\u5173\nfunc NewAPIGateway() *APIGateway {\n    return &APIGateway{\n        routes:         make(map[string]http.Handler),\n        globalLimiter:  NewTokenBucket(1000, 1000), \/\/ \u5168\u5c40\u9650\u6d41\uff1a1000 QPS\n    }\n}\n\/\/ RegisterRoute \u6ce8\u518c\u8def\u7531\nfunc (gw *APIGateway) RegisterRoute(path string, handler http.Handler, rateLimit int64) {\n    gw.routes[path] = handler\n    \/\/ \u4e3a\u8def\u7531\u521b\u5efa\u9650\u6d41\u6876\n    gw.limiters.Store(path, NewTokenBucket(rateLimit, float64(rateLimit)))\n    \/\/ \u4e3a\u8def\u7531\u521b\u5efa\u7194\u65ad\u5668\n    gw.circuitBreakers.Store(path, NewCircuitBreaker(5, 3, 30*time.Second))\n}\n\/\/ ServeHTTP \u5b9e\u73b0http.Handler\u63a5\u53e3\nfunc (gw *APIGateway) ServeHTTP(w http.ResponseWriter, r *http.Request) {\n    \/\/ \u68c0\u67e5\u5168\u5c40\u9650\u6d41\n    if !gw.globalLimiter.Allow() {\n        http.Error(w, "Too Many Requests (Global)", http.StatusTooManyRequests)\n        return\n    }\n    \/\/ \u83b7\u53d6\u8def\u7531\u5904\u7406\u5668\n    handler, ok := gw.routes[r.URL.Path]\n    if !ok {\n        http.Error(w, "Not Found", http.StatusNotFound)\n        return\n    }\n    \/\/ \u83b7\u53d6\u8def\u7531\u9650\u6d41\u6876\n    limiter, ok := gw.limiters.Load(r.URL.Path)\n    if !ok {\n        http.Error(w, "Internal Server Error", http.StatusInternalServerError)\n        return\n    }\n    \/\/ \u68c0\u67e5\u8def\u7531\u9650\u6d41\n    if !limiter.(*TokenBucket).Allow() {\n        http.Error(w, "Too Many Requests (Route)", http.StatusTooManyRequests)\n        return\n    }\n    \/\/ \u83b7\u53d6\u8def\u7531\u7194\u65ad\u5668\n    cb, ok := gw.circuitBreakers.Load(r.URL.Path)\n    if !ok {\n        http.Error(w, "Internal Server Error", http.StatusInternalServerError)\n        return\n    }\n    \/\/ \u4f7f\u7528\u7194\u65ad\u5668\u6267\u884c\u8bf7\u6c42\n    err := cb.(*CircuitBreaker).Execute(func() error {\n        \/\/ \u6267\u884c\u5b9e\u9645\u7684\u8bf7\u6c42\u5904\u7406\n        handler.ServeHTTP(w, r)\n        return nil\n    })\n    if err != nil {\n        http.Error(w, fmt.Sprintf("Service Unavailable: %v", err), http.StatusServiceUnavailable)\n        return\n    }\n}<\/code><\/pre>\n
          \u7406\u8bba\u77e5\u8bc6\u652f\u6491<\/h3>\n
          \u6f0f\u6876\u7b97\u6cd5 vs \u4ee4\u724c\u6876\u7b97\u6cd5<\/strong><\/p>\n
          \u6f0f\u6876\u7b97\u6cd5\u548c\u4ee4\u724c\u6876\u7b97\u6cd5\u662f\u4e24\u79cd\u5e38\u7528\u7684\u9650\u6d41\u7b97\u6cd5\uff0c\u5b83\u4eec\u7684\u533a\u522b\u5728\u4e8e\uff1a<\/p>\n
            \n
          • \u6f0f\u6876\u7b97\u6cd5\uff1a<\/strong> \u8bf7\u6c42\u4ee5\u56fa\u5b9a\u901f\u7387\u5904\u7406\uff0c\u65e0\u8bba\u8bf7\u6c42\u901f\u7387\u5982\u4f55\u53d8\u5316\uff0c\u5904\u7406\u901f\u7387\u59cb\u7ec8\u4fdd\u6301\u4e0d\u53d8\u3002\u8fd9\u79cd\u7b97\u6cd5\u9002\u5408\u4e8e\u5bf9\u5904\u7406\u901f\u7387\u6709\u4e25\u683c\u8981\u6c42\u7684\u573a\u666f\uff0c\u4f46\u65e0\u6cd5\u5904\u7406\u7a81\u53d1\u6d41\u91cf\u3002<\/li>\n
          • \u4ee4\u724c\u6876\u7b97\u6cd5\uff1a<\/strong> \u4ee4\u724c\u4ee5\u56fa\u5b9a\u901f\u7387\u751f\u6210\uff0c\u8bf7\u6c42\u9700\u8981\u83b7\u53d6\u4ee4\u724c\u624d\u80fd\u6267\u884c\u3002\u8fd9\u79cd\u7b97\u6cd5\u5141\u8bb8\u4e00\u5b9a\u7a0b\u5ea6\u7684\u7a81\u53d1\u6d41\u91cf\uff0c\u9002\u5408\u4e8e\u5927\u591a\u6570\u573a\u666f\u3002<\/li>\n<\/ul>\n
            Go\u8bed\u8a00\u901a\u8fc7\u539f\u5b50\u64cd\u4f5c\u548c\u534f\u7a0b\u8c03\u5ea6\uff0c\u53ef\u4ee5\u9ad8\u6548\u5730\u5b9e\u73b0\u4ee4\u724c\u6876\u7b97\u6cd5\uff0c\u652f\u6301\u767e\u4e07\u7ea7QPS\u7684\u9650\u6d41\u3002<\/p>\n
            \u6ed1\u52a8\u7a97\u53e3\u7edf\u8ba1<\/strong><\/p>\n
            \u6ed1\u52a8\u7a97\u53e3\u7edf\u8ba1\u662f\u4e00\u79cd\u66f4\u7cbe\u786e\u7684\u9650\u6d41\u7b97\u6cd5\uff0c\u901a\u8fc7\u7ef4\u62a4\u4e00\u4e2a\u6ed1\u52a8\u7684\u65f6\u95f4\u7a97\u53e3\uff0c\u7edf\u8ba1\u7a97\u53e3\u5185\u7684\u8bf7\u6c42\u6570\u3002\u4e0e\u56fa\u5b9a\u65f6\u95f4\u7a97\u53e3\u76f8\u6bd4\uff0c\u6ed1\u52a8\u7a97\u53e3\u53ef\u4ee5\u907f\u514d\u56fa\u5b9a\u65f6\u95f4\u7a97\u53e3\u7684\u4e34\u754c\u95ee\u9898\uff08\u5982\u6700\u540e\u4e00\u79d2\u96c6\u4e2d\u8bf7\u6c42\uff09\uff0c\u63d0\u9ad8\u9650\u6d41\u7cbe\u5ea6\u3002<\/p>\n
            \u5728\u5b9e\u73b0\u6ed1\u52a8\u7a97\u53e3\u65f6\uff0c\u6211\u4eec\u5c06\u65f6\u95f4\u7a97\u53e3\u5206\u5272\u4e3a\u591a\u4e2a\u5b50\u7a97\u53e3\uff0c\u6bcf\u4e2a\u5b50\u7a97\u53e3\u7ef4\u62a4\u4e00\u4e2a\u8ba1\u6570\u3002\u5f53\u65f6\u95f4\u6ed1\u52a8\u65f6\uff0c\u65e7\u7684\u5b50\u7a97\u53e3\u8ba1\u6570\u4f1a\u88ab\u91cd\u7f6e\uff0c\u65b0\u7684\u5b50\u7a97\u53e3\u8ba1\u6570\u4f1a\u88ab\u66f4\u65b0\u3002\u8fd9\u79cd\u5b9e\u73b0\u65b9\u5f0f\u53ef\u4ee5\u5728\u4fdd\u8bc1\u7cbe\u5ea6\u7684\u540c\u65f6\uff0c\u964d\u4f4e\u8ba1\u7b97\u590d\u6742\u5ea6\u3002<\/p>\n
            Hystrix\u7194\u65ad\u673a\u5236<\/strong><\/p>\n
            Hystrix\u662fNetflix\u5f00\u6e90\u7684\u7194\u65ad\u6846\u67b6\uff0c\u7528\u4e8e\u9632\u6b62\u5206\u5e03\u5f0f\u7cfb\u7edf\u4e2d\u7684\u7ea7\u8054\u5931\u8d25\u3002Hystrix\u7684\u6838\u5fc3\u601d\u60f3\u662f\uff1a\u5f53\u67d0\u4e2a\u670d\u52a1\u51fa\u73b0\u6545\u969c\u65f6\uff0c\u5feb\u901f\u5931\u8d25\uff0c\u907f\u514d\u5c06\u6545\u969c\u4f20\u64ad\u5230\u5176\u4ed6\u670d\u52a1\u3002<\/p>\n
            Go\u8bed\u8a00\u7684context\u5305\u548csemaphore\u5305\u4e3a\u5b9e\u73b0\u7194\u65ad\u673a\u5236\u63d0\u4f9b\u4e86\u9ad8\u6548\u7684\u5de5\u5177\u3002\u901a\u8fc7context.WithTimeout\u53ef\u4ee5\u8bbe\u7f6e\u8bf7\u6c42\u8d85\u65f6\u65f6\u95f4\uff0c\u5f53\u8bf7\u6c42\u8d85\u65f6\u6216\u5931\u8d25\u6b21\u6570\u8fbe\u5230\u9608\u503c\u65f6\uff0c\u81ea\u52a8\u89e6\u53d1\u7194\u65ad\u3002<\/p>\n
            \u5206\u5e03\u5f0f\u9650\u6d41\u4e00\u81f4\u6027<\/strong><\/p>\n
            \u5728\u5206\u5e03\u5f0f\u73af\u5883\u4e0b\uff0c\u591a\u4e2aAPI\u7f51\u5173\u5b9e\u4f8b\u4e4b\u95f4\u9700\u8981\u5171\u4eab\u9650\u6d41\u72b6\u6001\uff0c\u786e\u4fdd\u5168\u5c40\u9650\u6d41\u7684\u51c6\u786e\u6027\u3002\u5e38\u7528\u7684\u5206\u5e03\u5f0f\u9650\u6d41\u65b9\u6848\u5305\u62ec\uff1a<\/p>\n
              \n
            • \u57fa\u4e8eRedis\u7684\u5206\u5e03\u5f0f\u9650\u6d41\uff1a<\/strong> \u4f7f\u7528Redis\u7684\u539f\u5b50\u64cd\u4f5c\uff08\u5982INCR\u3001EXPIRE\uff09\u5b9e\u73b0\u5206\u5e03\u5f0f\u9650\u6d41<\/li>\n
            • \u57fa\u4e8eEtcd\u7684\u5206\u5e03\u5f0f\u9650\u6d41\uff1a<\/strong> \u4f7f\u7528Etcd\u7684\u5206\u5e03\u5f0f\u9501\u548c\u952e\u503c\u5b58\u50a8\u5b9e\u73b0\u5206\u5e03\u5f0f\u9650\u6d41<\/li>\n
            • \u57fa\u4e8eSentinel\u7684\u5206\u5e03\u5f0f\u9650\u6d41\uff1a<\/strong> \u4f7f\u7528Sentinel\u7684\u96c6\u7fa4\u9650\u6d41\u529f\u80fd\u5b9e\u73b0\u5206\u5e03\u5f0f\u9650\u6d41<\/li>\n<\/ul>\n
              \u5728\u5b9e\u73b0\u5206\u5e03\u5f0f\u9650\u65f6\uff0c\u9700\u8981\u6743\u8861\u4e00\u81f4\u6027\u548c\u6027\u80fd\u3002\u5f3a\u4e00\u81f4\u6027\u65b9\u6848\uff08\u5982\u57fa\u4e8eRedis\u7684\u5206\u5e03\u5f0f\u9501\uff09\u6027\u80fd\u8f83\u4f4e\uff0c\u800c\u6700\u7ec8\u4e00\u81f4\u6027\u65b9\u6848\uff08\u5982\u57fa\u4e8eRedis\u7684\u6ed1\u52a8\u7a97\u53e3\uff09\u6027\u80fd\u8f83\u9ad8\uff0c\u4f46\u53ef\u80fd\u5b58\u5728\u4e00\u5b9a\u7684\u8bef\u5dee\u3002<\/p>\n
              \u4e94\u3001\u573a\u666f4\uff1a\u5206\u5e03\u5f0f\u4efb\u52a1\u961f\u5217\uff08Redis Stream\uff09<\/h2>\n
              \u573a\u666f\u63cf\u8ff0<\/h3>\n
              \u5206\u5e03\u5f0f\u4efb\u52a1\u961f\u5217\u662f\u73b0\u4ee3\u7cfb\u7edf\u4e2d\u7684\u91cd\u8981\u7ec4\u4ef6\uff0c\u7528\u4e8e\u5904\u7406\u5f02\u6b65\u4efb\u52a1\u3001\u6279\u91cf\u5904\u7406\u548c\u540e\u53f0\u4f5c\u4e1a\u3002<\/strong> \u4f8b\u5982\uff0c\u7535\u5546\u7cfb\u7edf\u7684\u8ba2\u5355\u5904\u7406\u3001\u7269\u6d41\u8ddf\u8e2a\u3001\u6570\u636e\u5206\u6790\u7b49\u90fd\u53ef\u4ee5\u901a\u8fc7\u5206\u5e03\u5f0f\u4efb\u52a1\u961f\u5217\u6765\u5b9e\u73b0\u3002\u5728\u9ad8\u5e76\u53d1\u573a\u666f\u4e0b\uff0c\u5206\u5e03\u5f0f\u4efb\u52a1\u961f\u5217\u9700\u8981\u5904\u7406\u5927\u91cf\u7684\u4efb\u52a1\uff0c\u540c\u65f6\u4fdd\u8bc1\u4efb\u52a1\u7684\u53ef\u9760\u6027\u548c\u987a\u5e8f\u6027\u3002<\/p>\n
              \u95ee\u9898\u77db\u76fe\u70b9<\/h3>\n
              \u4f20\u7edf\u7684\u5206\u5e03\u5f0f\u4efb\u52a1\u961f\u5217\uff08\u5982RabbitMQ\u3001Kafka\uff09\u5728\u9ad8\u5e76\u53d1\u573a\u666f\u4e0b\u9762\u4e34\u4ee5\u4e0b\u51e0\u5927\u75db\u70b9\uff1a<\/p>\n
                \n
              • \u6d88\u606f\u53ef\u9760\u6027\u4e0d\u8db3\uff1a<\/strong> \u7f51\u7edc\u5206\u533a\u6216\u6d88\u8d39\u8005\u5d29\u6e83\u65f6\uff0c\u6d88\u606f\u53ef\u80fd\u4e22\u5931\uff08AT LEAST ONCE\u8bed\u4e49\u96be\u4ee5\u4fdd\u8bc1\uff09\u3002\u4f8b\u5982\uff0cRabbitMQ\u5728\u9ed8\u8ba4\u914d\u7f6e\u4e0b\uff0c\u5982\u679c\u6d88\u8d39\u8005\u5728\u5904\u7406\u6d88\u606f\u65f6\u5d29\u6e83\uff0c\u6d88\u606f\u4f1a\u88ab\u91cd\u65b0\u6295\u9012\uff0c\u4f46\u53ef\u80fd\u5bfc\u81f4\u6d88\u606f\u91cd\u590d\u5904\u7406\u3002<\/li>\n
              • \u6269\u5c55\u6027\u53d7\u9650\uff1a<\/strong> \u5206\u533a\u6570\u56fa\u5b9a\uff0c\u65e0\u6cd5\u52a8\u6001\u6269\u5bb9\uff0c\u9ad8\u5cf0\u671f\u541e\u5410\u91cf\u74f6\u9888\u660e\u663e\u3002\u4f8b\u5982\uff0cKafka\u7684\u5206\u533a\u6570\u5728\u521b\u5efa\u4e3b\u9898\u65f6\u56fa\u5b9a\uff0c\u65e0\u6cd5\u52a8\u6001\u589e\u52a0\uff0c\u9650\u5236\u4e86\u7cfb\u7edf\u7684\u6269\u5c55\u6027\u3002<\/li>\n
              • \u8fd0\u7ef4\u590d\u6742\u5ea6\u9ad8\uff1a<\/strong> \u9700\u8981\u90e8\u7f72\u548c\u7ef4\u62a4\u591a\u4e2a\u7ec4\u4ef6\uff08\u5982ZooKeeper\u3001Broker\u3001Consumer\uff09\uff0c\u589e\u52a0\u4e86\u8fd0\u7ef4\u6210\u672c\u3002\u4f8b\u5982\uff0cRabbitMQ\u9700\u8981\u90e8\u7f72\u591a\u4e2aBroker\u8282\u70b9\u548cCluster\uff0cKafka\u9700\u8981\u90e8\u7f72ZooKeeper\u96c6\u7fa4\u548cBroker\u96c6\u7fa4\u3002<\/li>\n
              • \u5ef6\u8fdf\u4e0d\u53ef\u63a7\uff1a<\/strong> \u5728\u9ad8\u8d1f\u8f7d\u573a\u666f\u4e0b\uff0c\u6d88\u606f\u5ef6\u8fdf\u53ef\u80fd\u4f1a\u663e\u8457\u589e\u52a0\u3002\u4f8b\u5982\uff0cKafka\u5728\u9ad8\u5cf0\u671f\u53ef\u80fd\u4f1a\u51fa\u73b0\u6d88\u606f\u5806\u79ef\uff0c\u5bfc\u81f4\u5ef6\u8fdf\u8fbe\u5230\u5206\u949f\u7ea7\u3002<\/li>\n
              • \u987a\u5e8f\u6027\u4fdd\u8bc1\u56f0\u96be\uff1a<\/strong> \u5728\u5206\u5e03\u5f0f\u73af\u5883\u4e0b\uff0c\u4fdd\u8bc1\u6d88\u606f\u7684\u987a\u5e8f\u6027\u662f\u4e00\u4e2a\u590d\u6742\u7684\u95ee\u9898\u3002\u4f8b\u5982\uff0cRabbitMQ\u7684\u961f\u5217\u53ef\u4ee5\u4fdd\u8bc1\u6d88\u606f\u7684\u987a\u5e8f\u6027\uff0c\u4f46\u5728\u591a\u4e2a\u6d88\u8d39\u8005\u7684\u60c5\u51b5\u4e0b\uff0c\u987a\u5e8f\u6027\u96be\u4ee5\u4fdd\u8bc1\u3002
                –<\/li>\n<\/ul>\n
                Go\u89e3\u51b3\u65b9\u6848\u6838\u5fc3\u6280\u672f<\/h3>\n
                Redis Stream + Consumer Group<\/strong><\/p>\n
                Redis Stream\u662fRedis 5.0\u5f15\u5165\u7684\u65b0\u6570\u636e\u7c7b\u578b\uff0c\u4e13\u4e3a\u6d88\u606f\u961f\u5217\u8bbe\u8ba1\uff0c\u652f\u6301\u6301\u4e45\u5316\u3001\u6d88\u8d39\u8005\u7ec4\u3001\u6d88\u606f\u786e\u8ba4\u7b49\u529f\u80fd\u3002Go\u8bed\u8a00\u901a\u8fc7github.com\/go-redis\/redis\/v8\u5305\u53ef\u4ee5\u8f7b\u677e\u5b9e\u73b0Redis Stream\u7684\u751f\u4ea7\u8005\u548c\u6d88\u8d39\u8005\u3002<\/p>\n
                \u6301\u4e45\u5316\u5b58\u50a8<\/strong><\/p>\n
                Redis Stream\u5c06\u6240\u6709\u6d88\u606f\u6301\u4e45\u5316\u5230\u78c1\u76d8\uff0c\u5373\u4f7fRedis\u91cd\u542f\uff0c\u6d88\u606f\u4e5f\u4e0d\u4f1a\u4e22\u5931\u3002\u8fd9\u786e\u4fdd\u4e86\u6d88\u606f\u7684\u53ef\u9760\u6027\uff0c\u652f\u6301AT LEAST ONCE\u8bed\u4e49\u3002<\/p>\n
                \u6d88\u8d39\u8005\u7ec4\u673a\u5236<\/strong><\/p>\n
                \u6d88\u8d39\u8005\u7ec4\u662fRedis Stream\u7684\u6838\u5fc3\u7279\u6027\uff0c\u5b83\u5141\u8bb8\u591a\u4e2a\u6d88\u8d39\u8005\u7ec4\u6210\u4e00\u4e2a\u7ec4\uff0c\u5171\u540c\u6d88\u8d39\u4e00\u4e2aStream\u7684\u6d88\u606f\u3002\u6d88\u8d39\u8005\u7ec4\u5185\u7684\u6d88\u606f\u5206\u914d\u91c7\u7528\u8f6e\u8be2\u65b9\u5f0f\uff0c\u6bcf\u4e2a\u6d88\u606f\u53ea\u4f1a\u88ab\u7ec4\u5185\u7684\u4e00\u4e2a\u6d88\u8d39\u8005\u6d88\u8d39\u3002\u540c\u65f6\uff0c\u6d88\u8d39\u8005\u7ec4\u652f\u6301\u6d88\u606f\u786e\u8ba4\u673a\u5236\uff0c\u53ea\u6709\u5f53\u6d88\u8d39\u8005\u786e\u8ba4\u6d88\u606f\u5904\u7406\u5b8c\u6210\u540e\uff0c\u6d88\u606f\u624d\u4f1a\u4ece\u7ec4\u5185\u79fb\u9664\u3002<\/p>\n
                \u6d88\u606fID\u4e0e\u987a\u5e8f\u6027<\/strong><\/p>\n
                \u6bcf\u4e2a\u6d88\u606f\u90fd\u6709\u4e00\u4e2a\u552f\u4e00\u7684ID\uff0c\u683c\u5f0f\u4e3a\u65f6\u95f4\u6233-\u5e8f\u5217\u53f7\u3002\u6d88\u606fID\u662f\u5355\u8c03\u9012\u589e\u7684\uff0c\u786e\u4fdd\u4e86\u6d88\u606f\u7684\u987a\u5e8f\u6027\u3002\u6d88\u8d39\u8005\u53ef\u4ee5\u901a\u8fc7\u6d88\u606fID\u6765\u5b9a\u4f4d\u548c\u6d88\u8d39\u6d88\u606f\uff0c\u652f\u6301\u4ece\u4efb\u610f\u4f4d\u7f6e\u5f00\u59cb\u6d88\u8d39\u3002<\/p>\n
                \u4ee3\u7801\u5b9e\u73b0<\/h3>\n
                \"\"<\/p>\n
                Redis Stream\u751f\u4ea7\u8005\u5b9e\u73b0<\/strong><\/p>\n
                \/\/ NewRedisProducer \u521b\u5efa\u65b0\u7684Redis Stream\u751f\u4ea7\u8005\nfunc NewRedisProducer(client *redis.Client, stream string) *RedisProducer {\n    return &RedisProducer{\n        client: client,\n        stream: stream,\n    }\n}\n\/\/ Produce \u751f\u4ea7\u4efb\u52a1\nfunc (p *RedisProducer) Produce(ctx context.Context, task *Task) (string, error) {\n    \/\/ \u5e8f\u5217\u5316\u4efb\u52a1\n    payload, err := json.Marshal(task)\n    if err != nil {\n        return "", err\n    }\n    \/\/ \u53d1\u5e03\u4efb\u52a1\u5230Redis Stream\n    msgID, err := p.client.XAdd(ctx, &redis.XAddArgs{\n        Stream: p.stream,\n        Values: map[string]interface{}{\n            "task": string(payload),\n        },\n        MaxLen: 10000, \/\/ \u4fdd\u7559\u6700\u65b0\u768410000\u6761\u6d88\u606f\n        Approx: true,  \/\/ \u8fd1\u4f3c\u622a\u65ad\uff0c\u63d0\u9ad8\u6027\u80fd\n    }).Result()\n    if err != nil {\n        return "", err\n    }\n    return msgID, nil\n}<\/code><\/pre>\n
                Redis Stream\u6d88\u8d39\u8005\u5b9e\u73b0<\/strong><\/p>\n
                \/\/ Start \u542f\u52a8\u6d88\u8d39\u8005\nfunc (c *RedisConsumer) Start(ctx context.Context, wg *sync.WaitGroup) error {\n    defer wg.Done()\n    \/\/ \u521b\u5efa\u6d88\u8d39\u8005\u7ec4\uff08\u5982\u679c\u4e0d\u5b58\u5728\uff09\n    _, err := c.client.XGroupCreateMkStream(ctx, c.stream, c.group, "$").Result()\n    if err != nil && err != redis.Nil {\n        \/\/ \u5982\u679c\u9519\u8bef\u4e0d\u662f"\u6d88\u8d39\u8005\u7ec4\u5df2\u5b58\u5728"\uff0c\u5219\u8fd4\u56de\u9519\u8bef\n        return err\n    }\n    log.Printf("Consumer %s started, group: %s, stream: %s", c.name, c.group, c.stream)\n    \/\/ \u6301\u7eed\u6d88\u8d39\u6d88\u606f\n    for {\n        select {\n        case <-ctx.Done():\n            \/\/ \u4e0a\u4e0b\u6587\u53d6\u6d88\uff0c\u505c\u6b62\u6d88\u8d39\n            log.Printf("Consumer %s stopped", c.name)\n            return nil\n        default:\n            \/\/ \u6d88\u8d39\u6d88\u606f\n            err := c.consume(ctx)\n            if err != nil {\n                log.Printf("Error consuming messages: %v", err)\n                \/\/ \u77ed\u6682\u4f11\u7720\u540e\u91cd\u8bd5\n                time.Sleep(1 * time.Second)\n            }\n        }\n    }\n}\n\/\/ consume \u6d88\u8d39\u6d88\u606f\nfunc (c *RedisConsumer) consume(ctx context.Context) error {\n    \/\/ \u4eceRedis Stream\u8bfb\u53d6\u6d88\u606f\n    msgs, err := c.client.XReadGroup(ctx, &redis.XReadGroupArgs{\n        Group:    c.group,\n        Consumer: c.name,\n        Streams:  []string{c.stream, " > "}, \/\/ " > " \u8868\u793a\u4ece\u6700\u65b0\u6d88\u606f\u5f00\u59cb\u6d88\u8d39\n        Count:    int64(c.batchSize),        \/\/ \u6279\u91cf\u8bfb\u53d6\u6d88\u606f\n        Block:    c.blockTimeout,            \/\/ \u963b\u585e\u65f6\u95f4\n    }).Result()\n    if err != nil {\n        return err\n    }\n    \/\/ \u5904\u7406\u6bcf\u6761\u6d88\u606f\n    for _, msgStream := range msgs {\n        for _, msg := range msgStream.Messages {\n            \/\/ \u89e3\u6790\u4efb\u52a1\n            var task Task\n            taskData, ok := msg.Values["task"].(string)\n            if !ok {\n                log.Printf("Invalid task data: %v", msg.Values["task"])\n                \/\/ \u786e\u8ba4\u6d88\u606f\uff0c\u907f\u514d\u6d88\u606f\u5806\u79ef\n                c.client.XAck(ctx, c.stream, c.group, msg.ID)\n                continue\n            }\n            if err := json.Unmarshal([]byte(taskData), &task); err != nil {\n                log.Printf("Failed to unmarshal task: %v", err)\n                \/\/ \u786e\u8ba4\u6d88\u606f\uff0c\u907f\u514d\u6d88\u606f\u5806\u79ef\n                c.client.XAck(ctx, c.stream, c.group, msg.ID)\n                continue\n            }\n            \/\/ \u5904\u7406\u4efb\u52a1\n            log.Printf("Consumer %s processing task: %s, message ID: %s", c.name, task.ID, msg.ID)\n            if err := c.processor(ctx, &task); err != nil {\n                log.Printf("Failed to process task %s: %v", task.ID, err)\n                \/\/ \u4e0d\u786e\u8ba4\u6d88\u606f\uff0c\u8ba9\u5176\u4ed6\u6d88\u8d39\u8005\u91cd\u8bd5\n                continue\n            }\n            \/\/ \u786e\u8ba4\u6d88\u606f\u5904\u7406\u5b8c\u6210\n            if err := c.client.XAck(ctx, c.stream, c.group, msg.ID).Err(); err != nil {\n                log.Printf("Failed to acknowledge task %s: %v", task.ID, err)\n                continue\n            }\n            log.Printf("Consumer %s processed task: %s, message ID: %s", c.name, task.ID, msg.ID)\n        }\n    }\n    return nil\n}\n\/\/ \u793a\u4f8b\u4efb\u52a1\u5904\u7406\u5668\nfunc taskProcessor(ctx context.Context, task *Task) error {\n    \/\/ \u6a21\u62df\u4efb\u52a1\u5904\u7406\n    time.Sleep(100 * time.Millisecond)\n    log.Printf("Processed task: %s, type: %s, payload: %s", task.ID, task.Type, task.Payload)\n    return nil\n}<\/code><\/pre>\n
                \u7406\u8bba\u77e5\u8bc6\u652f\u6491<\/h3>\n
                \u53d1\u5e03-\u8ba2\u9605\u6a21\u5f0f<\/strong><\/p>\n
                \u53d1\u5e03-\u8ba2\u9605\u6a21\u5f0f\u662f\u4e00\u79cd\u6d88\u606f\u4f20\u9012\u6a21\u5f0f\uff0c\u5176\u4e2d\u53d1\u5e03\u8005\u5c06\u6d88\u606f\u53d1\u9001\u5230\u7279\u5b9a\u7684\u4e3b\u9898\uff0c\u8ba2\u9605\u8005\u901a\u8fc7\u8ba2\u9605\u4e3b\u9898\u6765\u63a5\u6536\u6d88\u606f\u3002Redis Stream\u5b9e\u73b0\u4e86\u53d1\u5e03-\u8ba2\u9605\u6a21\u5f0f\uff0c\u540c\u65f6\u652f\u6301\u6301\u4e45\u5316\u548c\u6d88\u8d39\u8005\u7ec4\u529f\u80fd\u3002<\/p>\n
                \u6d88\u8d39\u7ec4\u673a\u5236<\/strong><\/p>\n
                \u6d88\u8d39\u8005\u7ec4\u673a\u5236\u662fRedis Stream\u7684\u6838\u5fc3\u7279\u6027\uff0c\u5b83\u5141\u8bb8\u591a\u4e2a\u6d88\u8d39\u8005\u7ec4\u6210\u4e00\u4e2a\u7ec4\uff0c\u5171\u540c\u6d88\u8d39\u4e00\u4e2aStream\u7684\u6d88\u606f\u3002\u6d88\u8d39\u8005\u7ec4\u5185\u7684\u6d88\u606f\u5206\u914d\u91c7\u7528\u8f6e\u8be2\u65b9\u5f0f\uff0c\u6bcf\u4e2a\u6d88\u606f\u53ea\u4f1a\u88ab\u7ec4\u5185\u7684\u4e00\u4e2a\u6d88\u8d39\u8005\u6d88\u8d39\u3002\u8fd9\u79cd\u673a\u5236\u53ef\u4ee5\u5b9e\u73b0\u8d1f\u8f7d\u5747\u8861\u548c\u9ad8\u53ef\u7528\u6027\u3002<\/p>\n
                CAP\u7406\u8bba\u53d6\u820d<\/strong><\/p>\n
                CAP\u7406\u8bba\u6307\u51fa\uff0c\u5728\u5206\u5e03\u5f0f\u7cfb\u7edf\u4e2d\uff0c\u4e00\u81f4\u6027\uff08Consistency\uff09\u3001\u53ef\u7528\u6027\uff08Availability\uff09\u548c\u5206\u533a\u5bb9\u9519\u6027\uff08Partition tolerance\uff09\u4e09\u8005\u4e0d\u53ef\u517c\u5f97\u3002<\/strong> Redis Stream\u5728\u8bbe\u8ba1\u4e0a\u727a\u7272\u4e86\u90e8\u5206\u5206\u533a\u5bb9\u9519\u6027\uff08P\uff09\uff0c\u6362\u53d6\u4e86\u5f3a\u4e00\u81f4\u6027\uff08C\uff09\u548c\u53ef\u7528\u6027\uff08A\uff09\u3002\u5f53\u53d1\u751f\u7f51\u7edc\u5206\u533a\u65f6\uff0cRedis Stream\u53ef\u80fd\u4f1a\u51fa\u73b0\u6682\u65f6\u7684\u4e0d\u53ef\u7528\uff0c\u4f46\u4e00\u65e6\u5206\u533a\u6062\u590d\uff0c\u7cfb\u7edf\u4f1a\u81ea\u52a8\u6062\u590d\u4e00\u81f4\u6027\u3002<\/p>\n
                \u5e42\u7b49\u6027\u8bbe\u8ba1<\/strong><\/p>\n
                \u5728\u5206\u5e03\u5f0f\u7cfb\u7edf\u4e2d\uff0c\u6d88\u606f\u53ef\u80fd\u4f1a\u88ab\u91cd\u590d\u6295\u9012\uff0c\u56e0\u6b64\u4efb\u52a1\u5904\u7406\u5668\u9700\u8981\u652f\u6301\u5e42\u7b49\u6027\u3002\u5e42\u7b49\u6027\u662f\u6307\u591a\u6b21\u6267\u884c\u540c\u4e00\u4e2a\u64cd\u4f5c\uff0c\u7ed3\u679c\u4e0e\u6267\u884c\u4e00\u6b21\u76f8\u540c\u3002\u5e38\u7528\u7684\u5e42\u7b49\u6027\u8bbe\u8ba1\u65b9\u6848\u5305\u62ec\uff1a<\/p>\n
                  \n
                • \u4f7f\u7528\u552f\u4e00ID\uff1a<\/strong> \u4e3a\u6bcf\u4e2a\u4efb\u52a1\u5206\u914d\u4e00\u4e2a\u552f\u4e00ID\uff0c\u5904\u7406\u5668\u901a\u8fc7\u68c0\u67e5ID\u662f\u5426\u5df2\u5904\u7406\u6765\u907f\u514d\u91cd\u590d\u5904\u7406<\/li>\n
                • \u72b6\u6001\u673a\u8bbe\u8ba1\uff1a<\/strong> \u5c06\u4efb\u52a1\u5904\u7406\u8bbe\u8ba1\u4e3a\u72b6\u6001\u673a\uff0c\u53ea\u6709\u5728\u7279\u5b9a\u72b6\u6001\u4e0b\u624d\u80fd\u6267\u884c\u64cd\u4f5c<\/li>\n
                • \u5206\u5e03\u5f0f\u9501\uff1a<\/strong> \u4f7f\u7528\u5206\u5e03\u5f0f\u9501\u786e\u4fdd\u540c\u4e00\u4efb\u52a1\u540c\u4e00\u65f6\u95f4\u53ea\u80fd\u88ab\u4e00\u4e2a\u5904\u7406\u5668\u5904\u7406
                  –<\/li>\n<\/ul>\n
                  \u516d\u3001\u573a\u666f5\uff1a\u5206\u5e03\u5f0f\u9501\uff08Redis RedLock\uff09<\/h2>\n
                  \u573a\u666f\u63cf\u8ff0<\/h3>\n
                  \u5206\u5e03\u5f0f\u9501\u662f\u5206\u5e03\u5f0f\u7cfb\u7edf\u4e2d\u7684\u91cd\u8981\u7ec4\u4ef6\uff0c\u7528\u4e8e\u89e3\u51b3\u591a\u4e2a\u8fdb\u7a0b\u6216\u670d\u52a1\u4e4b\u95f4\u7684\u8d44\u6e90\u7ade\u4e89\u95ee\u9898\u3002\u4f8b\u5982\uff0c\u5728\u7535\u5546\u7cfb\u7edf\u4e2d\uff0c\u591a\u4e2a\u670d\u52a1\u5b9e\u4f8b\u9700\u8981\u540c\u65f6\u8bbf\u95ee\u540c\u4e00\u4e2a\u5546\u54c1\u5e93\u5b58\uff0c\u6b64\u65f6\u5c31\u9700\u8981\u4f7f\u7528\u5206\u5e03\u5f0f\u9501\u6765\u786e\u4fdd\u5e93\u5b58\u64cd\u4f5c\u7684\u539f\u5b50\u6027\u3002\u5728\u9ad8\u5e76\u53d1\u573a\u666f\u4e0b\uff0c\u5206\u5e03\u5f0f\u9501\u9700\u8981\u5177\u5907\u9ad8\u6027\u80fd\u3001\u9ad8\u53ef\u7528\u6027\u548c\u5b89\u5168\u6027\u3002<\/strong><\/p>\n
                  \u95ee\u9898\u77db\u76fe\u70b9<\/h3>\n
                  \u4f20\u7edf\u7684\u5206\u5e03\u5f0f\u9501\u65b9\u6848\uff08\u5982\u57fa\u4e8eRedis\u7684SETNX\uff09\u5728\u9ad8\u5e76\u53d1\u573a\u666f\u4e0b\u9762\u4e34\u4ee5\u4e0b\u51e0\u5927\u98ce\u9669\uff1a<\/p>\n
                    \n
                  • \u65f6\u949f\u56de\u62e8\u95ee\u9898\uff1a<\/strong> \u670d\u52a1\u5668\u65f6\u95f4\u8df3\u8dc3\u5bfc\u81f4\u9501\u8fc7\u671f\uff0c\u5f15\u53d1\u5e76\u53d1\u51b2\u7a81\u3002\u4f8b\u5982\uff0c\u5f53\u4e00\u4e2a\u5ba2\u6237\u7aef\u83b7\u53d6\u9501\u540e\uff0c\u670d\u52a1\u5668\u65f6\u949f\u53d1\u751f\u56de\u62e8\uff0c\u5bfc\u81f4\u9501\u63d0\u524d\u8fc7\u671f\uff0c\u6b64\u65f6\u5176\u4ed6\u5ba2\u6237\u7aef\u53ef\u4ee5\u83b7\u53d6\u5230\u540c\u4e00\u4e2a\u9501\uff0c\u5f15\u53d1\u5e76\u53d1\u95ee\u9898\u3002<\/li>\n
                  • \u8111\u88c2\u73b0\u8c61\uff1a<\/strong> \u96c6\u7fa4\u6a21\u5f0f\u4e0b\uff0c\u90e8\u5206\u8282\u70b9\u8ba4\u4e3a\u9501\u5df2\u91ca\u653e\uff0c\u5b9e\u9645\u4ecd\u6709\u6301\u6709\u8005\u3002\u4f8b\u5982\uff0c\u5728Redis\u4e3b\u4ece\u67b6\u6784\u4e2d\uff0c\u5f53\u4e3b\u8282\u70b9\u5b95\u673a\u65f6\uff0c\u4ece\u8282\u70b9\u5347\u7ea7\u4e3a\u4e3b\u8282\u70b9\uff0c\u4f46\u4e3b\u8282\u70b9\u4e0a\u7684\u9501\u4fe1\u606f\u53ef\u80fd\u8fd8\u672a\u540c\u6b65\u5230\u4ece\u8282\u70b9\uff0c\u6b64\u65f6\u5176\u4ed6\u5ba2\u6237\u7aef\u53ef\u4ee5\u83b7\u53d6\u5230\u540c\u4e00\u4e2a\u9501\u3002<\/li>\n
                  • \u6027\u80fd\u74f6\u9888\uff1a<\/strong> \u5355\u5b9e\u4f8bRedis QPS\u4e0a\u9650\u7ea65\u4e07\uff0c\u5927\u89c4\u6a21\u96c6\u7fa4\u573a\u666f\u4e0b\u9501\u7ade\u4e89\u52a0\u5267\u3002\u5f53\u591a\u4e2a\u5ba2\u6237\u7aef\u540c\u65f6\u8bf7\u6c42\u540c\u4e00\u4e2a\u9501\u65f6\uff0c\u4f1a\u5bfc\u81f4Redis\u6210\u4e3a\u6027\u80fd\u74f6\u9888\u3002<\/li>\n
                  • \u6b7b\u9501\u98ce\u9669\uff1a<\/strong> \u5f53\u5ba2\u6237\u7aef\u83b7\u53d6\u9501\u540e\u5d29\u6e83\uff0c\u9501\u53ef\u80fd\u6c38\u8fdc\u4e0d\u4f1a\u91ca\u653e\u3002\u867d\u7136\u53ef\u4ee5\u901a\u8fc7\u8bbe\u7f6e\u8fc7\u671f\u65f6\u95f4\u6765\u907f\u514d\uff0c\u4f46\u5982\u679c\u4efb\u52a1\u6267\u884c\u65f6\u95f4\u8d85\u8fc7\u9501\u7684\u8fc7\u671f\u65f6\u95f4\uff0c\u4ecd\u7136\u53ef\u80fd\u5bfc\u81f4\u5e76\u53d1\u51b2\u7a81\u3002<\/li>\n
                  • \u9501\u7c92\u5ea6\u95ee\u9898\uff1a<\/strong> \u4f20\u7edf\u5206\u5e03\u5f0f\u9501\u901a\u5e38\u662f\u7c97\u7c92\u5ea6\u7684\uff0c\u65e0\u6cd5\u5b9e\u73b0\u7ec6\u7c92\u5ea6\u7684\u8d44\u6e90\u63a7\u5236\u3002\u4f8b\u5982\uff0c\u5f53\u591a\u4e2a\u5ba2\u6237\u7aef\u9700\u8981\u8bbf\u95ee\u540c\u4e00\u8d44\u6e90\u7684\u4e0d\u540c\u90e8\u5206\u65f6\uff0c\u4f20\u7edf\u5206\u5e03\u5f0f\u9501\u4f1a\u5bfc\u81f4\u8d44\u6e90\u7ade\u4e89\u52a0\u5267\uff0c\u964d\u4f4e\u7cfb\u7edf\u541e\u5410\u91cf\u3002
                    –<\/li>\n<\/ul>\n
                    Go\u89e3\u51b3\u65b9\u6848\u6838\u5fc3\u6280\u672f<\/h3>\n
                    Redis RedLock\u7b97\u6cd5<\/strong><\/p>\n
                    RedLock\u662fRedis\u5b98\u65b9\u63a8\u8350\u7684\u5206\u5e03\u5f0f\u9501\u7b97\u6cd5\uff0c\u901a\u8fc7\u5728\u591a\u4e2a\u72ec\u7acb\u7684Redis\u8282\u70b9\u4e0a\u83b7\u53d6\u9501\uff0c\u786e\u4fdd\u5728\u5927\u591a\u6570\u8282\u70b9\u6210\u529f\u83b7\u53d6\u9501\u65f6\u624d\u8ba4\u4e3a\u9501\u83b7\u53d6\u6210\u529f\u3002Go\u8bed\u8a00\u53ef\u4ee5\u9ad8\u6548\u5730\u5b9e\u73b0RedLock\u7b97\u6cd5\uff0c\u7ed3\u5408github.com\/go-redis\/redis\/v8\u5305\u53ef\u4ee5\u8f7b\u677e\u4e0eRedis\u96c6\u7fa4\u4ea4\u4e92\u3002<\/p>\n
                    \u591a\u8282\u70b9\u9501\u83b7\u53d6<\/strong><\/p>\n
                    RedLock\u7b97\u6cd5\u7684\u6838\u5fc3\u601d\u60f3\u662f\uff1a\u5ba2\u6237\u7aef\u9700\u8981\u5728\u591a\u4e2a\u72ec\u7acb\u7684Redis\u8282\u70b9\u4e0a\u83b7\u53d6\u9501\uff0c\u53ea\u6709\u5f53\u5728\u8d85\u8fc7\u534a\u6570\u7684\u8282\u70b9\u4e0a\u6210\u529f\u83b7\u53d6\u9501\u65f6\uff0c\u624d\u8ba4\u4e3a\u9501\u83b7\u53d6\u6210\u529f\u3002<\/strong> \u8fd9\u79cd\u8bbe\u8ba1\u53ef\u4ee5\u907f\u514d\u5355\u70b9\u6545\u969c\u548c\u8111\u88c2\u95ee\u9898\uff0c\u63d0\u9ad8\u9501\u7684\u53ef\u9760\u6027\u3002<\/p>\n
                    \u9501\u7eed\u547d\u673a\u5236<\/strong><\/p>\n
                    \u901a\u8fc7\u5b9a\u65f6\u5668\u5b9a\u671f\u5237\u65b0\u9501\u7684\u8fc7\u671f\u65f6\u95f4\uff0c\u786e\u4fdd\u5728\u4efb\u52a1\u6267\u884c\u671f\u95f4\u9501\u4e0d\u4f1a\u8fc7\u671f\u3002\u8fd9\u79cd\u673a\u5236\u53ef\u4ee5\u89e3\u51b3\u9501\u8fc7\u671f\u65f6\u95f4\u4e0e\u4efb\u52a1\u6267\u884c\u65f6\u95f4\u4e0d\u5339\u914d\u7684\u95ee\u9898\uff0c\u907f\u514d\u5e76\u53d1\u51b2\u7a81\u3002<\/p>\n
                    \u7ec6\u7c92\u5ea6\u9501\u63a7\u5236<\/strong><\/p>\n
                    \u4f7f\u7528Redis\u7684\u54c8\u5e0c\u7ed3\u6784\u5b9e\u73b0\u7ec6\u7c92\u5ea6\u7684\u9501\u63a7\u5236\uff0c\u5141\u8bb8\u5ba2\u6237\u7aef\u53ea\u9501\u5b9a\u8d44\u6e90\u7684\u7279\u5b9a\u90e8\u5206\uff0c\u63d0\u9ad8\u7cfb\u7edf\u7684\u5e76\u53d1\u5904\u7406\u80fd\u529b\u3002<\/p>\n
                    \u4ee3\u7801\u5b9e\u73b0<\/h3>\n
                    \"\"<\/p>\n
                    RedLock\u7b97\u6cd5\u5b9e\u73b0<\/strong><\/p>\n
                    \/\/ Lock \u83b7\u53d6\u5206\u5e03\u5f0f\u9501\nfunc (rl *RedLock) Lock(ctx context.Context, key string) (bool, error) {\n    \/\/ \u751f\u6210\u968f\u673a\u9501\u503c\n    value := rl.generateRandomValue()\n\n\n    \/\/ \u8ba1\u7b97\u9501\u7684\u8fc7\u671f\u65f6\u95f4\n    expireAt := time.Now().Add(rl.ttl).UnixNano() \/ int64(time.Millisecond)\n\n\n    \/\/ \u91cd\u8bd5\u83b7\u53d6\u9501\n    for i := 0; i < rl.retryCount; i++ {\n        \/\/ \u5728\u591a\u4e2aRedis\u8282\u70b9\u4e0a\u83b7\u53d6\u9501\n        successCount := 0\n        for _, client := range rl.clients {\n            success, err := rl.tryLock(ctx, client, key, value, rl.ttl)\n            if err != nil {\n                continue\n            }\n            if success {\n                successCount++\n            }\n        }\n\n\n        \/\/ \u68c0\u67e5\u662f\u5426\u5728\u5927\u591a\u6570\u8282\u70b9\u4e0a\u6210\u529f\u83b7\u53d6\u9501\n        if successCount > len(rl.clients)\/2 {\n            \/\/ \u8ba1\u7b97\u5b9e\u9645\u8fc7\u671f\u65f6\u95f4\uff08\u8003\u8651\u65f6\u949f\u6f02\u79fb\uff09\n            actualExpireAt := expireAt - rl.clockDrift\n            if actualExpireAt > time.Now().UnixNano()\/int64(time.Millisecond) {\n                \/\/ \u6210\u529f\u83b7\u53d6\u9501\uff0c\u8bb0\u5f55\u9501\u4fe1\u606f\n                rl.mu.Lock()\n                rl.lockedKeys[key] = true\n                rl.lockValues[key] = value\n                rl.mu.Unlock()\n\n\n                \/\/ \u542f\u52a8\u9501\u7eed\u547d\u534f\u7a0b\n                go rl.extendLock(ctx, key, value)\n\n\n                return true, nil\n            }\n        }\n\n\n        \/\/ \u77ed\u6682\u4f11\u7720\u540e\u91cd\u8bd5\n        time.Sleep(rl.retryDelay)\n    }\n\n\n    return false, nil\n}\n\/\/ tryLock \u5728\u5355\u4e2aRedis\u8282\u70b9\u4e0a\u5c1d\u8bd5\u83b7\u53d6\u9501\nfunc (rl *RedLock) tryLock(ctx context.Context, client *redis.Client, key, value string, ttl time.Duration) (bool, error) {\n    \/\/ \u4f7f\u7528SETNX\u547d\u4ee4\u83b7\u53d6\u9501\n    success, err := client.SetNX(ctx, key, value, ttl).Result()\n    if err != nil {\n        return false, err\n    }\n    return success, nil\n}\n\/\/ extendLock \u9501\u7eed\u547d\nfunc (rl *RedLock) extendLock(ctx context.Context, key, value string) {\n    \/\/ \u7eed\u547d\u95f4\u9694\u4e3aTTL\u76841\/3\n    extendInterval := rl.ttl \/ 3\n    ticker := time.NewTicker(extendInterval)\n    defer ticker.Stop()\n\n\n    for {\n        select {\n        case <-ctx.Done():\n            \/\/ \u4e0a\u4e0b\u6587\u53d6\u6d88\uff0c\u505c\u6b62\u7eed\u547d\n            return\n        case <-ticker.C:\n            \/\/ \u68c0\u67e5\u9501\u662f\u5426\u5df2\u91ca\u653e\n            rl.mu.Lock()\n            if !rl.lockedKeys[key] {\n                rl.mu.Unlock()\n                return\n            }\n            rl.mu.Unlock()\n\n\n            \/\/ \u7eed\u547d\u9501\n            successCount := 0\n            for _, client := range rl.clients {\n                \/\/ \u53ea\u6709\u5f53\u9501\u503c\u5339\u914d\u65f6\u624d\u7eed\u547d\n                script := `\n                if redis.call("GET", KEYS[1]) == ARGV[1] then\n                    return redis.call("PEXPIRE", KEYS[1], ARGV[2])\n                else\n                    return 0\n                end\n                `\n                success, err := client.Eval(ctx, script, []string{key}, value, rl.ttl.Milliseconds()).Int()\n                if err != nil {\n                    continue\n                }\n                if success == 1 {\n                    successCount++\n                }\n            }\n\n\n            \/\/ \u68c0\u67e5\u662f\u5426\u5728\u5927\u591a\u6570\u8282\u70b9\u4e0a\u6210\u529f\u7eed\u547d\n            if successCount <= len(rl.clients)\/2 {\n                \/\/ \u7eed\u547d\u5931\u8d25\uff0c\u91ca\u653e\u9501\n                rl.Unlock(ctx, key)\n                return\n            }\n        }\n    }\n}\n\/\/ Unlock \u91ca\u653e\u5206\u5e03\u5f0f\u9501\nfunc (rl *RedLock) Unlock(ctx context.Context, key string) error {\n    \/\/ \u68c0\u67e5\u9501\u662f\u5426\u5df2\u83b7\u53d6\n    rl.mu.Lock()\n    value, ok := rl.lockValues[key]\n    if !ok || !rl.lockedKeys[key] {\n        rl.mu.Unlock()\n        return nil\n    }\n\n\n    \/\/ \u6e05\u9664\u9501\u4fe1\u606f\n    delete(rl.lockedKeys, key)\n    delete(rl.lockValues, key)\n    rl.mu.Unlock()\n\n\n    \/\/ \u5728\u6240\u6709Redis\u8282\u70b9\u4e0a\u91ca\u653e\u9501\n    for _, client := range rl.clients {\n        \/\/ \u53ea\u6709\u5f53\u9501\u503c\u5339\u914d\u65f6\u624d\u91ca\u653e\n        script := `\n        if redis.call("GET", KEYS[1]) == ARGV[1] then\n            return redis.call("DEL", KEYS[1])\n        else\n            return 0\n        end\n        `\n        _, err := client.Eval(ctx, script, []string{key}, value).Int()\n        if err != nil {\n            return err\n        }\n    }\n\n\n    return nil\n}<\/code><\/pre>\n
                    \u7406\u8bba\u77e5\u8bc6\u652f\u6491<\/h3>\n
                    Fencing Token<\/strong><\/p>\n
                    Fencing Token\u662f\u4e00\u79cd\u9632\u6b62\u65e7\u5ba2\u6237\u7aef\u7ee7\u7eed\u64cd\u4f5c\u7684\u673a\u5236\u3002\u6bcf\u6b21\u83b7\u53d6\u9501\u65f6\uff0c\u751f\u6210\u4e00\u4e2a\u552f\u4e00\u9012\u589e\u7684Token\uff0c\u5ba2\u6237\u7aef\u5728\u6267\u884c\u64cd\u4f5c\u65f6\u9700\u8981\u643a\u5e26\u8fd9\u4e2aToken\u3002\u670d\u52a1\u7aef\u901a\u8fc7\u68c0\u67e5Token\u7684\u6709\u6548\u6027\u6765\u786e\u4fdd\u53ea\u6709\u6700\u65b0\u83b7\u53d6\u9501\u7684\u5ba2\u6237\u7aef\u624d\u80fd\u6267\u884c\u64cd\u4f5c\u3002<\/p>\n
                    Quorum\u7b97\u6cd5<\/strong><\/p>\n
                    Quorum\u7b97\u6cd5\u662f\u6307\u5728\u5206\u5e03\u5f0f\u7cfb\u7edf\u4e2d\uff0c\u53ea\u6709\u5f53\u8d85\u8fc7\u534a\u6570\u7684\u8282\u70b9\u540c\u610f\u67d0\u4e2a\u64cd\u4f5c\u65f6\uff0c\u624d\u8ba4\u4e3a\u8be5\u64cd\u4f5c\u6709\u6548\u3002RedLock\u7b97\u6cd5\u57fa\u4e8eQuorum\u7b97\u6cd5\uff0c\u8981\u6c42\u5728\u8d85\u8fc7\u534a\u6570\u7684Redis\u8282\u70b9\u4e0a\u6210\u529f\u83b7\u53d6\u9501\u624d\u8ba4\u4e3a\u9501\u83b7\u53d6\u6210\u529f\uff0c\u907f\u514d\u4e86\u8111\u88c2\u95ee\u9898\u3002<\/p>\n
                    \u65f6\u949f\u56de\u62e8\u9632\u5fa1<\/strong><\/p>\n
                    \u65f6\u949f\u56de\u62e8\u662f\u6307\u670d\u52a1\u5668\u65f6\u949f\u7a81\u7136\u5411\u540e\u8df3\u8dc3\uff0c\u5bfc\u81f4\u9501\u63d0\u524d\u8fc7\u671f\u3002RedLock\u7b97\u6cd5\u901a\u8fc7\u8bb0\u5f55\u9501\u521b\u5efa\u65f6\u7684\u7269\u7406\u65f6\u95f4\u6233\uff0c\u5e76\u5728\u68c0\u67e5\u9501\u6709\u6548\u6027\u65f6\u8003\u8651\u65f6\u949f\u6f02\u79fb\uff0c\u6765\u9632\u5fa1\u65f6\u949f\u56de\u62e8\u95ee\u9898\u3002<\/p>\n
                    \u7ec6\u7c92\u5ea6\u9501\u8bbe\u8ba1<\/strong><\/p>\n
                    \u7ec6\u7c92\u5ea6\u9501\u662f\u6307\u5c06\u9501\u7684\u7c92\u5ea6\u7ec6\u5316\u5230\u8d44\u6e90\u7684\u7279\u5b9a\u90e8\u5206\uff0c\u800c\u4e0d\u662f\u6574\u4e2a\u8d44\u6e90\u3002\u4f8b\u5982\uff0c\u5f53\u591a\u4e2a\u5ba2\u6237\u7aef\u9700\u8981\u8bbf\u95ee\u540c\u4e00\u5546\u54c1\u7684\u4e0d\u540cSKU\u5e93\u5b58\u65f6\uff0c\u53ef\u4ee5\u4f7f\u7528\u7ec6\u7c92\u5ea6\u9501\u53ea\u9501\u5b9a\u7279\u5b9aSKU\u7684\u5e93\u5b58\uff0c\u800c\u4e0d\u662f\u6574\u4e2a\u5546\u54c1\u7684\u5e93\u5b58\u3002\u8fd9\u79cd\u8bbe\u8ba1\u53ef\u4ee5\u63d0\u9ad8\u7cfb\u7edf\u7684\u5e76\u53d1\u5904\u7406\u80fd\u529b\u3002<\/p>\n
                    \u4e03\u3001\u7ed3\u8bba\uff1aGo\u8bed\u8a00\u7684\u6838\u5fc3\u7ade\u4e89\u529b<\/h2>\n
                    \u901a\u8fc7\u4e0a\u8ff0\u4e94\u4e2a\u5178\u578b\u573a\u666f\u7684\u5206\u6790\uff0c\u6211\u4eec\u53ef\u4ee5\u770b\u51faGo\u8bed\u8a00\u5728\u6784\u5efa\u9ad8\u5e76\u53d1\u9ad8\u53ef\u7528\u7cfb\u7edf\u65b9\u9762\u5177\u6709\u663e\u8457\u7684\u4f18\u52bf\u3002\u8fd9\u4e9b\u4f18\u52bf\u4e3b\u8981\u4f53\u73b0\u5728\u4ee5\u4e0b\u51e0\u4e2a\u65b9\u9762\uff1a<\/p>\n
                    1. \u6781\u81f4\u5e76\u53d1\u6a21\u578b<\/h3>\n
                    Go\u8bed\u8a00\u7684Goroutine\u548cChannel\u662f\u5176\u5e76\u53d1\u6a21\u578b\u7684\u6838\u5fc3\uff0cGoroutine\u7684\u8c03\u5ea6\u5f00\u9500\u6bd4\u7ebf\u7a0b\u4f4e100\u500d\uff0c\u9002\u5408\u767e\u4e07\u7ea7\u5e76\u53d1\u573a\u666f\u3002Goroutine\u7684\u521b\u5efa\u548c\u9500\u6bc1\u5f00\u9500\u6781\u5c0f\uff0c\u5185\u5b58\u5360\u7528\u4ec5\u4e3a2KB\u5de6\u53f3\uff0c\u800c\u7ebf\u7a0b\u7684\u5185\u5b58\u5360\u7528\u901a\u5e38\u4e3aMB\u7ea7\u522b\u3002\u6b64\u5916\uff0cGo\u8bed\u8a00\u7684\u8c03\u5ea6\u5668\u91c7\u7528M:N\u6a21\u578b\uff0c\u5c06\u591a\u4e2aGoroutine\u6620\u5c04\u5230\u5c11\u6570\u51e0\u4e2aOS\u7ebf\u7a0b\u4e0a\uff0c\u51cf\u5c11\u4e86OS\u7ebf\u7a0b\u7684\u4e0a\u4e0b\u6587\u5207\u6362\u5f00\u9500\u3002<\/p>\n
                    2. \u9ad8\u6027\u80fd\u7f51\u7edc\u5e93<\/h3>\n
                    Go\u8bed\u8a00\u7684\u6807\u51c6\u5e93\uff08\u5982net\/http\u3001net\/grpc\uff09\u57fa\u4e8eepoll\/kqueue\u7b49\u4e8b\u4ef6\u9a71\u52a8\u673a\u5236\u5b9e\u73b0\uff0c\u652f\u6301\u96f6\u62f7\u8d1dI\/O\uff0c\u5ef6\u8fdf\u53ef\u63a7\u5236\u57281ms\u5185\u3002\u8fd9\u4e9b\u7f51\u7edc\u5e93\u5df2\u7ecf\u8fc7\u5e7f\u6cdb\u7684\u751f\u4ea7\u9a8c\u8bc1\uff0c\u5728\u9ad8\u5e76\u53d1\u573a\u666f\u4e0b\u8868\u73b0\u4f18\u5f02\u3002\u6b64\u5916\uff0cGo\u8bed\u8a00\u7684\u7f51\u7edc\u5e93\u652f\u6301\u591a\u8def\u590d\u7528\u548c\u5f02\u6b65I\/O\uff0c\u80fd\u591f\u9ad8\u6548\u5730\u5904\u7406\u5927\u91cf\u5e76\u53d1\u8fde\u63a5\u3002<\/p>\n
                    3. \u5185\u5b58\u5b89\u5168\u4e0e\u539f\u5b50\u64cd\u4f5c<\/h3>\n
                    Go\u8bed\u8a00\u901a\u8fc7\u5783\u573e\u56de\u6536\u673a\u5236\u548c\u7c7b\u578b\u7cfb\u7edf\u786e\u4fdd\u5185\u5b58\u5b89\u5168\uff0c\u907f\u514d\u4e86\u5e38\u89c1\u7684\u5185\u5b58\u9519\u8bef\uff08\u5982\u7f13\u51b2\u533a\u6ea2\u51fa\u3001\u91ce\u6307\u9488\uff09\u3002\u540c\u65f6\uff0cGo\u8bed\u8a00\u7684sync\/atomic\u5305\u63d0\u4f9b\u4e86\u9ad8\u6548\u7684\u539f\u5b50\u64cd\u4f5c\uff0c\u652f\u6301\u65e0\u9501\u7f16\u7a0b\uff0c\u907f\u514d\u4e86\u6570\u636e\u7ade\u4e89\u95ee\u9898\u3002\u8fd9\u4e9b\u7279\u6027\u4f7f\u5f97Go\u8bed\u8a00\u5728\u9ad8\u5e76\u53d1\u573a\u666f\u4e0b\u5177\u6709\u826f\u597d\u7684\u7a33\u5b9a\u6027\u548c\u53ef\u9760\u6027\u3002<\/p>\n
                    4. \u7b80\u6d01\u7684\u5e76\u53d1\u7f16\u7a0b\u6a21\u578b<\/h3>\n
                    Go\u8bed\u8a00\u7684\u5e76\u53d1\u7f16\u7a0b\u6a21\u578b\u975e\u5e38\u7b80\u6d01\uff0c\u901a\u8fc7Goroutine\u548cChannel\u53ef\u4ee5\u8f7b\u677e\u5b9e\u73b0\u590d\u6742\u7684\u5e76\u53d1\u903b\u8f91\u3002\u4e0e\u4f20\u7edf\u7684\u7ebf\u7a0b+\u9501\u6a21\u578b\u76f8\u6bd4\uff0cGo\u8bed\u8a00\u7684\u5e76\u53d1\u7f16\u7a0b\u6a21\u578b\u66f4\u52a0\u5b89\u5168\u3001\u9ad8\u6548\u548c\u6613\u7528\u3002\u4f8b\u5982\uff0c\u901a\u8fc7select\u8bed\u53e5\u53ef\u4ee5\u540c\u65f6\u76d1\u542c\u591a\u4e2aChannel\uff0c\u5b9e\u73b0\u975e\u963b\u585e\u7684I\/O\u64cd\u4f5c\uff1b\u901a\u8fc7sync.WaitGroup\u53ef\u4ee5\u8f7b\u677e\u5b9e\u73b0\u591a\u4e2aGoroutine\u7684\u540c\u6b65\u3002<\/p>\n
                    5. \u4e30\u5bcc\u7684\u751f\u6001\u7cfb\u7edf<\/h3>\n
                    Go\u8bed\u8a00\u62e5\u6709\u4e30\u5bcc\u7684\u751f\u6001\u7cfb\u7edf\uff0c\u4ece\u5fae\u670d\u52a1\u6846\u67b6\uff08\u5982Kratos\u3001Gin\uff09\u5230\u5206\u5e03\u5f0f\u5b58\u50a8\uff08\u5982Etcd\u3001TiKV\uff09\uff0c\u4ece\u6d88\u606f\u961f\u5217\uff08\u5982NATS\u3001NSQ\uff09\u5230\u76d1\u63a7\u7cfb\u7edf\uff08\u5982Prometheus\u3001Grafana\uff09\uff0c\u5f62\u6210\u4e86\u5b8c\u6574\u7684\u9ad8\u53ef\u7528\u89e3\u51b3\u65b9\u6848\u6808\u3002\u8fd9\u4e9b\u5f00\u6e90\u9879\u76ee\u5df2\u7ecf\u8fc7\u5e7f\u6cdb\u7684\u751f\u4ea7\u9a8c\u8bc1\uff0c\u80fd\u591f\u5e2e\u52a9\u5f00\u53d1\u8005\u5feb\u901f\u6784\u5efa\u9ad8\u5e76\u53d1\u9ad8\u53ef\u7528\u7cfb\u7edf\u3002<\/p>\n
                    6. \u7f16\u8bd1\u578b\u8bed\u8a00\u7684\u9ad8\u6027\u80fd<\/h3>\n
                    Go\u8bed\u8a00\u662f\u4e00\u79cd\u7f16\u8bd1\u578b\u8bed\u8a00\uff0c\u7f16\u8bd1\u540e\u751f\u6210\u7684\u4e8c\u8fdb\u5236\u6587\u4ef6\u53ef\u4ee5\u76f4\u63a5\u8fd0\u884c\uff0c\u65e0\u9700\u89e3\u91ca\u5668\u3002\u4e0e\u89e3\u91ca\u578b\u8bed\u8a00\uff08\u5982Python\u3001JavaScript\uff09\u76f8\u6bd4\uff0cGo\u8bed\u8a00\u5177\u6709\u66f4\u9ad8\u7684\u6267\u884c\u6548\u7387\u3002\u6b64\u5916\uff0cGo\u8bed\u8a00\u7684\u7f16\u8bd1\u5668\u4f18\u5316\u505a\u5f97\u975e\u5e38\u597d\uff0c\u80fd\u591f\u751f\u6210\u9ad8\u6548\u7684\u673a\u5668\u7801\uff0c\u8fdb\u4e00\u6b65\u63d0\u9ad8\u4e86\u7cfb\u7edf\u7684\u6027\u80fd\u3002<\/p>\n
                    7. \u5f3a\u5927\u7684\u6807\u51c6\u5e93<\/h3>\n
                    Go\u8bed\u8a00\u7684\u6807\u51c6\u5e93\u975e\u5e38\u5f3a\u5927\uff0c\u63d0\u4f9b\u4e86\u4e30\u5bcc\u7684\u529f\u80fd\uff0c\u5305\u62ec\u7f51\u7edc\u901a\u4fe1\u3001\u5e76\u53d1\u63a7\u5236\u3001\u52a0\u5bc6\u89e3\u5bc6\u3001\u6587\u4ef6\u64cd\u4f5c\u7b49\u3002\u8fd9\u4e9b\u6807\u51c6\u5e93\u7ecf\u8fc7\u7cbe\u5fc3\u8bbe\u8ba1\u548c\u4f18\u5316\uff0c\u5177\u6709\u826f\u597d\u7684\u6027\u80fd\u548c\u53ef\u9760\u6027\u3002\u5f00\u53d1\u8005\u53ef\u4ee5\u76f4\u63a5\u4f7f\u7528\u6807\u51c6\u5e93\u6784\u5efa\u590d\u6742\u7684\u7cfb\u7edf\uff0c\u65e0\u9700\u4f9d\u8d56\u5927\u91cf\u7684\u7b2c\u4e09\u65b9\u5e93\uff0c\u51cf\u5c11\u4e86\u4f9d\u8d56\u7ba1\u7406\u7684\u590d\u6742\u5ea6\u3002<\/p>\n
                    \u516b\u3001\u603b\u7ed3<\/h2>\n
                    Go\u8bed\u8a00\u51ed\u501f\u5176\u72ec\u7279\u7684\u8bbe\u8ba1\u54f2\u5b66\u548c\u6280\u672f\u7279\u6027\uff0c\u6210\u4e3a\u4e86\u6784\u5efa\u9ad8\u5e76\u53d1\u9ad8\u53ef\u7528\u7cfb\u7edf\u7684\u9996\u9009\u8bed\u8a00\u4e4b\u4e00\u3002\u901a\u8fc7\u4e0a\u8ff0\u4e94\u4e2a\u5178\u578b\u573a\u666f\u7684\u5206\u6790\uff0c\u6211\u4eec\u53ef\u4ee5\u770b\u51faGo\u8bed\u8a00\u5728\u5904\u7406\u5fae\u670d\u52a1\u901a\u4fe1\u3001\u5b9e\u65f6\u6d88\u606f\u63a8\u9001\u3001API\u7f51\u5173\u9650\u6d41\u4e0e\u7194\u65ad\u3001\u5206\u5e03\u5f0f\u4efb\u52a1\u961f\u5217\u548c\u5206\u5e03\u5f0f\u9501\u7b49\u573a\u666f\u65f6\u5177\u6709\u663e\u8457\u7684\u4f18\u52bf\u3002<\/p>\n
                    Go\u8bed\u8a00\u7684\u6838\u5fc3\u7ade\u4e89\u529b\u5728\u4e8e\u5176\u6781\u81f4\u7684\u5e76\u53d1\u6a21\u578b\u3001\u9ad8\u6027\u80fd\u7684\u7f51\u7edc\u5e93\u3001\u5185\u5b58\u5b89\u5168\u4e0e\u539f\u5b50\u64cd\u4f5c\u3001\u7b80\u6d01\u7684\u5e76\u53d1\u7f16\u7a0b\u6a21\u578b\u3001\u4e30\u5bcc\u7684\u751f\u6001\u7cfb\u7edf\u3001\u7f16\u8bd1\u578b\u8bed\u8a00\u7684\u9ad8\u6027\u80fd\u4ee5\u53ca\u5f3a\u5927\u7684\u6807\u51c6\u5e93\u3002\u8fd9\u4e9b\u7279\u6027\u4f7f\u5f97Go\u8bed\u8a00\u5728\u9ad8\u5e76\u53d1\u9ad8\u53ef\u7528\u7cfb\u7edf\u4e2d\u8868\u73b0\u4f18\u5f02\uff0c\u80fd\u591f\u5e2e\u52a9\u5f00\u53d1\u8005\u5feb\u901f\u6784\u5efa\u53ef\u9760\u3001\u9ad8\u6548\u7684\u5206\u5e03\u5f0f\u7cfb\u7edf\u3002<\/p>\n
                    \u968f\u7740\u4e92\u8054\u7f51\u6280\u672f\u7684\u4e0d\u65ad\u53d1\u5c55\uff0c\u9ad8\u5e76\u53d1\u9ad8\u53ef\u7528\u7cfb\u7edf\u7684\u9700\u6c42\u5c06\u8d8a\u6765\u8d8a\u666e\u904d\u3002Go\u8bed\u8a00\u4f5c\u4e3a\u4e00\u79cd\u4e13\u4e3a\u5e76\u53d1\u8bbe\u8ba1\u7684\u7f16\u7a0b\u8bed\u8a00\uff0c\u5fc5\u5c06\u5728\u672a\u6765\u7684\u5206\u5e03\u5f0f\u7cfb\u7edf\u4e2d\u53d1\u6325\u8d8a\u6765\u8d8a\u91cd\u8981\u7684\u4f5c\u7528\u3002<\/strong><\/p>\n
                    \u5f80\u671f\u56de\u987e<\/h3>\n
                    1.\u9879\u76ee\u6027\u80fd\u4f18\u5316\u5b9e\u8df5\uff1a\u6df1\u5165FMP\u7b97\u6cd5\u539f\u7406\u63a2\u7d22\uff5c\u5f97\u7269\u6280\u672f<\/p>\n
                    2.Dragonboat\u7edf\u4e00\u5b58\u50a8LogDB\u5b9e\u73b0\u5206\u6790\uff5c\u5f97\u7269\u6280\u672f<\/p>\n
                    3.\u4ece\u6570\u5b57\u5230\u7248\u9762\uff1a\u5f97\u7269\u6570\u636e\u4ea7\u54c1\u91cc\u6570\u5b57\u683c\u5f0f\u5316\u7684\u90a3\u4e9b\u4e8b<\/p>\n
                    4.RN\u4e0ehawk\u78b0\u649e\u7684\u706b\u82b1\u4e4bC++\u5f02\u5e38\u6355\u83b7\uff5c\u5f97\u7269\u6280\u672f<\/p>\n
                    5.\u5927\u6a21\u578b\u5982\u4f55\u9769\u65b0\u641c\u7d22\u76f8\u5173\u6027\uff1f\u667a\u80fd\u5347\u7ea7\u8ba9\u641c\u7d22\u66f4\u201c\u61c2\u4f60\u201d\uff5c\u5f97\u7269\u6280\u672f<\/p>\n
                    \u6587 \/\u609f<\/h3>\n
                    \u5173\u6ce8\u5f97\u7269\u6280\u672f\uff0c\u6bcf\u5468\u66f4\u65b0\u6280\u672f\u5e72\u8d27<\/p>\n
                    \u8981\u662f\u89c9\u5f97\u6587\u7ae0\u5bf9\u4f60\u6709\u5e2e\u52a9\u7684\u8bdd\uff0c\u6b22\u8fce\u8bc4\u8bba\u8f6c\u53d1\u70b9\u8d5e\uff5e<\/p>\n
                    \u672a\u7ecf\u5f97\u7269\u6280\u672f\u8bb8\u53ef\u4e25\u7981\u8f6c\u8f7d\uff0c\u5426\u5219\u4f9d\u6cd5\u8ffd\u7a76\u6cd5\u5f8b\u8d23\u4efb\u3002<\/p>\n
                    https:\/\/segmentfault.com\/a\/1190000047477645<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"
                    \u4e00\u3001\u5f15\u8a00 \u968f\u7740\u4e92\u8054\u7f51\u6280\u672f\u7684\u98de\u901f\u53d1\u5c55\uff0c\u73b0\u4ee3\u7cfb\u7edf\u9762\u4e34\u7740\u524d\u6240\u672a\u6709\u7684\u5e76\u53d1\u538b\u529b\u548c\u53ef\u7528\u6027\u8981\u6c42\u3002\u4ece\u7535\u5546\u79d2\u6740\u5230\u793e\u4ea4\u5a92\u4f53\u76f4\u64ad\uff0c\u4ece […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"_jetpack_memberships_contains_paid_content":false,"footnotes":""},"categories":[4],"tags":[],"class_list":["post-10021122","post","type-post","status-publish","format-standard","hentry","category-share"],"jetpack_sharing_enabled":true,"jetpack_featured_media_url":"","_links":{"self":[{"href":"https:\/\/itmax.cn\/index.php?rest_route=\/wp\/v2\/posts\/10021122","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/itmax.cn\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/itmax.cn\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/itmax.cn\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/itmax.cn\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=10021122"}],"version-history":[{"count":0,"href":"https:\/\/itmax.cn\/index.php?rest_route=\/wp\/v2\/posts\/10021122\/revisions"}],"wp:attachment":[{"href":"https:\/\/itmax.cn\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=10021122"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/itmax.cn\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=10021122"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/itmax.cn\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=10021122"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}