golang rpc的两种调用方法

golang rpc的两种调用方法

golang的rpc有两种方法进行调用，一种是rpc例子中给的：package mainimport ( "net/rpc" "net/ "log" "net" "time")type Args struct { A, B int}type Arith intfunc (t *Arith) Multiply(args *Args, reply *([]string)) error { *reply = append(*reply, "test") return nil}func main() { arith := new(Arith) rpc.Register(arith) rpc.HandleHTTP() l, e := net.Listen("tcp", ":1234") if e != nil { log.Fatal("listen error:", e) } go nil) time.Sleep(5 * time.Second) client, err := rpc.DialHTTP("tcp", "127.0.0.1" + ":1234") if err != nil { log.Fatal("dialing:", err) } args := &Args{7,8} reply := make([]string, 10) err = client.Call("Arith.Multiply", args, &reply) if err != nil { log.Fatal("arith error:", err) } log.Println(reply)}另一种是使用NewServer这种是当rpc已经注册的时候就要使用了另外一种了。即一个server只能在DefaultRPC中注册一种类型。当Server使用rpc.NewServer的时候，client也需要进行下改动了package mainimport ( "net/rpc" //"net/ "log" "net" "time")type Args struct { A, B int}type Arith intfunc (t *Arith) Multiply(args *Args, reply *([]string)) error { *reply = append(*reply, "test") return nil}func main() { newServer := rpc.NewServer() newServer.Register(new(Arith)) l, e := net.Listen("tcp", "127.0.0.1:1234") // any available address if e != nil { log.Fatalf("net.Listen tcp :0: %v", e) } go newServer.Accept(l) newServer.HandleHTTP("/foo", "/bar") time.Sleep(2 * time.Second) address, err := net.ResolveTCPAddr("tcp", "127.0.0.1:1234") if err != nil { panic(err) } conn, _ := net.DialTCP("tcp", nil, address) defer conn.Close() client := rpc.NewClient(conn) defer client.Close() args := &Args{7,8} reply := make([]string, 10) err = client.Call("Arith.Multiply", args, &reply) if err != nil { log.Fatal("arith error:", err) } log.Println(reply)}第二个例子中的}1第二个例子中的1newServer.HandleHTTP("/foo", "/bar")1可以任意设置，第一个例子其实是设置了默认的两个11这里也顺便将reply作为[]slice的例子给演示了下

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。