如何验证Java驱动配置的一致性级别？（3.x升级到4.x场景）

一、验证ConsistencyLevel是否生效 #

1. 直接读取驱动配置确认 #

从配置加载器中取出配置对象，直接读取已设置的一致性级别参数，对比是否符合预期：

// 获取初始化配置对象
DriverConfiguration config = driverConfigLoader.getInitialConfig();
// 读取全局配置的一致性级别
String configuredConsistency = config.getString(DefaultDriverOption.REQUEST_CONSISTENCY);
System.out.println("全局配置的一致性级别：" + configuredConsistency);
// 转换为枚举类型进一步验证
ConsistencyLevel consistencyLevel = ConsistencyLevel.valueOf(configuredConsistency);
System.out.println("转换为枚举值：" + consistencyLevel);

2. 检查读写请求实际使用的级别 #

执行读写操作时，从Statement对象中获取实际生效的一致性级别——如果没有单独为语句设置级别，会默认使用全局配置的值：

// 以SimpleStatement为例
SimpleStatement query = SimpleStatement.newInstance("SELECT * FROM your_table WHERE id = ?", 1);
// 获取当前语句使用的一致性级别
ConsistencyLevel usedLevel = query.getConsistencyLevel();
System.out.println("查询请求使用的一致性级别：" + usedLevel);

// 若单独为语句设置级别，可对比是否覆盖全局配置
query.setConsistencyLevel(ConsistencyLevel.LOCAL_ONE);
System.out.println("单独设置后使用的级别：" + query.getConsistencyLevel());

3. 通过Cassandra节点日志验证 #

查看Cassandra节点的system.log（默认路径为logs/system.log），执行读写操作后，日志会记录请求的一致性级别，示例如下：

DEBUG [Native-Transport-Requests-1] 2024-05-20 10:00:00,000 QueryProcessor.java:210 - Processing query 'SELECT * FROM your_table WHERE id = 1' with consistency level LOCAL_QUORUM

二、启用调试日志打印一致性级别 #

1. 配置日志框架（以Logback为例） #

在logback.xml中添加驱动相关日志节点，开启DEBUG级别以输出请求细节：

<logger name="com.datastax.oss.driver.internal.core.request" level="DEBUG"/>
<logger name="com.datastax.oss.driver.api.core.session" level="DEBUG"/>

2. 日志输出示例 #

开启DEBUG后，日志会打印每个请求的详细信息，其中包含一致性级别：

DEBUG [s0-admin-0] 2024-05-20 10:00:00,000 DefaultRequest.java:150 - Sending request with consistency level LOCAL_QUORUM, query: SELECT * FROM your_table WHERE id = ?

3. 自定义请求日志拦截（可选） #

如果需要更定制化的日志输出，可以实现RequestTracker接口，在请求发送前后主动记录一致性级别：

public class ConsistencyLoggingTracker implements RequestTracker {
    private static final Logger logger = LoggerFactory.getLogger(ConsistencyLoggingTracker.class);

    @Override
    public void onRequestSent(Request request, Node node) {
        ConsistencyLevel cl = request.getConsistencyLevel();
        logger.info("请求发送至节点 {}，一致性级别：{}", node.getEndPoint(), cl);
    }

    // 实现接口其他必填方法（如onRequestSuccess、onRequestFailure）
}

// 注册到Session
CqlSession session = CqlSession.builder()
        .withConfigLoader(driverConfigLoader)
        .addRequestTracker(new ConsistencyLoggingTracker())
        .build();

内容的提问来源于stack exchange，提问作者Shobby Jacob K