Couchbase设置CAS后并发更新未触发CASMismatchException问题求助

看起来你遇到的问题核心是CAS值没有被正确从Couchbase传递到你的SomeObject对象中，导致后续的upsert操作跳过了乐观锁校验，直接执行了覆盖更新。我来帮你拆解细节：

最可能的原因：CAS值未正确赋值 #

Couchbase的CAS机制要求你传递的CAS值必须和服务器端文档元数据中的CAS完全匹配，才会执行更新；如果传递的是默认值（比如0），服务器会认为你不需要CAS校验，直接执行upsert——这就是为什么两次更新都成功，第二次还覆盖了第一次的结果。

你的getSomeObjectFromCouchbase方法大概率只完成了文档内容到SomeObject的转换，却漏掉了把JsonDocument中的CAS元数据赋值给SomeObject的cas字段。正确的获取逻辑应该是这样的：

public SomeObject getSomeObjectFromCouchbase(String id) {
    JsonDocument doc = couchbaseDao.getDatasource().getBucket().get(id);
    if (doc == null) {
        return null;
    }
    // 将JSON内容转换为SomeObject实例
    SomeObject obj = mapper.readValue(doc.content().toString(), SomeObject.class);
    // 关键步骤：把文档的CAS元数据赋值给obj的cas变量
    obj.setCas(doc.cas());
    return obj;
}

如果缺少了obj.setCas(doc.cas())这一步，someObjectA和someObjectB的cas变量会是默认值（比如0），服务器自然不会触发CAS冲突。

快速验证方法 #

你可以在创建JsonDocument前，打印两个对象的CAS值：

System.out.println("Object A CAS: " + someObjectA.getCas());
System.out.println("Object B CAS: " + someObjectB.getCas());

如果输出是0或者明显不符合Couchbase CAS格式的数值（CAS是64位非零整数），就坐实了CAS值未正确获取的问题。

其他排查方向（如果CAS值已正确赋值） #

如果确认CAS值没问题，可以检查以下几点：

• SDK版本bug：某些旧版本的Couchbase Java SDK对upsert带CAS的处理存在问题，建议升级到最新稳定版（比如3.x或4.x系列，根据你的项目依赖选择）。
• 操作方法选择：如果你确定文档一定存在，用replace代替upsert会更直观——replace强制要求文档存在且CAS匹配才更新，不存在直接报错，避免混淆。
• 服务器配置：虽然极少出现，但可以确认你的Couchbase集群没有禁用CAS机制（默认是启用的，不建议禁用）。

修复后的预期效果 #

当你正确传递CAS值后，第一次upsert会成功，服务器更新文档的CAS；第二次upsert使用旧CAS会触发CASMismatchException，此时你可以捕获异常，重新获取最新文档，合并两次的修改后再尝试更新，就能得到包含两个值的列表了。

内容的提问来源于stack exchange，提问作者A.C.