Golang实现RPC远程调用

 服务端，server.go ：

import (
	"math"
	"net"
	"net/http"
	"net/rpc"
)

type MathUtil struct {
}

//该方法向外暴露，提供计算圆形面积的服务
func (mu *MathUtil) CalculateCireArea(request float32, response *float32) error {
	*response = math.Pi * request * request
	return nil
}

func main() {
	// 初始化指针数据类型
	mathUtil := new(MathUtil)
	// 调用net/rpc包的功能将服务对象进行注册
	err := rpc.Register(mathUtil)
	if err != nil {
		panic(err.Error())
	}
	// 通过该函数把mathUtil中提供的服务注册到HTTP服务上，方便调用者可以利用http的方式进行数据传递
	rpc.HandleHTTP()
	// 在特定的接口上进行监听
	listen, err := net.Listen("tcp", ":8081")
	if err != nil {
		panic(err.Error())
	}
	http.Serve(listen, nil)
}

客户端，client.go :

import (
	"fmt"
	"net/rpc"
)

func main() {
	client, err := rpc.DialHTTP("tcp", "localhost:8081")
	if err != nil {
		panic(err.Error())
	}
	var request float32
	request = 10
	var response *float32
	// 同步的请求调用
	// err = client.Call("MathUtil.CalculateCireArea", request, &response)
	// if err != nil {
	// 	panic(err.Error())
	// }
	// fmt.Println(*response)

	// 异步的请求调用
	syncCall := client.Go("MathUtil.CalculateCireArea", request, &response, nil) //第四个参数为通道，Done:nil
	replayDone := <-syncCall.Done                                                //通过通道来感知异步调用是否结束，当Done有值才可以读取，继续执行下面的代码；否则一直阻塞状态
	fmt.Println(replayDone)
	fmt.Println(*response)
}