服务健康检查
在微服务架构中,每个服务都会存在多个实例,可能部署在不同的主机中。因为网络或者主机等不确定因素,每个服务都可能会出现故障。我们需要能够监控每个服务实例的健康状态,当一个服务故障时,及时将它从注册中心删除。
实现
micro 提供两个方法可以直接实现健康检查功能
micro.RegisterTTL(time.Second*30), micro.RegisterInterval(time.Second*20),
Interval 就是间隔多久服务会重新注册
TTL 就是注册服务的过期时间,如果服务挂了,超过过期时间后,注册中心也会将服务删除
micro 内部服务注册的流程
当我们执行 service.Run() 时内部会执行 Start()
在 Start 函数中又会执行 s.opts.Server.Start(),方法的实现在 go-micro/server/rpc_server.go 中。
我们跳转到内部 server 的 Start 方法
可以发现 micro 使用一个定时器按照间隔时间去自动重新注册。当服务意外故障,无法向注册中心重新注册时,如果超过了设定的 TTL 时间,注册中心就会将服务删除。
修改源码
service := grpc.NewService( micro.Name("go.micro.srv.hello"), micro.WrapHandler(ocplugin.NewHandlerWrapper(t)), + micro.RegisterTTL(time.Second*15), + micro.RegisterInterval(time.Second*10), // micro.Version("latest"), )
service := web.NewService( web.Name(name), web.Version("lastest"), + web.RegisterTTL(time.Second*15), + web.RegisterInterval(time.Second*10), web.MicroService(grpc.NewService()), )
欢迎来到这里!
我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。
注册 关于