{"id":42992,"date":"2024-12-01T14:03:18","date_gmt":"2024-12-01T06:03:18","guid":{"rendered":"https:\/\/fwq.ai\/blog\/42992\/"},"modified":"2024-12-01T14:03:18","modified_gmt":"2024-12-01T06:03:18","slug":"%e5%a6%82%e4%bd%95%e4%bd%bf%e7%94%a8-envoy-%e5%92%8c-grpc_web-%e8%bf%9e%e6%8e%a5-go-grpc-%e6%9c%8d%e5%8a%a1%e5%99%a8%e4%b8%8e-dart-grpc-%e5%ae%a2%e6%88%b7%e7%ab%af","status":"publish","type":"post","link":"https:\/\/fwq.ai\/blog\/42992\/","title":{"rendered":"\u5982\u4f55\u4f7f\u7528 Envoy \u548c Grpc_web \u8fde\u63a5 go grpc \u670d\u52a1\u5668\u4e0e dart grpc \u5ba2\u6237\u7aef"},"content":{"rendered":"

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

\u5f53\u524d\u4f4d\u7f6e\uff1a ><\/span> ><\/span> ><\/span> ><\/span> \u5982\u4f55\u4f7f\u7528 Envoy \u548c Grpc_web \u8fde\u63a5 go grpc \u670d\u52a1\u5668\u4e0e dart grpc \u5ba2\u6237\u7aef<\/span><\/p>\n

\u5982\u4f55\u4f7f\u7528 Envoy \u548c Grpc_web \u8fde\u63a5 go grpc \u670d\u52a1\u5668\u4e0e dart grpc \u5ba2\u6237\u7aef<\/h1>\n

\u6765\u6e90\uff1astackoverflow<\/span>
\n2024-04-28 09:48:34<\/span>
\n<\/i>0\u6d4f\u89c8<\/span>
\n<\/i>\u6536\u85cf<\/span> <\/p>\n

\u73cd\u60dc\u65f6\u95f4\uff0c\u52e4\u594b\u5b66\u4e60\uff01\u4eca\u5929\u7ed9\u5927\u5bb6\u5e26\u6765\u300a\u5982\u4f55\u4f7f\u7528 Envoy \u548c Grpc_web \u8fde\u63a5 go grpc \u670d\u52a1\u5668\u4e0e dart grpc \u5ba2\u6237\u7aef\u300b<\/span>\uff0c\u6b63\u6587\u5185\u5bb9\u4e3b\u8981\u6d89\u53ca\u5230<\/span>\u7b49\u7b49\uff0c\u5982\u679c\u4f60\u6b63\u5728\u5b66\u4e60Golang<\/span>\uff0c\u6216\u8005\u662f\u5bf9Golang<\/span>\u6709\u7591\u95ee\uff0c\u6b22\u8fce\u5927\u5bb6\u5173\u6ce8\u6211\uff01\u540e\u9762\u6211\u4f1a\u6301\u7eed\u66f4\u65b0\u76f8\u5173\u5185\u5bb9\u7684\uff0c\u5e0c\u671b\u90fd\u80fd\u5e2e\u5230\u6b63\u5728\u5b66\u4e60\u7684\u5927\u5bb6\uff01<\/p>\n

\u95ee\u9898\u5185\u5bb9
\n <\/p>\n

\u6211\u662f grpc_web \u548c envoy \u7684\u65b0\u624b\u3002<\/p>\n

\u8bf7\u5e2e\u6211\u8bbe\u7f6e\u4ee5\u4e0b\u5185\u5bb9\uff0c<\/p>\n

    \n
  1. grpc_go \u670d\u52a1\u5668\u4f5c\u4e3a docker \u5bb9\u5668\u5728 ec2 \u5b9e\u4f8b\u4e0a\u8fd0\u884c<\/li>\n
  2. dart web \u5ba2\u6237\u7aef\u6b63\u5728\u672c\u5730 pc \u4e0a\u8fd0\u884c<\/li>\n
  3. \u9700\u8981\u4ece dart web \u5e94\u7528\u5411 grpc_go \u670d\u52a1\u5668\u53d1\u51fa grpc \u8c03\u7528\u8bf7\u6c42<\/li>\n
  4. \u4f7f\u7528 envoy \u4ee3\u7406\u6765\u8f6c\u53d1\u8bf7\u6c42\u3002 envoy \u4ee3\u7406\u4f5c\u4e3a\u5bb9\u5668\u5728\u540c\u4e00\u4e2a ec2 \u5b9e\u4f8b\u4e2d\u8fd0\u884c<\/li>\n<\/ol>\n

    \u6211\u6536\u5230\u4ee5\u4e0b\u9519\u8bef\u201c\u54cd\u5e94\uff1anull\uff0c\u9884\u544a\u7247\uff1a{access-control-allow-credentials\uff1atrue\uff0caccess-control-allow-origin\uff1ahttp:\/\/127.0.0.1:9000\uff0c\u53d8\u5316\uff1aorigin} \uff09\u201d\u3002<\/p>\n

    grpc_go\uff1a<\/strong><\/p>\n

    package main\n\nimport (\n\"context\"\n\"flag\"\n\"fmt\"\n\"log\"\n\"net\"\n\n\"google.golang.org\/grpc\"\npb \"google.golang.org\/grpc\/examples\/helloworld\/helloworld\"\n)\n\nvar (\n  port = flag.int(\"port\", 50051, \"the server port\")\n)\n\n\/\/ server is used to implement helloworld.greeterserver.\ntype server struct {\n   pb.unimplementedgreeterserver\n}\n\n\/\/ sayhello implements helloworld.greeterserver\nfunc (s *server) sayhello(ctx context.context, in *pb.hellorequest) (*pb.helloreply, error) {\n   log.printf(\"received: %v\", in.getname())\n   return &pb.helloreply{message: \"hello \" + in.getname()}, nil\n}\n\nfunc (s *server) sayhelloagain(ctx context.context, in *pb.hellorequest) (*pb.helloreply, \nerror) \n{\n   return &pb.helloreply{message: \"hello again \" + in.getname()}, nil\n}\n\nfunc main() {\nflag.parse()\nlis, err := net.listen(\"tcp\", fmt.sprintf(\":%d\", *port))\nif err != nil {\n    log.fatalf(\"failed to listen: %v\", err)\n}\ns := grpc.newserver()\npb.registergreeterserver(s, &server{})\nlog.printf(\"server listening at %v\", lis.addr())\nif err := s.serve(lis); err != nil {\n    log.fatalf(\"failed to serve: %v\", err)\n }\n}<\/pre>\n
    grpc_dart_client\uff1a<\/strong><\/p>\n
    import 'package:grpc\/grpc_web.dart';\nimport 'package:grpc_web\/app.dart';\nimport 'package:grpc_web\/src\/generated\/echo.pbgrpc.dart';\n\nvoid main() {\n  final channel = grpcwebclientchannel.xhr(uri.parse('http:\/\/ec2-ip:8080'));\n  final service = echoserviceclient(channel);\n  final app = echoapp(service);\n\n  final button = queryselector('#send') as buttonelement;\n  button.onclick.listen((e) async {\n    final msg = queryselector('#msg') as textinputelement;\n    final value = msg.value!.trim();\n    msg.value = '';\n\n    if (value.isempty) return;\n\n    if (value.indexof(' ') > 0) {\n      final countstr = value.substring(0, value.indexof(' '));\n      final count = int.tryparse(countstr);\n\n      if (count != null) {\n        app.repeatecho(value.substring(value.indexof(' ') + 1), count);\n      } else {\n        app.echo(value);\n      }\n    } else {\n      app.echo(value);\n    }\n  });\n}<\/pre>\n
    envoy.yaml\uff1a<\/strong><\/p>\n
    access_log_path: \/tmp\/admin_access.log\n  address:\n    socket_address: { address: 0.0.0.0, port_value: 9901 }\n\nstatic_resources:\n  listeners:\n  - name: listener_0\n    address:\n      socket_address: { address: 0.0.0.0, port_value: 8080 }\n    filter_chains:\n    - filters:\n      - name: envoy.filters.network.http_connection_manager\n        typed_config:\n          \"@type\": type.googleapis.com\/envoy.extensions.filters.network.http_connection_manager.v3.httpconnectionmanager\n          codec_type: auto\n          stat_prefix: ingress_http\n          route_config:\n            name: local_route\n            virtual_hosts:\n            - name: local_service\n              domains: [\"*\"]\n              routes:\n              - match: { prefix: \"\/\" }\n                route:\n                  cluster: echo_service\n                  timeout: 0s\n                  max_stream_duration:\n                    grpc_timeout_header_max: 0s\n              cors:\n                allow_origin_string_match:\n                - prefix: \"*\"\n                allow_methods: get, put, delete, post, options\n                allow_headers: keep-alive,user-agent,cache-control,content-type,content-transfer-encoding,custom-header-1,x-accept-content-transfer-encoding,x-accept-response-streaming,x-user-agent,x-grpc-web,grpc-timeout\n                max_age: \"1728000\"\n                expose_headers: custom-header-1,grpc-status,grpc-message\n          http_filters:\n          - name: envoy.filters.http.grpc_web\n          - name: envoy.filters.http.cors\n          - name: envoy.filters.http.router\n  clusters:\n  - name: echo_service\n    connect_timeout: 0.25s\n    type: logical_dns\n    http2_protocol_options: {}\n    lb_policy: round_robin\n    load_assignment:\n      cluster_name: cluster_0\n      endpoints:\n        - lb_endpoints:\n            - endpoint:\n                address:\n                  socket_address:\n                    address: app\n                    port_value: 50051<\/pre>\n
    grpc_go_docker_file\uff1a<\/strong><\/p>\n
    # install git.\n# git is required for fetching the dependencies.\nrun apk update && apk add --no-cache git\nworkdir \/app\ncopy go.mod go.sum .\/\nrun go mod download\ncopy . .\nrun cgo_enabled=0 goos=linux go build -a -installsuffix cgo -o main .\n\n# start a new stage from scratch\nfrom alpine:latest\nrun apk --no-cache add ca-certificates\n\nworkdir \/root\/\n\n# copy the pre-built binary file from the previous stage. observe we also copied the .env file\ncopy --from=builder \/app\/main .\n# expose port 50051 to the outside world\nexpose 50051\n\ncmd [\".\/main\"]<\/pre>\n
    envoy_docker\uff1a<\/strong><\/p>\n
    COPY envoy.yaml \/etc\/envoy\/envoy.yaml\n\nCMD \/usr\/local\/bin\/envoy -c \/etc\/envoy\/envoy.yaml -l trace --log-path \/tmp\/envoy_info.log<\/pre>\n
    \u6211\u5df2\u7ecf\u5361\u4e86\u4e24\u5929\u591a\u4e86\uff0c\u8bf7\u5e2e\u5e2e\u6211\u3002\u63d0\u524d\u81f4\u8c22<\/p>\n
     <\/p>\n
    \u6b63\u786e\u7b54\u6848<\/h2>\n
     <\/p>\n
    \u8c22\u8c22\u5927\u5bb6\u7684\u56de\u590d\u3002<\/p>\n
    \u6211\u4f7f\u7528 ec2 \u5b9e\u4f8b\u7684 ip \u4fee\u590d\u4e86\u6b64\u95ee\u9898\u3002<\/p>\n
    clusters:\n  - name: echo_service\n    connect_timeout: 0.25s\n    type: logical_dns\n    http2_protocol_options: {}\n    lb_policy: round_robin\n    load_assignment:\n      cluster_name: cluster_0\n      endpoints:\n        - lb_endpoints:\n            - endpoint:\n                address:\n                  socket_address:\n                    address: app\n                    port_value: 50051\n<\/pre>\n
    \u6211\u4f7f\u7528\u4e86 ec2 \u5b9e\u4f8b\u7684 ip \u548c\u5bb9\u5668\u7aef\u53e3\uff0c\u800c\u4e0d\u662f envoy.yaml \u4e2d\u7684\u5bb9\u5668\u201c\u5730\u5740\uff1aapp\u201d\uff08app \u662f\u5bb9\u5668\u540d\u79f0\uff09\uff0c\u73b0\u5728 envoy \u6b63\u5728\u5c06\u8bf7\u6c42\u8f6c\u53d1\u5230\u670d\u52a1\u5668\u3002<\/p>\n
    \u672c\u7bc7\u5173\u4e8e\u300a\u5982\u4f55\u4f7f\u7528 Envoy \u548c Grpc_web \u8fde\u63a5 go grpc \u670d\u52a1\u5668\u4e0e dart grpc \u5ba2\u6237\u7aef\u300b\u7684\u4ecb\u7ecd\u5c31\u5230\u6b64\u7ed3\u675f\u5566\uff0c\u4f46\u662f\u5b66\u65e0\u6b62\u5883\uff0c\u60f3\u8981\u4e86\u89e3\u5b66\u4e60\u66f4\u591a\u5173\u4e8eGolang\u7684\u76f8\u5173\u77e5\u8bc6\uff0c\u8bf7\u5173\u6ce8\u7c73\u4e91\u516c\u4f17\u53f7\uff01<\/p>\n","protected":false},"excerpt":{"rendered":"
    \u5f53\u524d\u4f4d\u7f6e\uff1a > > > > \u5982\u4f55\u4f7f\u7528 Envoy \u548c Grpc_web \u8fde\u63a5 go grpc \u670d\u52a1\u5668\u4e0e dart grpc \u5ba2\u6237\u7aef \u5982\u4f55\u4f7f\u7528 Envoy \u548c Grpc_web \u8fde\u63a5 go grpc \u670d\u52a1\u5668\u4e0e dart grpc \u5ba2\u6237\u7aef \u6765\u6e90\uff1astackoverflow 2024-04-28 09:48:34 0\u6d4f\u89c8 \u6536\u85cf \u73cd\u60dc\u65f6\u95f4\uff0c\u52e4\u594b\u5b66\u4e60\uff01\u4eca\u5929\u7ed9\u5927\u5bb6\u5e26\u6765\u300a\u5982\u4f55\u4f7f\u7528 Envoy \u548c Grpc_web \u8fde\u63a5 go grpc \u670d\u52a1\u5668\u4e0e dart grpc \u5ba2\u6237\u7aef\u300b\uff0c\u6b63\u6587\u5185\u5bb9\u4e3b\u8981\u6d89\u53ca\u5230\u7b49\u7b49\uff0c\u5982\u679c\u4f60\u6b63\u5728\u5b66\u4e60Golang\uff0c\u6216\u8005\u662f\u5bf9Golang\u6709\u7591\u95ee\uff0c\u6b22\u8fce\u5927\u5bb6\u5173\u6ce8\u6211\uff01\u540e\u9762\u6211\u4f1a\u6301\u7eed\u66f4\u65b0\u76f8\u5173\u5185\u5bb9\u7684\uff0c\u5e0c\u671b\u90fd\u80fd\u5e2e\u5230\u6b63\u5728\u5b66\u4e60\u7684\u5927\u5bb6\uff01 \u95ee\u9898\u5185\u5bb9 \u6211\u662f grpc_web \u548c envoy \u7684\u65b0\u624b\u3002 \u8bf7\u5e2e\u6211\u8bbe\u7f6e\u4ee5\u4e0b\u5185\u5bb9\uff0c grpc_go \u670d\u52a1\u5668\u4f5c\u4e3a docker \u5bb9\u5668\u5728 ec2 […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[17],"tags":[],"class_list":["post-42992","post","type-post","status-publish","format-standard","hentry","category-docker"],"_links":{"self":[{"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/posts\/42992","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/comments?post=42992"}],"version-history":[{"count":0,"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/posts\/42992\/revisions"}],"wp:attachment":[{"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/media?parent=42992"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/categories?post=42992"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/fwq.ai\/blog\/wp-json\/wp\/v2\/tags?post=42992"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}