Go rpc调用的返回值

落日映苍穹つ 2022-05-26 11:10 225阅读 0赞

Go 语言RPC定义格式如下：

> func (t \*T) MethodName(argType T1, replyType \*T2) error

第一个参数是接收的参数，第二个参数是返回给客户端的参数，第二个参数必  
须是指针类型的

如果Server端RPC函数返回错误，即error不为nil，第二个参数不会返回任何信息。

例子如下。

**server端**

package main
    
    import (
        "fmt"
        "net"
        "net/rpc"
        "net/rpc/jsonrpc"
    )
    
    type Counter struct {
        Sum int
    }
    
    func (this *Counter) Add(i int, r *int) error {
    
        if i < 0 {
            *r = -1
            return fmt.Errorf("data format incorrect")
        }
    
    
        this.Sum += i
        *r = this.Sum
        fmt.Printf("i: %v\n", i)
        return nil
    }
    
    func NewJsonRpcSocketServer() {
    
        rpc.Register(new(Counter))
    
        l, err := net.Listen("tcp", ":3333")
        if err != nil {
            fmt.Printf("Listener tcp err: %s", err)
            return
        }
    
        for {
            fmt.Println("wating...")
            conn, err := l.Accept()
            if err != nil {
                fmt.Sprintf("accept connection err: %s\n", conn)
            }
            go jsonrpc.ServeConn(conn)
        }
    
    }
    
    func main() {
    
        NewJsonRpcSocketServer()
    }

server端对于参数小于0的情况，返回错误， 并把repoy设置为-1。

**client端**

package main
    
    import (
        "fmt"
        "net"
        "net/rpc/jsonrpc"
        "time"
    )
    
    
    func main() {
    
         NewJsonRpcSocketClient()
    }
    
    
    func NewJsonRpcSocketClient() {
    
        timeout := time.Second*30
        conn, err := net.DialTimeout("tcp", "127.0.0.1:3333", timeout)
        if err != nil {
            fmt.Printf("create client err:%s\n", err)
            return
        }
        defer conn.Close()
    
        client := jsonrpc.NewClient(conn)
        var reply int
        err = client.Call("Counter.Add", -10, &reply)
        if err != nil {
    
            fmt.Println("error:", err, "reply:", reply)
        return
        }
    
        fmt.Printf("reply: %d, err: %v\n", reply, err)
    
    }

client端传入参数小于0，此时client output:

> error: data format incorrect reply: 0

reply仍然是默认值，server端设置的信息没有返回给client。  
结果得到验证。