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

查看所有标签

猜你喜欢:

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

强化学习精要

强化学习精要

冯超 / 电子工业出版社 / 2018-6 / 80

《强化学习精要:核心算法与TensorFlow 实现》用通俗幽默的语言深入浅出地介绍了强化学习的基本算法与代码实现,为读者构建了一个完整的强化学习知识体系,同时介绍了这些算法的具体实现方式。从基本的马尔可夫决策过程,到各种复杂的强化学习算法,读者都可以从本书中学习到。本书除了介绍这些算法的原理,还深入分析了算法之间的内在联系,可以帮助读者举一反三,掌握算法精髓。书中介绍的代码可以帮助读者快速将算法......一起来看看 《强化学习精要》 这本书的介绍吧!

图片转BASE64编码
图片转BASE64编码

在线图片转Base64编码工具

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

Base64 编码/解码

正则表达式在线测试
正则表达式在线测试

正则表达式在线测试