Go語(yǔ)言原生RPC入門(mén)
GRPC教程 1- RPC原理?
本篇文章介紹一下RPC的概念以及在Go語(yǔ)言如何使用標(biāo)準(zhǔn)庫(kù)中的RPC.
RPC是全稱(chēng)叫Remote Procedure Call，遠(yuǎn)程過(guò)程調(diào)用，它允許像調(diào)用本地服務(wù)一樣去調(diào)用遠(yuǎn)程服務(wù)，相對(duì)應(yīng)的就是本地調(diào)用。
本地調(diào)用的例子
```
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)
}
```
可以看到結(jié)果是
```
107088
30
```
那么與此相對(duì)應(yīng)的RPC調(diào)用即，不是同一進(jìn)程下的服務(wù)調(diào)用。
```go
// 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)
}
```
```go
// 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()
// 同步調(diào)用
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)
// 異步調(diào)用
var reply2 int
divCall := client.Go("ServiceB.Sub", args, &reply2, nil)
replyCall := <-divCall.Done // 接收調(diào)用結(jié)果
fmt.Println("ServiceB.Sub error:", replyCall.Error)
fmt.Printf("ServiceB.Sub: %d+%d=%d\n", args.A, args.B, reply2)
}
```
在這里，client調(diào)用的是server下的服務(wù)，即不是同一個(gè)進(jìn)程下的服務(wù)，這樣的好處有很多，比如如果一個(gè)項(xiàng)目過(guò)大，那么維護(hù)起來(lái)會(huì)有很大的成本，可以將服務(wù)給分離成很多服務(wù)，來(lái)降低服務(wù)之間的耦合度，這也是我們常說(shuō)的微服務(wù)。
