内容简介:源码:
使用连接池
func init() { so := sync.Once{} so.Do(func() { //初始化client var err error base := &fr_common.Base{} if base.GetEnv() == "prod" { consul_addr = fr_common.CONSUL_ADDR_PROD concul_token = fr_common.CONSUL_TOKEN_PROD } else { consul_addr = fr_common.CONSUL_ADDR_DEV concul_token = fr_common.CONSUL_TOKEN_DEV } config := consul.Config{ Address:consul_addr, Token:concul_token, } client, err = consul.NewClient(&config)//非默认情况下需要设置实际的参数 if err != nil { client = nil fmt.Printf("did not connect: %v", err.Error()) } //初始化连接池 pool = grpcp.New(func(addr string) (*grpc.ClientConn, error) { return grpc.Dial( addr, grpc.WithInsecure(), ) }) }) } /** * 获取服务 * @param name string 服务名称 * @return service 服务实例 */ func GetSrvHandel(name string) (conn *grpc.ClientConn, err error) { defer func() { if err := recover(); err != nil { fmt.Println(err) } }() service, _, err = client.Catalog().Service(name, "", nil) if err != nil { fmt.Printf("can not find services: %v", err.Error()) return nil, err } //多服务端时遍历链接直到成功 for _, v := range service { addr := fmt.Sprintf("%s:%d", v.ServiceAddress, v.ServicePort) conn, err = pool.GetConn(addr) } return conn, err }
源码: go-grpc-getway
以上所述就是小编给大家介绍的《GO-Grpc微服务开发五 服务调用优化》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!
猜你喜欢:本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。