友情提示:此篇文章大约需要阅读 6分钟37秒,不足之处请多指教,感谢你的阅读。
在分布式计算,远程过程调用(英语:Remote Procedure Call,缩写为 RPC)是一个计算机通信协议。该协议允许运行于一台计算机的程序调用另一个地址空间(通常为一个开放网络的一台计算机)的子程序,而程序员就像调用本地程序一样,无需额外地为这个交互作用编程(无需关注细节)。RPC 是一种服务器-客户端( Client/Server )模式,经典实现是一个通过 发送请求-接受回应 进行信息交互的系统。 wiki 维基百科
在这里引用一下维基百科对于 RPC 的解释, 可以针对与 HTTP 协议来比较分析,RPC 更适合于公司中大、中型项目分布式调用场景。
C/S 架构调用
RPC 调用实现的方式是和 HTTP 有异曲同工之处的,但是对于 RPC 与 HTTP 在 请求 / 响应中还是存在着差别的:
当然 RPC 也有缺点,每一个 RPC 服务都需要单独搭建,一旦服务出错或者更为严重的不提供支持,作为客户端的就会出现服务不可用,这对系统稳定性及可持续提供支持要求比较高,当然在设计过程中,这样也加大了对系统调试的难度,也就是说这种设计要求 RPC 服务的稳定性及正确性要求是比较大的。
package main
import (
"demo/common"
"fmt"
"net/rpc"
)
func main() {
var args = common.Args{A: 32, B: 14}
var result = common.Result{}
var client, err = rpc.DialHTTP("tcp", "127.0.0.1:9090")
if err != nil {
fmt.Printf("connect rpc server failed, err:%v", err)
}
err = client.Call("MathService.Divide", args, &result)
if err != nil {
fmt.Printf("call math service failed, err:%v", err)
}
fmt.Printf("call RPC server success, result:%f", result.Value)
}
package main
import (
"demo/common"
"fmt"
"net/http"
"net/rpc"
)
func main() {
var ms = new(common.MathService)
// 注册 RPC 服务
err := rpc.Register(ms)
if err != nil {
fmt.Printf("rpc server register faild, err:%s", err)
}
// 将 RPC 服务绑定到 HTTP 服务中去
rpc.HandleHTTP()
fmt.Printf("server start ....")
err = http.ListenAndServe(":9090", nil)
if err != nil {
fmt.Printf("listen and server is failed, err:%v\n", err)
}
fmt.Printf("server stop ....")
}
package common
import "errors"
type Args struct {
A, B float32
}
type Result struct {
Value float32
}
type MathService struct {}
func (s *MathService) Add (args *Args, result *Result) error{
result.Value = args.A + args.B
return nil
}
func (s *MathService) Divide(args *Args, result *Result) error{
if args.B == 0 {
return errors.New("arge.B is 0")
}
result.Value = args.A / args.B
return nil
}