服务连接

概述

本文介绍如何使用 gRPC 框架进行 gRPC Client 的开发。

示例

准备工作

我们执行 goctl rpc new greet 生成一个 rpc server 服务。

  1. # 创建一个 demo 目录，进入 demo 目录
  2. $ mkdir demo && cd demo
  3. # 生成一个 greet 服务
  4. $ goctl rpc new greet
  5. # 新建一个 main.go 文件来创建一个 greet 服务的客户端
  6. $ touch main.go
服务连接 - 图1tip

以下配置详情请参考 服务配置

goctl rpc 指令使用请参考 goctl rpc

直连

直连分为两种模式，一种是直连单个服务，一种是直连服务集群。

地址解析模式

在 main.go 文件中代码如下

  1. func main() {
  2.     conn := zrpc.MustNewClient(zrpc.RpcClientConf{
  3.         Target: "dns:///127.0.0.1:8080",
  4.     })
  5.     client := greet.NewGreetClient(conn.Conn())
  6.     resp, err := client.Ping(context.Background(), &greet.Request{})
  7.     if err != nil {
  8.         log.Println(err)
  9.         return
  10.     }
  11.     log.Println(resp)
  12. }

多节点直连模式

在 main.go 文件中代码如下

  1. func main() {
  2.     conn := zrpc.MustNewClient(zrpc.RpcClientConf{
  3.         Endpoints: []string{"127.0.0.1:8080","127.0.0.2:8080"},// 直连集群时，只需要给 Endpoints 配置 rpc server的地址即可
  4.     })
  5.     client := greet.NewGreetClient(conn.Conn())
  6.     resp, err := client.Ping(context.Background(), &greet.Request{})
  7.     if err != nil {
  8.         log.Println(err)
  9.         return
  10.     }
  11.     log.Println(resp)
  12. }

etcd 服务发现

在 main.go 文件中代码如下

  1. func main() {
  2.     conn := zrpc.MustNewClient(zrpc.RpcClientConf{
  3.         Etcd: discov.EtcdConf{// 通过 etcd 服务发现时，只需要给 Etcd 配置即可
  4.             Hosts:              []string{"127.0.0.1:2379"},
  5.             Key:                "greet.rpc",
  6.             User:               "",// 当 etcd 开启 acl 时才填写，这里为了展示所以没有删除，实际使用如果没有开启 acl 可忽略
  7.             Pass:               "",// 当 etcd 开启 acl 时才填写，这里为了展示所以没有删除，实际使用如果没有开启 acl 可忽略
  8.             CertFile:           "",// 当 etcd 开启 acl 时才填写，这里为了展示所以没有删除，实际使用如果没有开启 acl 可忽略
  9.             CertKeyFile:        "",// 当 etcd 开启 acl 时才填写，这里为了展示所以没有删除，实际使用如果没有开启 acl 可忽略
  10.             CACertFile:         "",// 当 etcd 开启 acl 时才填写，这里为了展示所以没有删除，实际使用如果没有开启 acl 可忽略
  11.             InsecureSkipVerify: false,// 当 etcd 开启 acl 时才填写，这里为了展示所以没有删除，实际使用如果没有开启 acl 可忽略
  12.         },
  13.     })
  14.     client := greet.NewGreetClient(conn.Conn())
  15.     resp, err := client.Ping(context.Background(), &greet.Request{})
  16.     if err != nil {
  17.         log.Println(err)
  18.         return
  19.     }
  20.     log.Println(resp)
  21. }

原生支持

如果你不想使用 go-zero rpc 的 client 进行初始化，zrpc 也支持 grpc.ClientConn 的原生支持，你可以直接使用 grpc.ClientConn 进行初始化。

  1. func main() {
  2.     conn,err:=grpc.Dial("127.0.0.1:8080",grpc.WithBlock(), grpc.WithTransportCredentials(insecure.NewCredentials()))
  3.     if err!=nil{
  4.         log.Println(err)
  5.         return
  6.     }
  7.     client := greet.NewGreetClient(conn)
  8.     resp, err := client.Ping(context.Background(), &greet.Request{})
  9.     if err != nil {
  10.         log.Println(err)
  11.         return
  12.     }
  13.     log.Println(resp)
  14. }

其他服务发现

除了 go-zero 内置的 ectd 作为服务发现外，社区还提供了对 nacos,consul 等的服务发现支持，详情可参考 更多服务发现组件