上一篇帖子go微服務框架go-micro深度學習(三) Registry服務的注冊和發現詳細解釋了go-micro是如何做服務注冊和發現在,服務端注冊server信息,client獲取server的地址信息,就可以和服務建立連接,然后就可以進行通信了。這篇帖子詳細說一下,go-micro的通信協議、編碼,和具體服務方法的調用過程是如何實現的,文中的代碼還是我github上的例子: gomicrorpc
go-micro 支持很多通信協議:http、tcp、grpc等,支持的編碼方式也很多有json、protobuf、bytes、jsonrpc等。也可以根據自己的需要實現通信協議和編碼方式。go-micro 默認的通信協議是http,默認的編碼方式是protobuf,我就以默認的方式來分解他的具體實現。
服務的啟動
go-micro在啟動的時候會選擇默認通信協議http和protobuf編碼方式,但他是如何路由到具體方法的?在go-micro服務端啟動的時候我們需要注冊Handler,也就是我們具體實現結構體 ,如例子中注冊方法時,我們調用的RegisterSayHandler方法
// 注冊 Handler rpcapi.RegisterSayHandler(service.Server(), new(handler.Say))
這個方法內部的體實現主要是利用了反射的力量,注冊的對象是實現了rpc接口的方法,如我們的Say實現了SayHandler。go-micro默認的router會利用反射把Say對象的信息完全提取出來,解析出結構體內的方法及方法的參數,保存到一個map內-> map[結構體名稱][方法信息集合]
具體的實現在rpc_router.go里router的Handle(Handler)方法,組織完成后map的是下圖這樣,保存了很多反射信息,用以將來調用。
下面是這個方法的主要代碼,刪除了一些,很希望大家讀一下rpc_router.go里面的代碼,prepareMethod方法是具體利用反射提取信息的方法。
func (router *router) Handle(h Handler) error { router.mu.Lock() defer router.mu.Unlock() // .... rcvr := h.Handler() s := new(service) s.typ = reflect.TypeOf(rcvr) s.rcvr = reflect.ValueOf(rcvr) // check name // .... s.name = h.Name() s.method = make(map[string]*methodType) // Install the methods for m := 0; m < s.typ.NumMethod(); m++ { method := s.typ.Method(m) // prepareMethod會把所有解析的信息返回來 if mt := prepareMethod(method); mt != nil { s.method[method.Name] = mt } } // ..... // save handler router.serviceMap[s.name] = s return nil }
serviceMap里保存的就是反射后的信息,下圖是我用goland的debug得到的保存信息
路由信息處理完后,主要的工作就已經完成了,然后注冊服務並啟動服務,啟動的服務是一個http的服務,我們可以看一下http_transport.go里的代碼
服務的簡單流程圖如下 ,選擇通信協議和編碼方式->注冊服務方法->啟動服務並注冊服務信息
客戶端調用服務方法
客戶端在啟動的時候也要選擇默認的通信協議http,和protobuf編碼。客戶端在調用rpc方法的時候如:
rsp, err := client.Hello(context.Background(), &model.SayParam{Msg: "hello server"})
go-micro為我們自動生成的rpcapi.micro.go里我們可以看一上Hello的具體實現,沒有幾行代碼,但內部還是做了很多工作
func (c *sayService) Hello(ctx context.Context, in *model.SayParam, opts ...client.CallOption) (*model.SayResponse, error) { req := c.c.NewRequest(c.name, "Say.Hello", in) out := new(model.SayResponse) err := c.c.Call(ctx, req, out, opts...) if err != nil { return nil, err } return out, nil }
func newRequest(service, endpoint string, request interface{}, contentType string, reqOpts ...RequestOption) Request { var opts RequestOptions for _, o := range reqOpts { o(&opts) } // set the content-type specified if len(opts.ContentType) > 0 { contentType = opts.ContentType } return &rpcRequest{ service: service, method: endpoint, endpoint: endpoint, body: request, contentType: contentType, opts: opts, } }
簡單流程圖如下
client:封裝參數-> 編碼數據->連接服務->發送數據->接收返回數據,並解碼。
service: 接收數據->解碼數據,找到相應的實例和方法,利用反射調用具體方法->編碼返數據->發送給客戶端。
服務端處理請求
當服務端監接收到數據后,從http的Request里的Header中讀取到相應的信息:編碼方式,endpoint,請求的數據,由路由器進行對比和匹配找到保存的反射信息,利用反射把請求的數據根據相應的編碼方式進行解碼,再利用反射調用具體的方法,處理完把返回數據進行編碼,組織一個http.Response傳輸給用戶,客戶端接收到數據后進行解碼讀取數據。 rpc_router.go里的call方法就是具體的調用過程方法,有時間大家可以讀一下。