如何确保仅在 cassandra 中不存在数据时写入

Question

我的服务器应用程序中有两种方法：

boolean isMessageExist(messageId) 执行以下查询：

SELECT messageId from message where messageId =1;

insertMessage(int messageId,String data) 执行以下查询：

INSERT INTO message (messageId,data) VALUES (1, xyz);

在我的代码中，我正在执行以下操作以满足“仅在消息不存在时插入”的要求。

if(!isMessageExist(1)){
insertMessage(1,"xyz")
}

但如果对相同 messageId 的请求几乎同时出现，则上述代码不起作用。

即在时间 T0 ... Read1(1)、Write1(1) 和 Read2(1)、Write2(1) 同时发生，因为这两个请求是同时从客户端发送的。有没有办法在服务器端按顺序发出这些请求。我的意思是 Read2(1) 应该总是得到结果 Write1(1) ？

如果 IF NOT EXISTS 由于性能开销，我不想使用 CAS 操作。 有没有其他方法可以达到我的要求？请提出建议。

Answer 1

使用 Cassandra 的轻量级事务 (LWT) IF NOT EXISTS 应该比您当前正在做的更便宜，并且满足您对唯一性的要求。

INSERT INTO message( messageId, data ) VALUES ( 1, xyz ) IF NOT EXISTS

您可以测试和验证性能，但两次往返（读取、写入）几乎肯定比一次 INSERT ... IF NOT EXISTS 更昂贵。

或者，如果您可以重新设计您的应用程序，使其使用 UPSERTS - 新值只是覆盖旧数据，那会更好，并使用更原生的 Cassandra 样式。