摘要： 上一篇帖子go微服務框架go-micro深度學習(三) Registry服務的註冊和發現詳細解釋了go-micro是如何做服務註冊和發現在，服務端註冊server信息，client獲取server的地址信息，就可以和服務建立連接，然後就可以進行通信了。

上一篇帖子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
}

他的實現方式是封裝request，然後調用服務方法。這個request 是非常重要的：

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,
 }
}

這個方法返回一個rpcRequest裏面包含了詳細的調用信息，servicec：服務名，method和endpoint目前是一樣的是方法名這裏是Say.Hello，contentType是protobuf，body 是具體的信息，也要要進行編碼的內容，使用protobuf進行編碼，然後會把這些信息放到一個http.Request裏，再從Register或者從緩存獲取服務器信息，連接服務器，發送數據。

簡單流程圖如下

client：封裝參數-> 編碼數據->連接服務->發送數據->接收返回數據，並解碼。

service: 接收數據->解碼數據，找到相應的實例和方法，利用反射調用具體方法->編碼返數據->發送給客戶端。

服務端處理請求

當服務端監接收到數據後，從http的Request裏的Header中讀取到相應的信息：編碼方式，endpoint，請求的數據，由路由器進行對比和匹配找到保存的反射信息，利用反射把請求的數據根據相應的編碼方式進行解碼，再利用反射調用具體的方法，處理完把返回數據進行編碼，組織一個http.Response傳輸給用戶，客戶端接收到數據後進行解碼讀取數據。 rpc_router.go裏的call方法就是具體的調用過程方法，有時間大家可以讀一下。

作為一個開發者，有一個學習的氛圍跟一個交流圈子特別重要這是一個我的QQ群架構華山論劍：836442475，不管你是小白還是大牛歡迎入駐 ，分享BAT,阿裏面試題、面試經驗，討論技術， 大家一起交流學習成長！

go微服務框架go-micro深度學習 rpc方法調用過程詳解