在 Cassandra 中，一致性级别（Consistency Level）并不是一个全局开关，而是每次读写操作都可以单独指定的参数。它告诉协调节点在执行操作时，需要等待多少个副本节点的确认才能向客户端返回成功。这个设计让 Cassandra 能够在同一个集群中同时服务不同一致性要求的业务，但也给开发者带来了选择困难：选低了可能读到旧数据，选高了又会拖慢响应甚至降低可用性。正确选择一致性级别，需要先理解复制因子、读写确认机制以及各类级别背后的行为差异。
一致性级别与复制因子的关系
Cassandra 的数据副本数量由复制因子（Replication Factor，RF）决定，例如 RF=3 意味着每行数据会存储到 3 个不同的节点上。一致性级别定义的是协调节点在读写路径上需要联系多少个副本并得到响应。写入时，协调节点会把数据发送给所有负责该分区的副本节点，但根据一致性级别的要求，只要收到指定数量的确认就能向客户端返回成功；读取时则相反，协调节点会向指定数量的副本发起请求，并根据返回结果合并数据。
值得强调的是，一致性级别的数值并不代表必须成功写入或读取多少个副本，而是参与响应的副本数量。例如写入时使用 ONE，只要求一个副本确认写入，数据会在后台异步复制到其余副本；使用 ALL 则要求所有副本都确认写入，任意一个副本宕机或网络抖动就会导致写入失败。因此，一致性级别的选择实际上是在数据安全、操作延迟和故障容忍度之间做权衡。
一个常见的误区是认为 RF=3 时 QUORUM 必须联系 3 个节点。实际上 QUORUM 的计算公式是 (RF / 2) + 1 向下取整，所以 RF=3 时仲裁数为 2。这意味着只要 2 个副本同意，协调节点就可以做出决定。理解这一点有助于在设计时避免过度保守或过度激进的选择。
常用一致性级别详解与读写组合
Cassandra 提供多种一致性级别，按适用场景可以分成单数据中心、跨数据中心和特殊用途三类。单数据中心常用的有 ONE、QUORUM、LOCAL_QUORUM、ALL；跨数据中心常用 EACH_QUORUM；特殊场景还有 ANY、SERIAL 和 LOCAL_SERIAL。
ONE 是最宽松的级别，读写操作只要求一个副本响应。它的优势是延迟最低、可用性最高，只要有一个副本活着就能完成操作；缺点则是可能读到旧数据，或者写入数据尚未同步到其他副本时该副本宕机，造成数据丢失。QUORUM 是多数派级别，要求超过半数的副本确认，能够在强一致性与高可用性之间取得较好平衡。RF=3 时 QUORUM 容忍 1 个副本故障，并保证读写之间至少有 1 个副本重叠，从而避免读到陈旧的已确认写入。
LOCAL_QUORUM 与 QUORUM 类似，但只计算本地数据中心的副本确认，适合多数据中心部署中希望减少跨机房延迟的场景。EACH_QUORUM 则要求每个数据中心的本地仲裁都成功，协调节点必须等待所有数据中心返回，跨机房网络抖动会直接影响延迟，但能保证各中心数据一致。ALL 要求所有副本确认，读写延迟最高，任意副本不可用都会导致操作失败，通常只在数据安全要求极高且能接受可用性下降时使用。
读写一致性经常被组合使用，例如写入 QUORUM 配合读取 QUORUM 可以提供线性一致性的常规读写体验：因为写入仲裁和读取仲裁至少有一个公共副本，读操作能够观察到已确认的写操作。如果需要更低的写入延迟，可以采用写入 ONE 并配合读取 ALL，但这种组合的可用性会更依赖副本整体健康度。ANY 仅用于写入，允许协调节点在联系不到任何负责副本时将数据写入 hinted handoff，一旦该节点恢复才补写，通常不建议作为业务写入级别，因为此时数据并未持久化到正式副本。
下面的 CQL 示例展示了在 cqlsh 中查看当前一致性级别并修改为 QUORUM 的方式。
CONSISTENCY; CONSISTENCY QUORUM;
SERIAL 和 LOCAL_SERIAL 用于 Cassandra 的轻量事务（Lightweight Transaction，LWT），它们需要借助 Paxos 协议完成条件更新，比如实现比较并设置（CAS）操作。普通读写不会用到这两个级别，只有在执行 INSERT ... IF NOT EXISTS 或 UPDATE ... IF 条件时需要将一致性级别设置为 SERIAL 或 LOCAL_SERIAL。这类操作的延迟明显高于普通写入，因此应控制在确实需要线性化语义的小范围业务中。
实际场景选择策略与最佳实践
选择一致性级别没有万能答案，需要根据业务对数据正确性、响应时间和可用性的权重来定。对于用户会话、购物车、实时统计等能容忍少量陈旧读的场景，写入 ONE 配合读取 ONE 或 LOCAL_QUORUM 可以获得较好的性能和可用性。对于账户余额、库存扣减、订单状态等需要读取到最近写入数据的场景，推荐写入 QUORUM 和读取 QUORUM，这样可以在多数派层面保证一致性，同时允许少数节点故障。
多数据中心环境中，如果业务请求主要分布在单个机房，且能容忍跨机房复制延迟，可以采用写入 LOCAL_QUORUM 配合读取 LOCAL_QUORUM，这样所有操作只在本地数据中心完成，延迟更低。如果需要保证不同机房用户读取到相同数据，则应考虑写入 EACH_QUORUM，但必须接受跨机房网络往返带来的延迟增加。在极端情况下，如果数据绝对不能丢失且允许系统在部分节点宕机时拒绝服务，可以选择写入 ALL 配合读取 ALL，但这种情况非常少，需要谨慎评估故障场景下的可用性影响。
对于使用轻量事务的场景，一致性级别的选择比较特殊。即使写入级别设置为 ONE，执行 LWT 操作时仍要涉及 Paxos 协议，延迟远高于普通写入。此时应优先设置 LOCAL_SERIAL 以减少跨数据中心的协调开销，但要理解 LWT 只保证单个分区的串行化，不能作为跨分区事务使用。
下面是一个使用 DataStax Java 驱动为单条语句设置一致性级别的示例，可以帮助开发者在代码层面对不同操作单独指定级别。
import com.datastax.oss.driver.api.core.CqlSession;
import com.datastax.oss.driver.api.core.cql.SimpleStatement;
import com.datastax.oss.driver.api.core.ConsistencyLevel;
public class ConsistencyDemo {
public static void main(String[] args) {
try (CqlSession session = CqlSession.builder().build()) {
SimpleStatement statement = SimpleStatement.newInstance(
"INSERT INTO demo.users (id, name) VALUES (?, ?)",
"1001", "Alice");
statement.setConsistencyLevel(ConsistencyLevel.QUORUM);
session.execute(statement);
}
}
}
最后，还需要关注集群的监控和测试。在实际选择一致性级别之前，可以通过混沌工程方式模拟节点宕机、网络分区等故障，观察不同级别下的读写成功率和延迟变化。同时利用 Cassandra 提供的读写延迟指标、超时计数和 hinted handoff 队列长度来评估当前配置是否合理。记住，一致性级别不是越强越好，关键是在满足业务正确性要求的前提下，尽可能保留系统的性能和可用性余量。
Cassandra一致性级别分布式数据库数据一致性修改时间：2026-08-21 08:09:43