KV service - Txn方法

优质

小牛编辑

124浏览

2023-12-01

Txn 方法在单个事务中处理多个请求。

一个 txn 请求增加键值存储的修订版本并为每个完成的请求生成带有相同修订版本的事件。

不容许在一个txn中多次修改同一个key。

rpc Txn(TxnRequest) returns (TxnResponse) {}

背景

以下内容翻译来自 proto文件中 TxnRequest 的注释，解释了Txn请求的工作方式.

来自 google paxosdb 论文:
我们的实现围绕强大的我们称为 MultiOp 的原生(primitive)。所有除了循环外的其他数据库操作被实现为对 MultiOp 的单一调用。MultiOp 被原子性的应用并由三个部分组成：
被称为guard的测试列表。在guard中每个测试检查数据库中的单个项(entry)。它可能检查某个值的存在或者缺失，或者和给定的值比较。在guard中两个不同的测试可能应用于数据库中相同或者不同的项。guard中的所有测试被应用然后 MultiOp 返回结果。如果所有测试是true，MultiOp 执行 t 操作 (见下面的第二项), 否则它执行 f 操作 (见下面的第三项).
被称为 t 操作的数据库操作列表. 列表中的每个操作是插入，删除，或者查找操作，并应用到单个数据库项。列表中的两个不同操作可能应用到数据库中相同或者不同的项。如果 guard 评价为true 这些操作将被执行
被成为 f 操作的数据库操作列表. 类似 t 操作, 但是是在 guard 评价为 false 时执行。

消息体

请求的消息体是 TxnRequest：

message TxnRequest {
  // compare 是断言列表，体现为条件的联合。
  // 如果比较成功，那么成功请求将被按顺序处理，而应答将按顺序包含他们对应的应答。
  // 如果比较失败，那么失败请求将被按顺序处理，而应答将按顺序包含他们对应的应答。
  repeated Compare compare = 1;
  // 成功请求列表，当比较评估为 true 时将被应用。
  repeated RequestOp success = 2;
  // 失败请求列表，当比较评估为 false 时将被应用。
  repeated RequestOp failure = 3;
}

应答的消息体是 TxnResponse：

message TxnResponse {
  ResponseHeader header = 1;
  // 如果比较评估为true则succeeded被设置为true，否则是false
  bool succeeded = 2;
  // 应答列表，如果 succeeded 是 true 则对应成功请求，如果 succeeded 是 false 则对应失败请求
  repeated ResponseOp responses = 3;
}

Compare 消息体：

message Compare {
  enum CompareResult {
    EQUAL = 0;
    GREATER = 1;
    LESS = 2;
  }
  enum CompareTarget {
    VERSION = 0;
    CREATE = 1;
    MOD = 2;
    VALUE= 3;
  }
  // result是这个比较的逻辑比较操作
  CompareResult result = 1;
  // target是比较要检查的键值字段
  CompareTarget target = 2;
  // key是用于比较操作的主题key
  bytes key = 3;
  oneof target_union {
    // version是给定key的版本
    int64 version = 4;
    // create_revision 是给定key的创建修订版本
    int64 create_revision = 5;
    // mod_revision 是给定key的最后修改修订版本
    int64 mod_revision = 6;
    // value 是给定key的值，以bytes的形式
    bytes value = 7;
  }
}

RequestOp 消息体：

message RequestOp {
  // request 是可以被事务接受的请求类型的联合
  oneof request {
    RangeRequest request_range = 1;
    PutRequest request_put = 2;
    DeleteRangeRequest request_delete_range = 3;
  }
}

ResponseOp 消息体：

message ResponseOp {
  // response 是事务返回的应答类型的联合
  oneof response {
    RangeResponse response_range = 1;
    PutResponse response_put = 2;
    DeleteRangeResponse response_delete_range = 3;
  }
}