golang两种调用rpc的方法
发布时间：2020-12-16 19:31:04 所属栏目：大数据 来源：网络整理
导读：本篇章节讲解golang两种调用rpc的方法。供大家参考研究具体如下： golang的rpc有两种方法进行调用，一种是rpc例子中给的： 复制代码 代码如下: package main import ( "net/rpc" "net/http" "log" "net" "time" ) type Args struct { A,B int } ty
|
本篇章节讲解golang两种调用rpc的方法。分享给大家供大家参考，具体如下： golang的rpc有两种方法进行调用，一种是rpc例子中给的： 复制代码 代码如下: package main
import ( "net/rpc" "net/http" "log" "net" "time" ) type Args struct { A,B int } type Arith int func (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 http.Serve(l,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 main
import ( "net/rpc" //"net/http" "log" "net" "time" ) type Args struct { A,"test") return nil } func main() { newServer := rpc.NewServer() newServer.Register(new(Arith)) l,"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,err) } log.Println(reply) } 第二个例子中的 复制代码 代码如下: newServer.HandleHTTP("/foo","/bar")
可以任意设置，第一个例子其实是设置了默认的两个 这里也顺便将reply作为[]slice的例子给演示了下 希望本文所述对大家Go语言程序设计有所帮助。 （编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |