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)
}

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{}{}
}

// 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{})