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

      上一篇帖子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方法就是具體的調用過程方法，有時間大家可以讀一下。