Skip to content

Latest commit

 

History

History
88 lines (72 loc) · 5.22 KB

lab4_ShardKV_4A.md

File metadata and controls

88 lines (72 loc) · 5.22 KB
Raw
title date category tags
MIT6.5840(6.824) Lab4: 分片KV数据库 3B
2024-03-03 02:10:46 -0800
CS课程笔记
MIT6.5840(6.824) 2023
Lab笔记
分布式系统
Go

最新的更新在博客 ToniBlog

本文将介绍lab4A部分的实现, lab4A要求实现分片控制器, 其实就是lab3的翻版, 基本上可以照搬lab3。如果仅仅是为了通过测试，lab4A倒是极其简单，只需要每次更新Group后随机完成Shard的映射就好了, 但还要考虑将配置项的改动最小话, 还是有一些坑的。

Lab文档见: http://nil.csail.mit.edu/6.5840/2023/labs/lab-shard.html

我的代码: https://github.com/ToniXWD/MIT6.5840/tree/lab4A

1 项目结构

分片数据库的组成结构是：1个controller + 多个replica groups。controller将数据进行分片， 存储在不同的集群上， 每个集群都是一个raft集群, controller负责管理分片, 也就是管理配置项。clients 和 servers 都会询问 controller 最新的配置信息。 分片控制器需要具备如下的功能:

  1. 为了负载均衡 -> 能够迁移分片
  2. 需要处理请求和配置项更新几乎同时到达的情况
  3. 建议的实现: raft集群也要保存配置项
  4. 配置更新后, 新的负责某分片的replica groups需要从旧的replica groups复制旧分片

Shard controller使用下面的RPC来实现管理和查询:

  1. Join:
    1. 重新分片时尽量平均
    2. 重新分片时移动的分片尽量少
    3. 允许重用GID
  2. Leave
    1. 重新分片时尽量平均
    2. 重新分片时移动的分片尽量少
  3. Move
    1. 将某个shard分配给某个group
  4. Query
    1. 返回配置信息
    2. 必须反映在其之前做出的配置信息更改

主要的坑包括:

  1. 需要滤除重复的RPC(照抄lab3即可)
  2. 执行碎片再平衡的状态机中的代码需要具有确定性(大坑)

2 实现思路

由于我们的目标不仅仅是通过测例, 还需要完成下面2个目标:

  1. 实现负载均衡 实现负载均衡, 意味着所有的集群被映射的数量只差不能大于1(手动Move的情况除外), 因此需要对已经映射的集群号(gid)实现统计计数
  2. 最小化改动 新配置和旧配置之间的改动要最小化

因此我的实现思路和逻辑如下:

2.1 Join

  1. 首先继承旧配置lastConfig创建新配置newConfig
  2. 将要Join的newGroups追加到newConfig.Groups, 但需要注意下面的情况
    1. len(lastConfig.Groups) + len(newGroups) <= NShards, 此时无脑将Join的newGroups追加到newConfig.Groups即可
    2. len(lastConfig.Groups) + len(newGroups) > NShards, 此时只需要将newConfig.Groups填充至len(newConfig.Groups) == NShards即可, 剩余的部分缓存起来, 记缓存区为CachedGid
  3. 统计newConfig.Groups中对Shard的映射次数, 映射次数最高的和映射次数最低的绝对值不能大于1, 由于新增了目前没有映射的Join的新集群, 此特性不可能满足, 因此需要:
    1. 将目前对Shard的映射次数最少的gid剥夺一个映射, 被剥夺的这个映射本来是被映射到拥有Shard最多的一个gid
    2. 更新映射次数统计信息, 直到映射次数最少的gid(也就是之前新加入的)大于等于映射平均值(NShards / len(newConfig.Groups))即可

2.2 Leave

  1. 首先继承旧配置lastConfig创建新配置newConfig
  2. 从newConfig.Groups和newConfig.CachedGid中移除指定的gid(因为可能目前所有的gid数量大于NShards, 部分被暂存到了CachedGid), 被移除的gid在newConfig.Shards用0标记
  3. 如果newConfig.CachedGid还有剩余且len(newConfig.Groups) < NShards, 将newConfig.CachedGid中的gid移动到newConfig.Groups使其填充满或者使newConfig.CachedGid为空
  4. 获取当前映射数量最少的gid的统计信息
  5. 在newConfig.Shards用0标记的位置用映射数量最少的gid代替, 每代替一次后需要重新统计

2.3 Move && Query

这两个没啥坑, 就不说了

3 易错点解析

  1. Go的map的迭代顺序 Go的map的迭代顺序是无序的, 即使其插入时的顺序和数据都是相同的, 但多次进行迭代, 其顺序不一致, 因此在多个副本上想保证确定性的话, 需要先对map的key获取切片并排序
  2. gid的数量和NShards的关系 由于每个Shard都会映射一个gid, 因此如果gid的数量大于NShard的话, 会存在有gid映射不到的情况, 这时我的处理是将其放到暂存区, 保证Group中的gid数量
  3. map的复制 Go的map的复制是浅复制, 复制一个map时，只是复制了对底层数据结构的引用，而不是底层数据本身的副本。意味着如果在一个map中做出了改变（比如删除或添加键值对），这些改变会在所有对这个底层数据结构的引用中体现出来。因此，对原始map的修改会影响到复制后的map，因为它们都引用同一个数据结构。

4 代码实现

我自己实现的代码比较繁琐(很丑), 但逻辑其实很简单, 参见: https://github.com/ToniXWD/MIT6.5840/tree/lab4A

5 测试

lab4A-test

此测试经过50次没有报错