潍城区住房和城乡建设局网站,购物网站排名,济南12345官网,电子商务网站建设概括grpc-gateway
grpc-gateway 顾名思义是专门是grpc的网关。也是一个protobuf的编译器#xff0c;是一个proto的插件。 grpc-gateway就是将http请求处理后转发到对应grpc服务上。很多浏览器#xff0c;或者客户端开箱不支持grpc#xff0c;只支持传统的restful API。 grpc网关…grpc-gateway
grpc-gateway 顾名思义是专门是grpc的网关。也是一个protobuf的编译器是一个proto的插件。 grpc-gateway就是将http请求处理后转发到对应grpc服务上。很多浏览器或者客户端开箱不支持grpc只支持传统的restful API。 grpc网关而且也支持负载兼容不同版本。
官方文档
grpc-gateway
源码
架构 大致流程如下 写好服务的proto文件。代理grpc 根据proto文件生成反向代理服务代码 根据proto文件生成grpc服务存根 启动反向代理和grpc 客户端使用http json访问 或别的restful api形式
环境安装
protobuf
protobuf链接
下载对应环境的porotbuf。解压后bin路径配置环境变量
插件安装
博主 go 用的 1.19 windows预先安装好protobuf
go install github.com/grpc-ecosystem/grpc-gateway/v2/protoc-gen-grpc- gatewayv2.12.0
go install google.golang.org/protobuf/cmd/protoc-gen-gov1.28
go install google.golang.org/grpc/cmd/protoc-gen-go-grpcv1.2可以把对应GO_PATH bin下插件的二进制文件拷到对应go安装的bin目录下
grpc默认网关测试
proto文件
echo.proto
syntax proto3;
package echo;
option go_package echo/proto;message User{int64 id 1;string name 2;int32 age 3;string phone 4;Addr addr 5;
}
message Addr {string province 1;string city 2;string county 3;
}service Echo{rpc Get(User) returns (User) {}rpc AddOrUpdate(User) returns (User) {}rpc Delete(User) returns (User) {}
}生成grpc stub
# 生成message
protoc --proto_pathproto --go_outproto --go_optpathssource_relative proto/echo.proto
# 生成grpc service
protoc --proto_pathproto --go-grpc_outproto --go-grpc_optpathssource_relative proto/echo.proto生成默认网关
# 生成gateway protoc --proto_pathproto --grpc-gateway_outproto --grpc-gateway_opt logtostderrtrue --grpc-gateway_opt pathssource_relative --grpc-gateway_opt generate_unbound_methodstrue proto/echo.protogrpc服务器代码
server.go
package serverimport (contextecho/protofmt
)type echoServer struct {proto.UnimplementedEchoServer
}func NewServer() proto.EchoServer {return echoServer{}
}
func (s *echoServer) Get(ctx context.Context, in *proto.User) (*proto.User, error) {fmt.Printf(%v\n, in)return in, nil
}
func (s *echoServer) AddOrUpdate(ctx context.Context, in *proto.User) (*proto.User, error) {fmt.Printf(%v\n, in)return in, nil
}
func (s *echoServer) Delete(ctx context.Context, in *proto.User) (*proto.User, error) {fmt.Printf(%v\n, in)return in, nil
}gateway代码
这里直接用官网http代理的代码。需要修改端口和引用自己的grpc服务和网关package
gateway.go
package gatewayimport (contextflagnet/httpgithub.com/grpc-ecosystem/grpc-gateway/v2/runtimegoogle.golang.org/grpcgoogle.golang.org/grpc/credentials/insecure_ google.golang.org/grpc/grpcloggw echo/proto // Update
)var (// command-line options:// gRPC server endpointgrpcServerEndpoint flag.String(grpc-server-endpoint, localhost:50051, gRPC server endpoint)
)func Run() error {ctx : context.Background()ctx, cancel : context.WithCancel(ctx)defer cancel()// Register gRPC server endpoint// Note: Make sure the gRPC server is running properly and accessiblemux : runtime.NewServeMux()opts : []grpc.DialOption{grpc.WithTransportCredentials(insecure.NewCredentials())}// 注册对应grpc服务端点handlererr : gw.RegisterEchoHandlerFromEndpoint(ctx, mux, *grpcServerEndpoint, opts)if err ! nil {return err}// Start HTTP server (and proxy calls to gRPC server endpoint)return http.ListenAndServe(:8081, mux)
}
测试
main.go
package mainimport (contextecho/echo_server/gatewayecho/echo_server/serverecho/protofmtgoogle.golang.org/grpclognetosos/signaltime
)func main() {// 先启动grpc servicego func() {if err : run(); err ! nil {log.Fatal(err)}}()time.Sleep(time.Second * 2)//后启动gatewaygo func() {if err : gateway.Run(); err ! nil {log.Fatal(err)}}()ctx, stop : signal.NotifyContext(context.Background(), os.Interrupt, os.Kill)defer stop()-ctx.Done()
}func run() error {lis, err : net.Listen(tcp, :50051)if err ! nil {log.Fatal(err)}s : grpc.NewServer()userServiceServer : server.NewServer()proto.RegisterEchoServer(s, userServiceServer)fmt.Println(listening )return s.Serve(lis)
}默认路由
路由为proto文件中{包名}.{服务名}/{方法}。 gateway对外默认是post方法
PS D:\GIT\gorun\grpc-gateway-practice\echo Invoke-RestMethod -Uri http://10.5.81.57:8081/echo.Echo/Get -Method Postid : 0
name :
age : 0
phone :
addr :
用postman更方便些
总结 grpc-gateway 只是提供一个反向代理可以通过配置进行grpc版本兼容。 grpc-gateway对外提供restful API风格的http接口更好兼容各种客户端接入无需grpc客户端
