一致性哈希将整个哈希值空间组织成一个虚拟的圆环,如假设某哈希函数H的值空间为0-2^32-1(即哈希值是一个32位无符号整形)。
整个空间按顺时针方向组织,0和232-1在零点中方向重合。
一致性hash有什么用
一致性hash算法常用于分布式缓存服务,把所有的服务节点进行hash,得到hash环上的位置。
添加进服务的数据用同样的算法进行hash,然后从hash环上取得大于该hash值的第一个节点,如果没有大于该值的节点,那么就取整个环的第一个节点。
存在问题
在节点太少的情况,有可能存在hash偏移。就是节点负载不均衡,大量数据落在其中一个节点上面。
解决办法是,在环上面虚拟出足够多的节点,虚拟的节点和实际节点做对应。
java代码实现
package com.hj.lock.alg;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.*;
public class ConsistentHash<T> {
HashFunc hashFunc;
private final int numberOfReplicas;
private final TreeMap<Long, T> hashCircle = new TreeMap<>();
public interface HashFunc {
public Long hash(Object key);
}
public static void main(String[] args){
List nodes = new ArrayList<>();
System.out.println("--添加节点 ABC");
nodes.add("A");
nodes.add("B");
nodes.add("C");
ConsistentHash chash = new ConsistentHash(1, nodes);
System.out.println(chash.get("test1"));
System.out.println(chash.get("aest2"));
System.out.println(chash.get("dest3"));
System.out.println("--添加节点 D");
chash.add("D");
System.out.println(chash.get("test1"));
System.out.println(chash.get("aest2"));
System.out.println(chash.get("dest3"));
for (Iterator> it = chash.hashCircle.entrySet().iterator(); it.hasNext(); ) {
Map.Entry entry = it.next();
Long k = entry.getKey();
System.out.println(k + ":" + entry.getValue());
System.out.println(Math.abs(chash.nextHash(k + 1) - k));
}
}
}
以上代码输出值:
--添加节点 ABC
C
C
A
--添加节点 D
D
C
A
748451404:B
1081611916
1830063320:A
1542566198
3372629518:D
491985806
3864615324:C
3116163920
参考
https://www.cnblogs.com/lpfuture/p/5796398.html
免责声明:
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341