随着memcache、Redis以及其它一些内存K/V数据库的流行，一致性哈希也越来越被开发者所了解。因为这些内存K/V数据库大多不提供分布式支持(本文以redis为例)，所以如果要提供多台redis server来提供服务的话，就需要解决如何将数据分散到redis server，并且在增减redis server时如何最大化的不令数据重新分布，这将是本文讨论的范畴。
取模算法
取模运算通常用于得到某个半开区间内的值：m % n = v，其中n不为0，值v的半开区间为：[0, n)。取模运算的算法很简单：有正整数k，并令k使得k和n的乘积最大但不超过m，则v的值为：m – kn。比如1 % 5，令k = 0，则k * 5的乘积最大并不超过1，故结果v = 1 – 0 * 5 = 1。
我们在分表时也会用到取模运算。如一个表要划分三个表，则可对3进行取模，因为结果总是在[0, 3)之内，也就是取值为：0、1、2。
但是对于应用到redis上，这种方式就不行了，因为太容易冲突了。
哈希(Hash)
Hash，一般翻译做“散列”，也有直接音译为"哈希"的，就是把任意长度的输入（又叫做预映射， pre-image），通过散列算法，变换成固定长度的输出，该输出就是散列值。这种转换是一种压缩映射，也就是散列值的空间通常远小于输入的空间，不同的输入可能会散列成相同的输出，而不可能从散列值来唯一的确定输入值。
简单的说就是一种将任意长度的消息压缩到某一固定长度的消息摘要的函数。
目前普遍采用的哈希算法是time33，又称DJBX33A (Daniel J. Bernstein, Times 33 with Addition)。这个算法被广泛运用于多个软件项目，Apache、Perl和Berkeley DB等。对于字符串而言这是目前所知道的最好的哈希算法，原因在于该算法的速度非常快，而且分类非常好(冲突小，分布均匀)。
PHP内核就采用了time33算法来实现HashTable，来看下time33的定义：
[php] view plain
copy
print?
hash(i) = hash(i-1) * 33 + str[i]
有了定义就容易实现了：
[php] view plain
copy
print?
<?php
1.
function
myHash(
$str
) {
1.
// hash(i) = hash(i-1) \* 33 + str[i]
1.
$hash
= 0;
1.
$s
= md5(
$str
);
1.
$seed
= 5;
1.
$len
= 32;
1.
for
(
$i
= 0;
$i
<
$len
;
$i
++) {
1.
// (hash << 5) + hash 相当于 hash \* 33
1.
//$hash = sprintf("%u", $hash \* 33) + ord($s{$i});
1.
//$hash = ($hash \* 33 + ord($s{$i})) & 0x7FFFFFFF;
1.
$hash
= (
$hash
<<
$seed
) +
$hash
+ ord(
$s
{
$i
});
1.
}
1.
1.
return
$hash
& 0x7FFFFFFF;
1.
}
1.
1.
echo
myHash(
"test"
);
//输出 786776064
## 利用取模实现
现在有2台redis server，所以需要计算键的hash并跟2取模。比如有键key1和key2，代码如下：
**[php]** view plain
copy
print?
1.
<?php
1.
function
myHash(
$str
) {
1.
// hash(i) = hash(i-1) \* 33 + str[i]
1.
$hash
= 0;
1.
$s
= md5(
$str
);
1.
$seed
= 5;
1.
$len
= 32;
1.
for
(
$i
= 0;
$i
<
$len
;
$i
++) {
1.
// (hash << 5) + hash 相当于 hash \* 33
1.
//$hash = sprintf("%u", $hash \* 33) + ord($s{$i});
1.
//$hash = ($hash \* 33 + ord($s{$i})) & 0x7FFFFFFF;
1.
$hash
= (
$hash
<<
$seed
) +
$hash
+ ord(
$s
{
$i
});
1.
}
1.
1.
return
$hash
& 0x7FFFFFFF;
1.
}
1.
1.
echo
"key1: "
. (myHash(
"key1"
) % 2) .
"\n"
;
1.
echo
"key2: "
. (myHash(
"key2"
) % 2) .
"\n"
;
对于key1和key2来说，同时存储到一台服务器上，这似乎没什么问题，但正因为key1和key2是始终存储到这台服务器上，一旦这台服务器下线了，则这台服务器上的数据全部要重新定位到另一台服务器。对于增加服务器也是类似的情况。而且重新hash(之前跟2进行hash，现在是跟3进行hash)之后，结果就变掉了，导致大多数数据需要重新定位到redis server。
在服务器数量不变的时候，这种方式也是能很好的工作的。
## 一致性哈希
由于hash算法结果一般为unsigned int型，因此对于hash函数的结果应该均匀分布在[0,2^32-1]区间，如果我们把一个圆环用2^32 个点来进行均匀切割，首先按照hash(key)函数算出服务器(节点)的哈希值， 并将其分布到0～2^32的圆环上。
用同样的hash(key)函数求出需要存储数据的键的哈希值，并映射到圆环上。然后从数据映射到的位置开始顺时针查找，将数据保存到找到的第一个服务器(节点)上。如图所示：
key1、key2、key3和server1、server2通过hash都能在这个圆环上找到自己的位置，并且通过顺时针的方式来将key定位到server。按上图来说，key1和key2存储到server1，而key3存储到server2。如果新增一台server，hash后在key1和key2之间，则只会影响key1(key1将会存储在新增的server上)，其它不变。
上图这个圆环相当于是一个排好序的数组，我们先通过代码来看下key1、key2、key3、server1、server2的hash值，然后再作分析：
**[php]** view plain
copy
print?
1.
<?php
1.
function
myHash(
$str
) {
1.
// hash(i) = hash(i-1) \* 33 + str[i]
1.
$hash
= 0;
1.
$s
= md5(
$str
);
1.
$seed
= 5;
1.
$len
= 32;
1.
for
(
$i
= 0;
$i
<
$len
;
$i
++) {
1.
// (hash << 5) + hash 相当于 hash \* 33
1.
//$hash = sprintf("%u", $hash \* 33) + ord($s{$i});
1.
//$hash = ($hash \* 33 + ord($s{$i})) & 0x7FFFFFFF;
1.
$hash
= (
$hash
<<
$seed
) +
$hash
+ ord(
$s
{
$i
});
1.
}
1.
1.
return
$hash
& 0x7FFFFFFF;
1.
}
1.
1.
//echo myHash("却道天凉好个秋~");
1.
echo
"key1: "
. myHash(
"key1"
) .
"\n"
;
1.
echo
"key2: "
. myHash(
"key2"
) .
"\n"
;
1.
echo
"key3: "
. myHash(
"key3"
) .
"\n"
;
1.
echo
"serv1: "
. myHash(
"server1"
) .
"\n"
;
1.
echo
"serv2: "
. myHash(
"server2"
) .
"\n"
;
现在我们根据hash值重新画一张在圆环上的分布图，如下所示：
key1、key2和key3都存储到了server1上，这是正确的，因为是按顺时针来定位。我们想像一下，所有的server其实就是一个排好序的数组(降序)：[server2, server1]，然后通过计算key的hash值来得到处于哪个server上。来分析下定位过程：如果只有一台server，即[server]，则直接定位，取数组的第一个元素。如果有多台server，则要先看通过key计算的hash值是否落在[server2, server1, …]这个区间上，这个直接跟数组的第一个元素和最后一个元素比较就知道了。然后就可以通过查找来定位了。
## 利用一致性哈希实现
下面是一个实现一致性哈希的例子，仅仅实现了addServer和find。其实对于remove的实现跟addServer是类似的。代码如下：
**[php]** view plain
copy
print?
1.
<?php
1.
function
myHash(
$str
) {
1.
// hash(i) = hash(i-1) \* 33 + str[i]
1.
$hash
= 0;
1.
$s
= md5(
$str
);
1.
$seed
= 5;
1.
$len
= 32;
1.
for
(
$i
= 0;
$i
<
$len
;
$i
++) {
1.
// (hash << 5) + hash 相当于 hash \* 33
1.
//$hash = sprintf("%u", $hash \* 33) + ord($s{$i});
1.
//$hash = ($hash \* 33 + ord($s{$i})) & 0x7FFFFFFF;
1.
$hash
= (
$hash
<<
$seed
) +
$hash
+ ord(
$s
{
$i
});
1.
}
1.
1.
return
$hash
& 0x7FFFFFFF;
1.
}
1.
1.
class
ConsistentHash {
1.
// server列表
1.
private
$_server_list
=
array
();
1.
// 延迟排序，因为可能会执行多次addServer
1.
private
$_layze_sorted
= FALSE;
1.
1.
public
function
addServer(
$server
) {
1.
$hash
= myHash(
$server
);
1.
$this
->_layze_sorted = FALSE;
1.
1.
if
(!isset(
$this
->_server_list[
$hash
])) {
1.
$this
->_server_list[
$hash
] =
$server
;
1.
}
1.
1.
return
$this
;
1.
}
1.
1.
public
function
find(
$key
) {
1.
// 排序
1.
if
(!
$this
->_layze_sorted) {
1.
asort(
$this
->_server_list);
1.
$this
->_layze_sorted = TRUE;
1.
}
1.
1.
$hash
= myHash(
$key
);
1.
$len
= sizeof(
$this
->_server_list);
1.
if
(
$len
== 0) {
1.
return
FALSE;
1.
}
1.
1.
$keys
=
array_keys
(
$this
->_server_list);
1.
$values
=
array_values
(
$this
->_server_list);
1.
1.
// 如果不在区间内，则返回最后一个server
1.
if
(
$hash
<=
$keys
[0] ||
$hash
>=
$keys
[
$len
– 1]) {
1.
return
$values
[
$len
– 1];
1.
}
1.
1.
foreach
(
$keys
as
$key
=>
$pos
) {
1.
$next_pos
= NULL;
1.
if
(isset(
$keys
[
$key
+ 1]))
1.
{
1.
$next_pos
=
$keys
[
$key
+ 1];
1.
}
1.
1.
if
(
is_null
(
$next_pos
)) {
1.
return
$values
[
$key
];
1.
}
1.
1.
// 区间判断
1.
if
(
$hash
>=
$pos
&&
$hash
<=
$next_pos
) {
1.
return
$values
[
$key
];
1.
}
1.
}
1.
}
1.
}
1.
1.
$consisHash
=
new
ConsistentHash();
1.
$consisHash
->addServer(
"serv1"
)->addServer(
"serv2"
)->addServer(
"server3"
);
1.
echo
"key1 at "
.
$consisHash
->find(
"key1"
) .
".\n"
;
1.
echo
"key2 at "
.
$consisHash
->find(
"key2"
) .
".\n"
;
1.
echo
"key3 at "
.
$consisHash
->find(
"key3"
) .
".\n"
;
**[php]** view plain
copy
print?
1.
$ php -f test.php
1.
key1 at server3.
1.
key2 at server3.
1.
key3 at serv2.
即使新增或下线服务器，也不会影响全部，只要根据hash顺时针定位就可以了。
