关于golang:Go-语言实现-RPC-调用

情谊提醒：此篇文章大概须要浏览 6 分钟 38 秒，不足之处请多指教，感激你的浏览。订阅本站

RPC

在分布式计算 ，近程过程调用（英语：Remote Procedure Call，缩写为 RPC）是一个计算机通信协议。该协定容许运行于一台计算机的程序调用另一个地址空间（通常为一个凋谢网络的一台计算机）的子程序，而程序员就像调用本地程序一样，无需额定地为这个交互作用编程（无需关注细节）。RPC 是一种服务器 - 客户端（Client/Server）模式，经典实现是一个通过 发送申请 - 承受回应 进行信息交互的零碎。

wiki 维基百科

在这里援用一下维基百科对于 RPC 的解释，能够针对与 HTTP 协定来比拟剖析，RPC 更适宜于公司中大、中型我的项目分布式调用场景。

调用流程

1. 客户端调用客户端 stub（client stub）。这个调用是在本地，并将调用参数 push 到栈（stack）中。
2. 客户端 stub（client stub）将这些参数包装，并通过零碎调用发送到服务端机器。打包的过程叫 marshalling。（常见形式：XML、JSON、二进制编码）
3. 客户端本地操作系统发送信息至服务器。（可通过自定义 TCP 协定或 HTTP 传输）
4. 服务器零碎将信息传送至服务端 stub（server stub）。
5. 服务端 stub（server stub）解析信息。该过程叫 unmarshalling。
6. 服务端 stub（server stub）调用程序，并通过相似的形式返回给客户端。

C/S 架构调用

RPC 与 HTTP 区别

RPC 调用实现的形式是和 HTTP 有殊途同归之处的，然而对于 RPC 与 HTTP 在 申请 / 响应中还是存在着差异的：

1. HTTP 与 RPC 协定在实现上是不同的，大家都理解到 HTTP 原理就是 客户端申请服务端，服务端去响应并返回后果，然而 RPC 协定设计的时候采纳的形式就是服务端给客户端提供 TCP 长连贯服务，Client 端去调用 Server 提供的接口，实现特定的性能；
2. RPC 能够同时提供同步调用及异步调用，而 HTTP 提供的形式就是同步调用，客户端会期待并承受服务端的申请解决的后果；
3. 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 调用的区别