欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

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

程序员文章站 2024-01-23 11:26:04
在微服务架构里面,每个小服务都是由很多节点组成,节点的添加删除故障希望能对下游透明,因此有必要引入一种服务的自动注册和发现机制,而 consul 提供了完整的解决方案,并且...

在微服务架构里面,每个小服务都是由很多节点组成,节点的添加删除故障希望能对下游透明,因此有必要引入一种服务的自动注册和发现机制,而 consul 提供了完整的解决方案,并且内置了对 grpc 以及 http 服务的支持

总体架构

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

  1. 服务调用: client 直连 server 调用服务
  2. 服务注册: 服务端将服务的信息注册到 consul 里
  3. 服务发现: 客户端从 consul 里发现服务信息,主要是服务的地址
  4. 健康检查: consul 检查服务器的健康状态

服务注册

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

完整代码参考:

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 里发现服务信息,主要是服务的地址

完整代码参考:

services, metainfo, err := w.client.health().service(w.service, "", true, &api.queryoptions{
 waitindex: w.lastindex, // 同步点,这个调用将一直阻塞,直到有新的更新
})
if err != nil {
 logrus.warn("error retrieving instances from consul: %v", err)
}
w.lastindex = metainfo.lastindex

addrs := map[string]struct{}{}
for _, service := range services {
 addrs[net.joinhostport(service.service.address, strconv.itoa(service.service.port))] = struct{}{}
}

健康检查

consul 检查服务器的健康状态,consul 用 google.golang.org/grpc/health/grpc_health_v1.healthserver 接口,实现了对 grpc健康检查的支持,所以我们只需要实现先这个接口,consul 就能利用这个接口作健康检查了

完整代码参考:

// healthimpl 健康检查实现
type healthimpl struct{}

// check 实现健康检查接口,这里直接返回健康状态,这里也可以有更复杂的健康检查策略,比如根据服务器负载来返回
func (h *healthimpl) check(ctx context.context, req *grpc_health_v1.healthcheckrequest) (*grpc_health_v1.healthcheckresponse, error) {
 return &grpc_health_v1.healthcheckresponse{
  status: grpc_health_v1.healthcheckresponse_serving,
 }, nil
}

grpc_health_v1.registerhealthserver(server, &healthimpl{})

参考链接

完整工程代码:
consul 健康检查 api:
consul 服务注册 api:
grpc 健康检查:

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。