服务健康检查 在微服务架构中,每个服务都会存在多个实例,可能部署在不同的主机中。因为网络或者主机等不确定因素,每个服务都可能会出现故障。我们需要能够监控每个服务实例的健康状态,当一个服务故障时,及时将它从注册中心删除。 实现 micro 提供两个方法可以直接实现健康检查功能 micro.RegisterTTL(time ..

【GO-Micro】服务健康检查

服务健康检查

在微服务架构中,每个服务都会存在多个实例,可能部署在不同的主机中。因为网络或者主机等不确定因素,每个服务都可能会出现故障。我们需要能够监控每个服务实例的健康状态,当一个服务故障时,及时将它从注册中心删除。

实现

micro 提供两个方法可以直接实现健康检查功能

micro.RegisterTTL(time.Second*30),
micro.RegisterInterval(time.Second*20),

Interval 就是间隔多久服务会重新注册
TTL 就是注册服务的过期时间,如果服务挂了,超过过期时间后,注册中心也会将服务删除

micro 内部服务注册的流程

当我们执行 service.Run() 时内部会执行 Start()
c384d5af3021210b3179b5e2bf9aa727.png

在 Start 函数中又会执行 s.opts.Server.Start(),方法的实现在 go-micro/server/rpc_server.go 中。
我们跳转到内部 server 的 Start 方法
7e5dd323f567df7c021f98c076c07116.png

可以发现 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()),
	)

  • golang

    Go 语言是 Google 推出的一种全新的编程语言,可以在不损失应用程序性能的情况下降低代码的复杂性。谷歌首席软件工程师罗布派克(Rob Pike)说:我们之所以开发 Go,是因为过去 10 多年间软件开发的难度令人沮丧。Go 是谷歌 2009 发布的第二款编程语言。

    319 引用 • 1158 回帖 • 731 关注
回帖   
请输入回帖内容...