RPC Remote Procedure Call 远程过程调用。即客户端最简化,把实现过程放到服务端上供调用。最直接的作用就是微服务。虽然一般的公司根本不需要它。
通信过程
- Client以本地调用的方式发起调用;
- Client stub收到调用后负责将被调用的方法名、参数等打包编码成特定格式成网络传输的消息体;
- Client stub将消息体通过网络发送给服务端;
- Server stub收到通过网络接收到消息后按照相应格式进行拆包解码,获取方法名和参数;
- Server stub根据方法名和参数进行本地调用;
- 被调用者(Server)本地调用执行后将结果返回给Server stub;
- Server stub将返回值打包编码成消息;
- 通过网络发送给Client;
- Client stub收到消息后,进行拆包解码,返回给Client;
- 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)
}
看起来它并没有任何的认证/授权机制。
除此之外,比如说我的需求:服务端提供并不断增加用户自测量表,客户端能获取并使用。