微服务|GO-Grpc微服务开发六网关和http调用 golang|grpc

GO-Grpc微服务开发六网关和http调用

proto文件定义
将定义的proto编译为go文件
网关中注册服务
http请求

proto文件定义

syntax = "proto3"; package kibana; //引入google api实现http转rpc import "google/api/annotations.proto"; //service name is kibana service Kibana { //service method is write rpc Write(WriteRequest) returns (WriteResponse) { //定义http请求路由 option (google.api.http) = { //路由 post: "/v1/kibana/write" //参数为 request body body: "*" }; } }//writer request struct message WriteRequest { string tag = 1; string info = 2; string level = 3; }//writer response struct message WriteResponse { int32 code = 1; string message = 2; map data = https://www.it610.com/article/3; }

将定义的proto编译为go文件

//生成grpc文件 protoc --go_out=plugins=grpc:. kibana.proto //生成网关文件 //注意点：请先将google/api下载到/usr/local/include protoc -I/usr/local/include -I. -I$GOPATH/src -I$GOPATH/src/github.com/grpc-ecosystem/grpc-gateway/third_party/googleapis --grpc-gateway_out=logtostderr=true:. kibana.proto

网关中注册服务

package mainimport ( "github.com/golang/glog" "golang.org/x/net/context" "github.com/grpc-ecosystem/grpc-gateway/runtime" "google.golang.org/grpc" "net/http" //引入刚生产的文件包多个服务引入多个包 kibana "micro-srv/service/kibana/proto" "micro-srv/common" "fmt" )var services = map[string]string{ //这里加上我们的服务 "kibana": "50061", }func run() error { ctx := context.Background() ctx, cancel := context.WithCancel(ctx) defer cancel() mux := runtime.NewServeMux() base := common.Common{} //获取服务地址 server_host := base.GetVal("serveraddr") //注册http转grpc服务 registerServerHandle(ctx, mux, server_host) return http.ListenAndServe(":8080", mux) }//注册http转grpc服务 func registerServerHandle(ctx context.Context, mux *runtime.ServeMux, server_host string){ opts := []grpc.DialOption{grpc.WithInsecure()} var err error //注册服务 kibana 多个服务多次注册即可 err = kibana.RegisterKibanaHandlerFromEndpoint(ctx, mux, server_host + ":" + services["kibana"], opts) if err != nil { fmt.Printf("kibana http is fail: %s", err.Error()) } }func main() { defer glog.Flush() if err := run(); err != nil { glog.Fatal(err) } }

http请求

确保网关中已注册服务
确保网关和服务已运行

【微服务|GO-Grpc微服务开发六网关和http调用】curl

curl -H "Content-Type:application/json" -X POST --data '{"tag":"micro_test", "info":"hello", "level":"info"}' http://127.0.0.1:5061/v1/kibana/write

beego

url := "http://127.0.0.1:5061/v1/kibana/write" params := map[string]string{ "tag": "micro_test", "info": "hello", "level": "info", } req := httplib.Post(url) req.JSONBody(params) con, err := req.Bytes()

源码：go-grpc-getway