共计 2280 个字符,预计需要花费 6 分钟才能阅读完成。
情谊提醒:此篇文章大概须要浏览 6 分钟 38 秒,不足之处请多指教,感激你的浏览。订阅本站
RPC
在分布式计算 ,近程过程调用(英语:Remote Procedure Call,缩写为 RPC)是一个计算机通信协议。该协定容许运行于一台计算机的程序调用另一个地址空间(通常为一个凋谢网络的一台计算机)的子程序,而程序员就像调用本地程序一样,无需额定地为这个交互作用编程(无需关注细节)。RPC 是一种服务器 - 客户端(Client/Server)模式,经典实现是一个通过 发送申请 - 承受回应 进行信息交互的零碎。
wiki 维基百科
在这里援用一下维基百科对于 RPC 的解释,能够针对与 HTTP 协定来比拟剖析,RPC 更适宜于公司中大、中型我的项目分布式调用场景。
调用流程
- 客户端调用客户端 stub(client stub)。这个调用是在本地,并将调用参数 push 到栈(stack)中。
- 客户端 stub(client stub)将这些参数包装,并通过零碎调用发送到服务端机器。打包的过程叫 marshalling。(常见形式:XML、JSON、二进制编码)
- 客户端本地操作系统发送信息至服务器。(可通过自定义 TCP 协定或 HTTP 传输)
- 服务器零碎将信息传送至服务端 stub(server stub)。
- 服务端 stub(server stub)解析信息。该过程叫 unmarshalling。
- 服务端 stub(server stub)调用程序,并通过相似的形式返回给客户端。
C/S 架构调用
RPC 与 HTTP 区别
RPC 调用实现的形式是和 HTTP 有殊途同归之处的,然而对于 RPC 与 HTTP 在 申请 / 响应中还是存在着差异的:
- HTTP 与 RPC 协定在实现上是不同的,大家都理解到 HTTP 原理就是 客户端申请服务端,服务端去响应并返回后果,然而 RPC 协定设计的时候采纳的形式就是服务端给客户端提供 TCP 长连贯服务,Client 端去调用 Server 提供的接口,实现特定的性能;
- RPC 能够同时提供同步调用及异步调用,而 HTTP 提供的形式就是同步调用,客户端会期待并承受服务端的申请解决的后果;
- RPC 服务设计能够进步代码编写过程中的解耦操作,进步代码的可移植性,每一个 服务能够设计成提供特定性能的小服务,客户端去调取近程的服务,而不必去关怀近程是怎么实现的。
RPC 应用领域
- 大型网站的外部子系统设计;
- 为零碎提供降级性能;
- 并发设计场景;
当然 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
}
参考文章
- 简述 RPC 原理实现 – 博客园
- Http 和 RPC 区别
- 近程过程调用 – 维基百科
- 直观解说–RPC 调用和 HTTP 调用的区别
正文完