（转）一致性Hash算法在Memcached中的应用

前言

　　大家应该都知道Memcached要想实现分布式只能在客户端来完成,目前比较流行的是通过一致性hash算法来实现.常规的方法是将 server的hash值与server的总台数进行求余,即hash%N,这种方法的弊端是当增减服务器时,将会有较多的缓存需要被重新分配且会造成缓存分配不均匀的情况(有可能某一台服务器分配的很多,其它的却很少).

　　今天分享一种叫做”ketama”的一致性hash算法,它通过虚拟节点的概念和不同的缓存分配规则有效的抑制了缓存分布不均匀，并最大限度地减少服务器增减时缓存的重新分布。

实现思路

　　假设我们现在有N台Memcached的Server,如果我们用统一的规则对memcached进行Set,Get操作. 使具有不同key的object很均衡的分散存储在这些Server上,Get操作时也是按同样规则去对应的Server上取出object,这样各个 Server之间不就是一个整体了吗?

那到底是一个什么样的规则?

　　如下图所示,我们现在有5台(A,B,C,D,E)Memcached的Server,我们将其串联起来形成一个环形,每一台Server都代表圆环上的一个点,每一个点都具有唯一的Hash值,这个圆环上一共有2^32个点.

那么该如何确定每台Server具体分布在哪个点上? 这里我们通过”Ketama”的Hash算法来计算出每台Server的Hash值,拿到Hash值后就可以对应到圆环上点了.(可以用Server的IP地址作为Hash算法的Key.)

　　这样做的好处是,如下图当我新增Server F时,那么我只需要将hash值落在C和F之间的object从原本的D上重新分配到F上就可以了,其它的server上的缓存不需要重新分配,并且新增的Server也能及时帮忙缓冲其它Server的压力.

　　到此我们已经解决了增减服务器时大量缓存需要被重新分配的弊端.那该如何解决缓存分配不均匀的问题呢?因为现在我们的server只占据圆环上的6个点,而圆环上总共有2^32个点,这极其容易导致某一台server上热点非常多，某一台上热点很少的情况.

　　”虚拟节点”的概念很好的解决了这种负载不均衡的问题.通过将每台物理存在的Server分割成N个虚拟的Server节点(N通常根据物理 Server个数来定,这里有个比较好的阈值为250).这样每个物理Server实际上对应了N个虚拟的节点. 存储点多了,各个Server的负载自然要均衡一些.就像地铁站出口一样,出口越多,每个出口出现拥挤的情况就会越少.

　　代码实现:

 1 //保存所有虚拟节点信息, key : 虚拟节点的hash key, value: 虚拟节点对应的真实server
 2         private Dictionary<uint, string> hostDictionary = new Dictionary<uint, string>();
 3         //保存所有虚拟节点的hash key, 已按升序排序
 4         private uint[] ketamaHashKeys = new uint[] { };
 5         //保存真实server主机地址
 6         private string[] realHostArr = new string[] { };
 7         //每台真实server对应虚拟节点个数
 8         private int VirtualNodeNum = 250;
 9 
10         public KetamaVirtualNodeInit(string[] hostArr)
11         {
12             this.realHostArr = hostArr;
13             this.InitVirtualNodes();
14         }
15 
16         /// <summary>
17         /// 初始化虚拟节点
18         /// </summary>
19         private void InitVirtualNodes()
20         {
21             hostDictionary = new Dictionary<uint, string>();
22             List<uint> hostKeys = new List<uint>();
23             if (realHostArr == null || realHostArr.Length == 0)
24             {
25                 throw new Exception("不能传入空的Server集合");
26             }
27 
28             for (int i = 0; i < realHostArr.Length; i++)
29             {
30                 for (int j = 0; j < VirtualNodeNum; j++)
31                 {
32                     byte[] nameBytes = Encoding.UTF8.GetBytes(string.Format("{0}-node{1}", realHostArr[i], j));
33                     //调用Ketama hash算法获取hash key
34                     uint hashKey = BitConverter.ToUInt32(new KetamaHash().ComputeHash(nameBytes), 0);
35                     hostKeys.Add(hashKey);
36                     if (hostDictionary.ContainsKey(hashKey))
37                     {
38                         throw new Exception("创建虚拟节点时发现相同hash key,请检查是否传入了相同Server");
39                     }
40                     hostDictionary.Add(hashKey, realHostArr[i]);
41                 }
42             }
43 
44             hostKeys.Sort();
45             ketamaHashKeys = hostKeys.ToArray();
46         }

