rpc-remote procedure call demo

RPC:Remote Procedure Call

rpc对函数的要求：
1.字母大写，即要求是public
2.含有两个可导出类型的参数,返回给客户端的参数必须是指针类型
3.函数必须有一个返回值 error

server demo:

package main

import (
	"errors"
	"fmt"
	"net/http"
	"net/rpc"
)

type Args struct {
    
	A, B int
}

type Query struct {
    
	X, Y int
}

type Last int

func (t *Last) Multiply(args Args, reply *int) error {
    
	*reply = args.A * args.B
	fmt.Println(*reply, "Multiply exec")
	if *reply == 0 {
    
		return fmt.Errorf("%v中存在零值", args)
	}
	return nil
}

func (t *Last) Divide(args Args, query *Query) error {
    
	if args.B == 0 {
    
		return errors.New("分子args.B = 0")
	}
	query.X = args.A / args.B
	query.Y = args.A % args.B

	fmt.Println(*query, "Divide exec")
	return nil
}

func main() {
    
	La := new(Last)
	fmt.Println("la", La)

	// 类型注册
	// Register在DefaultServer中发布接接收类型的方法。
	rpc.Register(La)

	// HandleHTTP在DefaultRPCPath上为RPC消息向DefaultServer注册了一个HTTP处理器，
	// 在DefaultDebugPath上注册了一个调试处理器。
	// 仍然需要调用http.Serve()
	rpc.HandleHTTP() //设定http类型

	err := http.ListenAndServe("127.0.0.1:8080", nil)
	defer func() {
    
		err := recover()
		if err != nil {
    
			fmt.Println("panic() happend,err:", err)
		}
	}()

	if err != nil {
    
		panic(err)
	}
}

client demo：

package main

import (
	"fmt"
	"net/rpc"
)

type Args struct {
    
	A, B int
}

type Query struct {
    
	X, Y int
}

func main() {
    
	serverIp := "127.0.0.1:8080"
	client, err := rpc.DialHTTP("tcp", serverIp)
	if err != nil {
    
		fmt.Println(err)
	}

	i1 := 12
	i2 := 13
	args := Args{
    i1, i2}
	var reply int
	err = client.Call("Last.Multiply", &args, &reply)

	if err != nil {
    
		fmt.Println(err)
	}

	fmt.Println(args.A, "*", args.B, "=", reply)

	var query Query
	err = client.Call("Last.Divide", args, &query)
	if err != nil {
    
		fmt.Println(err)
	}
	fmt.Println(args.A, "/", args.B, "=", query.X)
	fmt.Println(args.A, "%", args.B, "=", query.Y)

}