每日一库：实现多个grpc 连接池shimingyah/pool

Go 的 grpc 客户端的连接池，支持连接重用。

池提供附加功能：

• Connection reuse由特定的 MaxConcurrentStreams 参数支持。

• Failure reconnection由 grpc 的 keepalive 支持。

package main

import (
   "fmt"
   "github.com/shimingyah/pool"
   "google.golang.org/grpc"
   "log"
   "sync"
)

var (
   grpcOnce sync.Once
   poolConn  pool.Pool
)

func main() {

}

//参考: https://github.com/shimingyah/pool
func GetGrpcClient() *grpc.ClientConn {
   grpcOnce.Do(func() {
      var err error
      //grpc 服务器的地址或者 服务注册中心的地址
      address :=""
      poolConn, err = pool.New(address, pool.DefaultOptions)
      if err != nil {
         log.Fatalf("failed to new pool: %v", err)
      }
   })
   conn, err := poolConn.Get()
   if err != nil {
      log.Fatalf("failed to get conn: %v", err)
   }
   return conn.Value()
}