golang使用net/rpc库实现rpc

package main
 
import (
	"errors"
	"fmt"
	"log"
	"net"
	"net/http"
	"net/rpc"
	"os"
)
 
// 运算结构体
type Arith struct {
}
 
// 运算请求结构体
type ArithRequest struct {
	A int
	B int
}
 
// 运算响应结构体
type ArithResponse struct {
	Pro int  //product 表示乘积
	Quo int  //quotient 表示商
	Rem int  //remaind 表示余数
}
 
/*
	运算结构体的乘法运算方法
	第一个参数只需要拿到其里面的值只需要传一个结构体即可，
	第二个参数需要将运算结果存到其里面所以需要传地址
*/
func (this *Arith) Multiply(req ArithRequest, res *ArithResponse) error {
	res.Pro = req.A * req.B
	return nil
}
 
/*
	运算结构体的除法运算方法 
	第一个参数只需要拿到其里面的值只需要传一个结构体即可，
	第二个参数需要将运算结果存到其里面所以需要传地址
*/ 
func (this *Arith) Divide(req ArithRequest, res *ArithResponse) error {
	if req.B == 0 {  //除法为0，运算不合法
		return errors.New("divide by zero")
	}
	res.Quo = req.A / req.B
	res.Rem = req.A % req.B
	return nil
}
func main() {
	rpc.Register(new(Arith)) //注册rpc服务
	rpc.HandleHTTP()         //采用http作为rpc的载体
 
	lis, err := net.Listen("tcp", "127.0.0.1:8090") //Listen是block(阻塞的)
	if err != nil {
		log.Fatalln("fatal error:", err)
	}
	fmt.Fprintf(os.Stdout, "%s", "start connection")
	http.Serve(lis, nil) //net.Listen是阻塞的，需要通过这里进行启动
}

package main
 
import (
	"fmt"
	"log"
	"net/rpc"
)
 
// 算数运算请求结构体
type ArithRequest struct {
	A int
	B int
}
 
// 算数运算响应结构体
type ArithResponse struct {
	Pro int  //product 乘积
	Quo int  //quotient 商
	Rem int  //remain 余数
}
 
func main() {
	//通过网络实现rpc远程进程调用
	conn, err := rpc.DialHTTP("tcp", "127.0.0.1:8090") 
	if err != nil {
		log.Fatalln("dailing error", err)
	}
 
	req := ArithRequest{9, 2}  //请求结构体
	var res ArithResponse    //响应结构体，用于存储运算结果
 
	//实现rpc之后，通过Call方法在客户端调用服务端里面算数运算结构体的乘法运算方法
	err = conn.Call("Arith.Multiply", req, &res)
	if err != nil {
		log.Fatalln("arith error", err)
	}
	fmt.Printf("%d * %d = %d\n", req.A, req.B, res.Pro)
 
	//实现rpc之后，通过Call方法在客户端调用服务端里面算数运算结构体的除法运算方法
	err = conn.Call("Arith.Divide", req, &res)
	if err != nil {
		log.Fatalln("arith error", err)
	}
	fmt.Printf("%d / %d, quo is %d, rem is %d\n", req.A, req.B, res.Quo, res.Rem)
}

go mod init pro01  //pro01表示项目名称