java - Cassandra : How to send multiple write/read requests in a single client request?

Question

我正在开发一个应用程序，我需要向 cassandra 服务器发送多个请求。各个请求是一种写/读请求，执行间隔很短。我发现往返时间存在一个主要瓶颈。

我可以将请求通过管道传送到 cassandra 以避免 RTT，就像 Redis 中的管道传送一样。

Answer 1

如果您使用的是 Cassandra 1.2 或更高版本，则可以使用 BATCH 来封装多个 INSERT/UPDATE 语句。

例如:

BEGIN BATCH
  INSERT INTO users (userid, password, name)
      VALUES ('user2', 'ch@ngem3b', 'second user');
  UPDATE users SET password = 'ps22dhds' WHERE userid = 'user3';
  INSERT INTO users (userid, password) VALUES ('user4', 'ch@ngem3c');
  DELETE name FROM users WHERE userid = 'user1';
APPLY BATCH;

See CQL3 Batch documentation .