RPC原理图
- 客户端Stub: 客户端存根
- 服务端Stub: 服务端存根
RPC技术架构
服务端：server.go
package mainimport ("math""net""net/http""net/rpc"
)type MathUtil struct {
}// 该方法向外暴露：提供计算圆形面积的服务
func (mu *MathUtil) CalculateCircleArea(req float32, resp *float32) error {*resp = math.Pi * req * reqreturn nil
}func main() {// 1. 初始化指针数据类型MathUtil := new(MathUtil) // 初始化指针数据类型// 2.调用net/rpc包的功能将服务对象进行注册err := rpc.Register(MathUtil)if err != nil {panic(err.Error())}// 3.通过该函数把mathUtil中提供的服务注册到HTTP协议上，方便调用者可以利用http的方法进行数据传输rpc.HandleHTTP()// 4.在特定的端口进行监听listen, err := net.Listen("tcp", ":8081")if err != nil {panic(err.Error())}http.Serve(listen, nil)
}
客户端：client.go
package mainimport ("fmt""net/rpc"
)// 客户端逻辑
func main() {client, err := rpc.DialHTTP("tcp", "localhost:8081")if err != nil {panic(err.Error())}var req float32req = 3// 同步调用方式// var resp *float32// err = client.Call("MathUtil.CalculateCircleArea", req, &resp)// if err != nil {// panic(err.Error())// }// fmt.Println("resp: ", *resp)// 异步调用方式var respSync *float32syncCall := client.Go("MathUtil.CalculateCircleArea", req, &respSync, nil)replayDone := <-syncCall.Donefmt.Println("replayDone: ", replayDone)fmt.Println("respSync: ", *respSync)
}
