详解golangconsul-grpc服务注册与发现_grpc注册中心资源-CSDN文库

服务注册与发现

78 浏览量 2020-09-20 07:43:39 上传评论收藏 79KB PDF 举报

资源推荐

资源详情

资源评论

详解详解golang consul-grpc 服务注册与发现服务注册与发现

主要介绍了详解golang consul-grpc 服务注册与发现，小编觉得挺不错的，现在分享给大家，也给大家做个参

考。一起跟随小编过来看看吧

在微服务架构里面，每个小服务都是由很多节点组成，节点的添加删除故障希望能对下游透明，因此有必要引入一种服务的自

动注册和发现机制，而 consul 提供了完整的解决方案，并且内置了对 GRPC 以及 HTTP 服务的支持

总体架构总体架构

1. 服务调用: client 直连 server 调用服务

2. 服务注册: 服务端将服务的信息注册到 consul 里

3. 服务发现: 客户端从 consul 里发现服务信息，主要是服务的地址

4. 健康检查: consul 检查服务器的健康状态

服务注册服务注册

服务端将服务信息注册到 consul 里，这个注册可以在服务启动可以提供服务的时候完成

完整代码参考: https://github.com/hatlonely/hellogolang/blob/master/sample/addservice/internal/grpcsr/consul_register.go

config := api.DefaultConfig()

config.Address = r.Address

client, err := api.NewClient(config)

if err != nil {

panic(err)

}

agent := client.Agent()

IP := localIP()

reg := &api.AgentServiceRegistration{

ID: fmt.Sprintf("%v-%v-%v", r.Service, IP, r.Port), // 服务节点的名称

Name: fmt.Sprintf("grpc.health.v1.%v", r.Service), // 服务名称

Tags: r.Tag, // tag，可以为空

Port: r.Port, // 服务端口

Address: IP, // 服务 IP

Check: &api.AgentServiceCheck{ // 健康检查

Interval: r.Interval.String(), // 健康检查间隔

// grpc 支持，执行健康检查的地址，service 会传到 Health.Check 函数中

GRPC: fmt.Sprintf("%v:%v/%v", IP, r.Port, r.Service),

DeregisterCriticalServiceAfter: r.DeregisterCriticalServiceAfter.String(), // 注销时间，相当于过期时间

},

}

if err := agent.ServiceRegister(reg); err != nil {

panic(err)

}

服务发现服务发现

客户端从 consul 里发现服务信息，主要是服务的地址

完整代码参考: https://github.com/hatlonely/hellogolang/blob/master/sample/addservice/internal/grpclb/consul_resolver.go

services, metainfo, err := w.client.Health().Service(w.service, "", true, &api.QueryOptions{

WaitIndex: w.lastIndex, // 同步点，这个调用将一直阻塞，直到有新的更新

})

本内容试读结束，登录后可阅读更多

下载后可阅读完整内容，剩余1页未读，立即下载

内容反馈

weixin_38663169

粉丝: 2
资源: 915

最新资源

资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！点击此处反馈

feedback-tip