我是悠悠之家的博主 每日一库,最近开发中收集的这篇文章主要介绍每日一库:实现多个grpc 连接池shimingyah/pool,觉得挺不错的,现在分享给大家,希望可以做个参考。

概述

Go 的 grpc 客户端的连接池,支持连接重用。池提供附加功能:Connection reuse由特定的 MaxConcurrentStreams 参数支持。Failure reconnection由 grpc 的 keepalive 支持。package mainimp

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 连接池shimingyah/pool所遇到的程序开发问题。

如果觉得悠悠之家网站的内容还不错,欢迎将悠悠之家网站推荐给程序员好友。

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

评论列表共有 0 条评论

立即
投稿
返回
顶部