// 服务器代码 package main // rpc 服务 import ( "net/rpc" "net" "log" "net/http" ) type Name struct { MyName string } type Age struct { MyAge string } type My struct { Name string Age string } // 暴露api 接收一个Name指针结构 和一个指针字符串 返回一个错误信息 func (m *My) SetName (name *Name,s *string) error{ *s = name.MyName+"Set-Name" return nil } // 暴露api func (m *My) SetAge (age *Age,s *string) error{ *s = age.MyAge return nil } func main() { arith:= new(My) rpc.Register(arith) // 注册 rpc.HandleHTTP() // 初始化 l,e:=net.Listen("tcp",":8080") if e!=nil { log.Fatal("sevice error.") } // 启动服务 http.Serve(l,nil) }
客户端代码api
package main // rpc 客户端 import ( "net/rpc" "log" "fmt" ) type MName struct { MyName string } func main() { // 拨号连接服务 client,err:=rpc.DialHTTP("tcp","127.0.0.1:8080") if err!=nil { log.Fatal("client not find") } name:=&MName{"lyl"} // 建立服务须要的结构参数 var g string // 接收数据返回的类型 err = client.Call("My.SetName",name,&g) fmt.Println(g) // 输出返回值 }