RPC（Remote Procedure Call Protocol）——是一种远程调用协议，它采用客户机/服务器模式。请求程序就是一个客户机，而服务提供程序就是一个服务器。首先，客户机调用进程发送一个有进程参数的调用信息到服务进程，然后等待应答信息。在服务器端，进程保持睡眠状态直到调用信息到达为止。当一个调用信息到达，服务器获得进程参数，计算结果，发送答复信息，然后等待下一个调用信息，最后，客户端调用进程接收答复信息，获得进程结果，然后调用执行继续进行。
RPC的调用过程
运行时,一次客户机对服务器的RPC调用,其内部操作大致有如下十步：
（1）调用客户端句柄；执行传送参数
（2）调用本地系统内核发送网络消息
（3）消息通过网络到远程主机
（4）服务器句柄得到消息并取得参数
（5）执行远程过程
（6）执行的过程将结果返回服务器句柄
（7）服务器句柄返回结果，调用远程系统内核
（8）消息通过网络传回本地主机
（9）客户句柄由内核接收消息
（10）客户接收句柄返回的数据
RPC的目标就是要2~8这些步骤都封装起来，让用户对这些细节透明。
在go中，一个对象中只有满足如下这些条件的方法，才能被 RPC 服务端设置为可供远程访问：
1） 必须是在对象外部可公开调用的方法（首字母大写）；
2） 必须有两个参数，且参数的类型都必须是包外部可以访问的类型或者是Go内建支持的类
型；
3） 第二个参数必须是一个指针；
4） 方法必须返回一个error类型的值。
总结为：func (t *T) MethodName(argType T1, replyType *T2) error
在上面这行代码中，类型T、T1 和 T2 默认会使用 Go 内置的 encoding/gob 包进行编码解码。
关于encoding/gob 包的内容，稍后我们将会对其进行介绍。
该方法（MethodName）的第一个参数表示由 RPC 客户端传入的参数，第二个参数表示要返
回给RPC客户端的结果，该方法最后返回一个 error 类型的值。
如果没有明确指定 RPC 传输过程中使用何种编码解码器，默认将使用 Go 标准库提供的
encoding/gob 包进行数据传输。net/rpc包下面还有json实现的rpc传输格式。
接下来贴一段go实现rpc的代码：
server端：
package main
import (
"errors"
"fmt"
"net"
"net/http"
"net/rpc"
)
type Person struct {
Name string
Sex string
Age int
}
func (p *Person) Hello(args Person, reply *Person) error {
reply.Name = "hello-" + args.Name
reply.Sex = "hello-" + args.Sex
reply.Age = args.Age * 2
return nil
}
func main() {
person := new(Person)
//注册服务对象并开启该RPC服务
rpc.Register(person)
rpc.HandleHTTP() //rpc.HandleHTTP函数把该服务注册到了HTTP协议上
//然后我们就可以利用http的方式来传递数据了（基于HTTP协议的RPC）
//如果我们采用基于TCP协议的RPC，则不用该函数
tcpAddr, err := net.ResolveTCPAddr("tcp", ":6060")
checkError(err)
listener, err := net.ListenTCP("tcp", tcpAddr)
checkError(err)
http.Serve(listener, nil)//http处理监听器
}
func checkError(err error) {
if err != nil {
fmt.Println("Fatal error", err.Error())
}
}
client端：
package main
import (
"fmt"
"log"
"net/rpc"
)
type Person struct {
Name string
Sex string
Age int
}
func main() {
//与RPC服务端建立连接
client, err := rpc.DialHTTP("tcp", ":6060")
if err != nil {
log.Fatal("dialing:", err)
}
//连接成功，RPC客户端调用服务端提供的方法
//同步调用程序顺序执行的方式
person1 := Person{
Name: "初级赛亚人",
Sex: "男",
Age: 117}
person2 := new(Person)
//同步调用rpc
client.Call("Person.Hello", person1, &person2)
fmt.Println("person2=", person2)
//异步rpc方式进行调用
person3 := new(Person)
divCall1 := client.Go("Person.Hello", person1, &person3, nil)
<-divCall1.Done //表示异步调用完成
fmt.Println("person3=", person3)
}
打印结果：
person2= &{hello-初级赛亚人 hello-男 234}
person3= &{hello-初级赛亚人 hello-男 234}
.
网友评论