带嵌套指示器的Spring启动执行器健康组

Question

我正在尝试配置执行器的健康探测器，以包括对嵌套在第一级之外的外部服务的检查。例如，当调用/执行器/健康时，以下是可用的健康指标：

json prettyprint-override">    {
       "status":"DOWN",
       "components":{
          "jms":{
             "status":"DOWN",
             "components":{
                "broker1":{
                   "status":"DOWN",
                   "details":{
                      "error":"javax.jms.JMSException: Failed to create session factory"
                   }
                },
                "broker2":{
                   "status":"UP",
                   "details":{
                      "provider":"ActiveMQ"
                   }
                }
             }
          },
          "livenessState":{
             "status":"UP"
          },
          "readinessState":{
             "status":"UP"
          }
       },
       "groups":[
          "liveness",
          "readiness"
       ]
    }

在jms组件下，有两个代理——broker1和broker2。我可以将执行器配置为将jms包括在就绪组中，如：

  endpoint:
    health:
      probes:
        enabled: true
      enabled: true
      show-details: always
      group:
        readiness:
          include: readinessState, jms

但是，这将包括准备调查中的所有经纪人。

当呼叫 /actuator/health/readiness，我得到：

{
   "status":"DOWN",
   "components":{
      "jms":{
         "status":"DOWN",
         "components":{
            "broker1":{
               "status":"DOWN",
               "details":{
                  "error":"javax.jms.JMSException: Failed to create session factory"
               }
            },
            "broker2":{
               "status":"UP",
               "details":{
                  "provider":"ActiveMQ"
               }
            }
         }
      },
      "readinessState":{
         "status":"UP"
      }
   }
}

由于Kubernetes中的就绪性探测只会阻止将web请求路由到我的pod，因此我可以在broker1关闭的情况下处理请求，只要broker2打开。有没有办法将执行器配置为在健康组中包括嵌套的健康指标，而不仅仅是根健康指标？我尝试了broker1、jms等组合。broker1，jms/broker1，jms\broker1无效。

如果没有通过配置直接支持，是否可以创建一个自定义组件来提供所需的行为。例如，我考虑过编写自定义CompositeHealthContributor的可能性，但我不确定是否可以聚合现有的健康指标。我不想重复已经进行的健康检查。

另一个相关用例是，只要一组外部资源中有一个可用，就认为服务是健康的。例如，我在两个数据中心有一个相同的代理。只要有一个经纪人，我的服务就可以被认为是健康的。对于这个用例，什么是好的方法？

Answer 1

我相信，只要将嵌套指示器作为健康对象公开，就会得到预期的结果：

@Component
public class CustomHealthIndicator implements ReactiveHealthIndicator {

    private final List<CustomContributor> customContributors;

    public CustomHealthIndicator(List<CustomContributor> customContributors) {
        Assert.notNull(customContributors, "At least one contributor must be available");
        this.customContributors = customContributors;
    }

    @Override
    public Mono<Health> health() {
        return checkServices()
            .onErrorResume(ex -> Mono.just(new Health.Builder().down(ex).build()));
    }

    private Mono<Health> checkServices() {
        return Mono.fromSupplier(() -> {
            final Builder builder = new Builder();
            AtomicBoolean partial = new AtomicBoolean();
            this.customContributors.parallelStream()
                .forEach(customContributor -> {
                    final Object status = customContributor.getStatus();
                    final boolean isAnErrorState = status instanceof Throwable;
                    partial.set(partial.get() || isAnErrorState);

                    if(isAnErrorState){
                        builder.withDetail(customContributor.getName(), new Builder().down().withException((Throwable) status).build());
                    } else {
                        builder.withDetail(customContributor.getName(), new Builder().up().withDetail("serviceDetail", status).build());
                    }
                });
            builder.status(partial.get() ? Status.DOWN : Status.UP);
            return
                builder.build();
        });
    }
}