一致性hash算法的分配规则

　　到此我们已经知道了所有虚拟节点的Hash值, 现在让我们来看下当我们拿到一个对象时如何存入Server, 或是拿到一个对象的Key时该如何取出对象.

Set一个对象时,先将对象的Key作为”Ketama”算法的Key,计算出Hash值后我们需要做下面几个步骤.

1:首先检查虚拟节点当中是否有与当前对象Hash值相等的,如有则直接将对象存入那个Hash值相等的节点,后面的步骤就不继续了.

2:如没有,则找出第一个比当前对象Hash值要大的节点,(节点的Hash值按升序进行排序,圆环上对应按照顺时针来排列),即离对象最近的节点,然后将对象存入该节点.

3:如果没有找到Hash值比对象要大的Server,证明对象的Hash值是介于最后一个节点和第一个节点之间的,也就是圆环上的E和A之间.这种情况就直接将对象存入第一个节点,即A.

　　代码实现:　　

 1 /// <summary>
 2         /// 根据hash key 获取对应的真实Server
 3         /// </summary>
 4         /// <param name="hash"></param>
 5         /// <returns></returns>
 6         public string GetHostByHashKey(string key)
 7         {
 8             byte[] bytes = Encoding.UTF8.GetBytes(key);
 9             uint hash = BitConverter.ToUInt32(new KetamaHash().ComputeHash(bytes), 0);
10 
11             //寻找与当前hash值相等的Server. 
12             int i = Array.BinarySearch(ketamaHashKeys, hash);
13 
14             //如果i小于零则表示没有hash值相等的虚拟节点
15             if (i < 0)
16             {
17                 //将i继续按位求补,得到数组中第一个大于当前hash值的虚拟节点
18                 i = ~i;
19 
20                 //如果按位求补后的i大于等于数组的大小,则表示数组中没有大于当前hash值的虚拟节点
21                 //此时直接取第一个server
22                 if (i >= ketamaHashKeys.Length)
23                 {
24                     i = 0;
25                 }
26             }
27 
28             //根据虚拟节点的hash key 返回对应的真实server host地址
29             return hostDictionary[ketamaHashKeys[i]];
30         }

Get一个对象,同样也是通过”Ketama”算法计算出Hash值,然后与Set过程一样寻找节点,找到之后直接取出对象即可.

那么这个”Ketama”到底长什么样呢,让我们来看看代码实现.

 1 /// <summary>
 2     ///  Ketama hash加密算法
 3     ///  关于HashAlgorithm参见MSDN链接
 4     ///  http://msdn.microsoft.com/zh-cn/library/system.security.cryptography.hashalgorithm%28v=vs.110%29.aspx
 5     /// </summary>
 6     public class KetamaHash : HashAlgorithm
 7     {
 8 
 9         private static readonly uint FNV_prime = 16777619;
10         private static readonly uint offset_basis = 2166136261;
11 
12         protected uint hash;
13 
14         public KetamaHash()
15         {
16             HashSizeValue = 32;
17         }
18 
19         public override void Initialize()
20         {
21             hash = offset_basis;
22         }
23 
24         protected override void HashCore(byte[] array, int ibStart, int cbSize)
25         {
26             int length = ibStart + cbSize;
27             for (int i = ibStart; i < length; i++)
28             {
29                 hash = (hash * FNV_prime) ^ array[i];
30             }
31         }
32 
33         protected override byte[] HashFinal()
34         {
35             hash += hash << 13;
36             hash ^= hash >> 7;
37             hash += hash << 3;
38             hash ^= hash >> 17;
39             hash += hash << 5;
40             return BitConverter.GetBytes(hash);
41         }
42     }