GRPC教程 1- RPC原理
本篇文章介紹一下RPC的概念以及在Go語言如何使用標(biāo)準(zhǔn)庫中的RPC.
RPC是全稱叫Remote Procedure Call，遠(yuǎn)程過程調(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é)果是
```
```
那么與此相對(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)
}
```
