package main
 
import (
	"errors"
	"fmt"
	"log"
	"net"
	"net/http"
	"net/rpc"
	"os"
)
 
// 運算結(jié)構(gòu)體
type Arith struct {
}
 
// 運算請求結(jié)構(gòu)體
type ArithRequest struct {
	A int
	B int
}
 
// 運算響應結(jié)構(gòu)體
type ArithResponse struct {
	Pro int  //product 表示乘積
	Quo int  //quotient 表示商
	Rem int  //remaind 表示余數(shù)
}
 
/*
	運算結(jié)構(gòu)體的乘法運算方法
	第一個參數(shù)只需要拿到其里面的值只需要傳一個結(jié)構(gòu)體即可，
	第二個參數(shù)需要將運算結(jié)果存到其里面所以需要傳地址
*/
func (this *Arith) Multiply(req ArithRequest, res *ArithResponse) error {
	res.Pro = req.A * req.B
	return nil
}
 
/*
	運算結(jié)構(gòu)體的除法運算方法 
	第一個參數(shù)只需要拿到其里面的值只需要傳一個結(jié)構(gòu)體即可，
	第二個參數(shù)需要將運算結(jié)果存到其里面所以需要傳地址
*/ 
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服務(wù)
	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"
)
 
// 算數(shù)運算請求結(jié)構(gòu)體
type ArithRequest struct {
	A int
	B int
}
 
// 算數(shù)運算響應結(jié)構(gòu)體
type ArithResponse struct {
	Pro int  //product 乘積
	Quo int  //quotient 商
	Rem int  //remain 余數(shù)
}
 
func main() {
	//通過網(wǎng)絡(luò)實現(xiàn)rpc遠程進程調(diào)用
	conn, err := rpc.DialHTTP("tcp", "127.0.0.1:8090") 
	if err != nil {
		log.Fatalln("dailing error", err)
	}
 
	req := ArithRequest{9, 2}  //請求結(jié)構(gòu)體
	var res ArithResponse    //響應結(jié)構(gòu)體，用于存儲運算結(jié)果
 
	//實現(xiàn)rpc之后，通過Call方法在客戶端調(diào)用服務(wù)端里面算數(shù)運算結(jié)構(gòu)體的乘法運算方法
	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)
 
	//實現(xiàn)rpc之后，通過Call方法在客戶端調(diào)用服務(wù)端里面算數(shù)運算結(jié)構(gòu)體的除法運算方法
	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表示項目名稱