Kitex Server SDK化

Server SDK化

SDK化（invoker）允許用戶(hù)將 Kitex server 當(dāng)作一個(gè)本地 SDK 調(diào)用。

調(diào)用通過(guò) ?message ?完成，初始化 ?message ?需要 ?local ?和 ?remote ?兩個(gè) ?net.Addr? ，分別表示本地地址和遠(yuǎn)端（客戶(hù)端）地址（此處的地址主要用于日志監(jiān)控），初始化后通過(guò) ?SetRequestBytes(buf []byte) error? 設(shè)置請(qǐng)求的二進(jìn)制數(shù)據(jù)。最后調(diào)用 ?invoker ?的 ?Call ?方法即可完成調(diào)用。調(diào)用完成后可通過(guò) ?message ?的 ?GetResponseBytes() ([]byte, error)? 獲取響應(yīng)的二進(jìn)制數(shù)據(jù)。

import (
		...
    "github.com/cloudwego/kitex/sdk/message"
  	...
)

func main() {
    var reqPayload, respPayload []byte
    var local, remote net.Addr
    ...
    // init local/remote
    ...
    ivk := echo.NewInvoker(new(EchoImpl))
    msg := message.NewMessage(local, remote)
    // 裝載payload
    msg.SetRequestBytes(reqPayload)
    // 發(fā)起調(diào)用
    err := ivk.Call(msg)
    if err != nil {
        ...
    }
    respPayload, err = msg.GetResponseBytes()
    if err != nil {
        ...
    }
}