GO-Grpc微服务开发五 服务调用优化

栏目: Go · 发布时间: 5年前

内容简介:源码:

使用连接池

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微服务开发五 服务调用优化》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

爆发

爆发

[美] 艾伯特-拉斯洛·巴拉巴西 / 马慧 / 中国人民大学出版社 / 2012-6 / 59.90元

1. 本书是一本超越《黑天鹅》的惊世之作。如果说塔勒布认为人类行为是随机的,都是小概率事件,是不可以预测的;那么全球复杂网络权威Barabasi则认为,人类行为93%是可以预测的。 2. Barabasi的研究是在人类生活数字化的大数据时代基础上进行的,移动电话、网络以及电子邮件使人类 行为变得更加容易量化,将我们的社会变成了一个巨大的数据库。他认为,人类正处在一个聚合点上,在这里数据、科学......一起来看看 《爆发》 这本书的介绍吧!

Base64 编码/解码
Base64 编码/解码

Base64 编码/解码

HEX CMYK 转换工具
HEX CMYK 转换工具

HEX CMYK 互转工具

HSV CMYK 转换工具
HSV CMYK 转换工具

HSV CMYK互换工具