(摘) golang rpc

RPC Remote Procedure Call 远程过程调用。即客户端最简化，把实现过程放到服务端上供调用。最直接的作用就是微服务。虽然一般的公司根本不需要它。

通信过程

1. Client以本地调用的方式发起调用；
2. Client stub收到调用后负责将被调用的方法名、参数等打包编码成特定格式成网络传输的消息体；
3. Client stub将消息体通过网络发送给服务端；
4. Server stub收到通过网络接收到消息后按照相应格式进行拆包解码，获取方法名和参数；
5. Server stub根据方法名和参数进行本地调用；
6. 被调用者（Server）本地调用执行后将结果返回给Server stub；
7. Server stub将返回值打包编码成消息；
8. 通过网络发送给Client；
9. Client stub收到消息后，进行拆包解码，返回给Client；
10. Client得到本次RPC调用的最终结果.

代码

服务端

package main

import (
	"log"
	"net"
	"net/rpc"
)

func main() {
	rpc.RegisterName("HelloService", new(HelloService))  // 注册服务对象
	listener, err := net.Listen("tcp", ":9999")
	if err != nil {
		log.Fatal("ListenTCP error:", err)
	}
	rpc.Accept(listener)
}

type HelloService struct{}

func (p *HelloService) Hello(request string, reply *string) error {
	*reply = "hello:" + request
	log.Println("got req", request)
	return nil
}

客户端

package main

import (
	"fmt"
	"log"
	"net/rpc"
)

func main() {
	client, err := rpc.Dial("tcp", "localhost:9999")
	if err != nil {
		log.Fatal("dialing:", err)
	}

	var reply string
        // 采用同步调用的方式
	err = client.Call("HelloService.Hello", "hello", &reply)
	if err != nil {
		log.Fatal(err)
	}

	fmt.Println(reply)
}

另一对

服务端

package main

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)
}

客户端

package main

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)
}

看起来它并没有任何的认证/授权机制。
除此之外，比如说我的需求：服务端提供并不断增加用户自测量表，客户端能获取并使用。