高端企业网站模板,建公司的步骤,wordpress建立模板,爱站网排名事务开启 获取全局授时作为startTS构建一个tikvTxn对象#xff08;包括snapshot#xff09;。
事务写 txn.Set方法本质上将kv值写入了一个内存缓存(即kv/memdb_buffer.go中的memDbBuffer)中。该内存kv数据库利用的是golevel提供的功能。
事务回滚 直接将tikvTxn的valid字段…事务开启 获取全局授时作为startTS构建一个tikvTxn对象包括snapshot。
事务写 txn.Set方法本质上将kv值写入了一个内存缓存(即kv/memdb_buffer.go中的memDbBuffer)中。该内存kv数据库利用的是golevel提供的功能。
事务回滚 直接将tikvTxn的valid字段置为false之后如果用户再执行提交或者回滚操作会检查valid如果为false则直接返回错误。
事务提交 操作映射
遍历kv数据库中所有的key并将每个key和其操作组装到一起成为一个mutationEx对象并且将其放到一个map中map由key映射到mutationEx最后将这个map放入twoPhaseCommitter的mutations字段。
操作也是通过key的内容推断出来的推断逻辑如下
key的长度为0则操作为删除Op_Del如果key的长度大于0且不需要延迟检查或者延迟检查不通过value的当前长度大于0则操作为Op_Put即新增key或者更新key如果key的长度大于0且延迟检查(value的当前长度等于0)通过则操作为Op_Insert即新增key不允许更新key对于tikvTxn中的lockKeys字段中的key如果他在kv数据库中不存在的话则给予Op_Lock即单纯的作为锁事务结束就将这个key删除
Prewrite
Percolator事务模型有primary和secondaries的概念TiDB的实现中直接将第一个key作为Primary剩下的Key全部作为secondaries
TiDB上的操作
将所有的key按照Region进行分组从Region缓存或者PD中获取key所处的Region将每组的key再拆分成Batch每个Batch在16k作为主要目的是为了缩小RPC packet的大小并发地对每个batch进行处理即给TiKV发送Prewrite指令
注意其实在Prewrite阶段的实现并不太能看出primary和secondaries的区别他们都被一起打成batch并发处理了。
Tikv接收到指令之后对每个Batch分别进行Prewrite
遍历batch中每个元素的mutationEx之前操作映射时组装的然后分别进行如下操作
如果操作是Op_Insert的话则以事务开始时间startTs进行快照读检查key是否重复如果重复则标记错误看batch中下一个元素编码出一把锁所谓“锁”就是指key的version为全0的64位bit正常情况下是时间戳所以锁永远排在第一个检查是否有其他事务给该key上锁即查看是否有version为全0的key如果有则事务冲突上面的检查通过了的话则查看Rocksdb上紧接着锁的下一个key即最新的key查看其时间戳是否大于等于startTs如果这样的话说明有其他事务先提交了事务冲突。上面的检查也通过了的话则将自己的锁锁的信息包括startTsprimaryvalue以及操作码等等详见store/mockstore/mocktikv/mvcc.go中的mvccLock结构插入进去
Commit
TiDB中的逻辑
重新获得一个全局授时作为提交时间戳commitTsRegion分组Batch拆分和上面是一样的先提交Primary然后在后台提交secondaries
TiKV中的逻辑
新建一个Rocksdb的Batch进行批量的增删然后对于每个key
除了Op_Lock操作的Key都以CommitTS作为Key的版本号插入进去组装Value的时候将TiKV的操作码转成底层mvcc store的操作码将Op_put转成typePut剩下的除了不可能出现的Op_Lock都转换成typeDelete然后删除锁对于Op_Lock操作的Key则直接删除锁即可
End 作者元青
微信公众号 「技乐书香」
