网站如何推广,730型反导密集阵,灵狐者裙底透视图
在微服务架构里面，每个小服务都是由很多节点组成，节点的添加删除故障希望能对下游透明，因此有必要引入一种服务的自动注册和发现机制，而 consul 提供了完整的解决方案，并且内置了对 grpc 以及 http 服务的支持
总体架构
服务注册
服务端将服务信息注册到 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 健康检查:
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持移动技术网。
如对本文有疑问，请在下面进行留言讨论，广大热心网友会与你互动！！ 点击进行留言回复
VSCode1.4 搭建Golang的开发调试环境(遇到很多问题)
网友评论