我是靠谱客的博主 每日一库,这篇文章主要介绍每日一库:实现多个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()
}


最后

以上就是每日一库最近收集整理的关于每日一库:实现多个grpc 连接池shimingyah/pool的全部内容,更多相关每日一库:实现多个grpc内容请搜索靠谱客的其他文章。

本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
点赞(791)

评论列表共有 0 条评论

立即
投稿
返回
顶部