HealthIndicator for Cassandra模板

Question

我正在构建一个web服务，它将数据从Cassandra公开到RESTful接口。此外，对于REST服务部分使用Spring-boot-web，对于生产就绪特性使用spring-boot-actuator，对于Cassandra接口使用Spring-data-cassandra。我正在为CassandraTemplate寻找一个自定义的HealthIndicator(http://docs.spring.io/spring-boot/docs/current/reference/html/production-ready-endpoints.html#production-ready-healt)。

总的来说，检查Cassandratemplate健康状况的好策略是什么？

Answer 1

Spring Boot和Spring Data Cassandra都没有为Cassandra提供开箱即用的HealthIndicator，但是构建自己的HealthIndicator非常简单。您只需要创建一个与Cassandra交互的新HealthIndicator bean。例如：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.actuate.health.AbstractHealthIndicator;
import org.springframework.boot.actuate.health.Health.Builder;
import org.springframework.dao.DataAccessException;
import org.springframework.data.cassandra.core.CassandraOperations;
import org.springframework.stereotype.Component;

@Component
public class CassandraHealthIndicator extends AbstractHealthIndicator {

    private final CassandraOperations cassandra;

    @Autowired
    public CassandraHealthIndicator(CassandraOperations cassandra) {
        this.cassandra = cassandra;
    }

    @Override
    protected void doHealthCheck(Builder builder) throws Exception {
        try {
            this.cassandra.execute("SELECT now() FROM system.local");
            builder.up().build();
        } catch (DataAccessException ex) {
            builder.down(ex).build();
        }
    }

}

只要这个bean存在于应用程序上下文中，Spring Boot的Actuator组件就会找到它，并在确定应用程序的运行状况时使用它。

对Cassandra执行的确切查询可能会根据您的需求而有所不同。上面使用的查询取自对一个关于对Cassandra执行健康检查的问题的回答。