GRPC教程 1- RPC原理

视频地址:https://www.bilibili.com/video/BV1ov4y1p75S/?vd_source=58c0cd7db768f7e1b79c590a4672562c

本篇文章介绍一下RPC的概念以及在Go语言如何使用标准库中的RPC.

RPC是全称叫Remote Procedure Call,远程过程调用,它允许像调用本地服务一样去调用远程服务,相对应的就是本地调用。

本地调用的例子

package main

import (
    "fmt"
    "os"
    "time"
)

type Args struct {
    A int
    B int
}

func Add(args *Args) int {
    return args.A + args.B 
}

func main() {
    fmt.Println(os.Getpid())
    fmt.Println(Add(&Args{10, 20}))
    time.Sleep(100 * time.Second)
}

可以看到结果是

107088
30

那么与此相对应的RPC调用即,不是同一进程下的服务调用。

// server.go
package main

import (
    "log"
    "net"
    "net/http"
    "net/rpc"
)

type Args struct {
    A int
    B int
}

type ServiceA struct{}

func (s ServiceA) Add(a *Args, reply *int) error {
    *reply = a.A + a.B
    return nil
}

type ServiceB struct{}

func (s ServiceB) Sub(a *Args, reply *int) error {
    *reply = a.A - a.B
    return nil
}

func main() {
    serviceA := new(ServiceA)
    serviceB := new(ServiceB)
    rpc.Register(serviceA)
    rpc.Register(serviceB)
    rpc.HandleHTTP()
    l, err := net.Listen("tcp", ":7890")
    if err != nil {
        log.Fatal("listen error:", err)
    }
    http.Serve(l, nil)
}
// client.go
package main

import (
    "fmt"
    "log"
    "net/rpc"
)

type Args struct {
    A, B int
}

func main() {
    // 建立HTTP连接
    client, err := rpc.DialHTTP("tcp", "127.0.0.1:7890")
    if err != nil {
        log.Fatal("dialing:", err)
    }
    defer client.Close()

    // 同步调用
    args := &Args{10, 20}
    var reply int
    err = client.Call("ServiceA.Add", args, &reply)
    if err != nil {
        log.Fatal("ServiceA.Add error:", err)
    }
    fmt.Printf("ServiceA.Add: %d+%d=%d\n", args.A, args.B, reply)

    // 异步调用
    var reply2 int
    divCall := client.Go("ServiceB.Sub", args, &reply2, nil)
    replyCall := <-divCall.Done // 接收调用结果
    fmt.Println("ServiceB.Sub error:", replyCall.Error)
    fmt.Printf("ServiceB.Sub: %d+%d=%d\n", args.A, args.B, reply2)
}

在这里,client调用的是server下的服务,即不是同一个进程下的服务,这样的好处有很多,比如如果一个项目过大,那么维护起来会有很大的成本,可以将服务给分离成很多服务,来降低服务之间的耦合度,这也是我们常说的微服务。

#go##rpc#
全部评论

相关推荐

06-27 12:54
已编辑
门头沟学院 Java
累了,讲讲我的大学经历吧,目前在家待业。我是一个二本院校软件工程专业。最开始选专业是觉得计算机感兴趣,所以选择了他。本人学习计算机是从大二暑假结束开始的,也就是大三开始。当时每天学习,我个人认为Java以及是我生活的一部分了,就这样持续学习了一年半,来到了大四上学期末,大概是在12月中旬,我终于找的到了一家上海中厂的实习,但我发现实习生的工作很枯燥,公司分配的活也不多,大多时间也是自己在自学。就这样我秋招末才找到实习。时间来到了3月中旬,公司说我可以转正,但是转正工资只有7000,不过很稳定,不加班,双休,因为要回学校参加答辩了,同时当时也是心高气傲,认为可以找到更好的,所以放弃了转正机会,回学校准备论文。准备论文期间就也没有投递简历。然后时间来到了5月中旬,这时春招基本也结束了,然后我开始投递简历,期间只是约到了几家下场面试。工资也只有6-7k,到现在我不知道该怎么办了。已经没有当初学习的心劲了,好累呀,但是又不知道该干什么去。在家就是打游戏,boss简历投一投。每天日重一次。26秋招都说是针对26届的人,25怎么办。我好绝望。要不要参加考公、考研、央国企这些的。有没有大佬可以帮帮我。为什么感觉别人找工作都是顺其自然的事情,我感觉自己每一步都在艰难追赶。八股文背了又忘背了又忘,我每次都花很长时间去理解他,可是现在感觉八股、项目都忘完了。真的已经没有力气再去学习了。图片是我的简历,有没有大哥可以指正一下,或者说我应该走哪条路,有点不想在找工作了。
码客明:太累了就休息一下兄弟,人生不会完蛋的
如果实习可以转正,你会不...
点赞 评论 收藏
分享
评论
5
收藏
分享

创作者周榜

更多
牛客网
牛客网在线编程
牛客网题解
牛客企业服务