一致性哈希算法 Java实现

一致性哈希算法 Java实现一致性哈希算法虚拟节点Java版本的简单实现。

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

import java.util.*;
public class ConsistencyHash { 

private static final int VIRTUAL_MACHINE_NUMBER = 5 ;
private SortedMap<Integer,String> virtualNodeMap = new TreeMap<Integer, String>();
private  List<String> trueNodeList = new ArrayList<String>();
public void addNode(String node){ 

if(trueNodeList.contains(node)){ 

return;
}
trueNodeList.add(node);
for(int i=0;i<VIRTUAL_MACHINE_NUMBER;i++){ 

String virtualNodeName = node + i;
int hash = getHash(virtualNodeName);
virtualNodeMap.put(hash,virtualNodeName);
}
}
/** * 删除某个节点 * @param node */
public void delNode(String node){ 

trueNodeList.remove(node);
for(int i=0;i<VIRTUAL_MACHINE_NUMBER;i++){ 

String virtualNodeName = node + i;
int hash = getHash(virtualNodeName);
virtualNodeMap.remove(hash);
}
}
/** * FNV哈希算法 * @param key * @return */
public int getHash(String key){ 

int p = 16777619;
int hash = (int)2166136261L;
for(int i=0;i<key.length();i++){ 

hash=(hash^key.charAt(i))*p;
}
hash+=hash<<13;
hash^=hash>>7;
hash+=hash<<3;
hash^=hash>>17;
hash+=hash<<5;
return hash>0?hash:Math.abs(hash);
}
public String getServer(String key){ 

int hash = getHash(key);
SortedMap<Integer, String> tailMap = virtualNodeMap.tailMap(hash);
int nodeKey;
if(tailMap.isEmpty()){ 

nodeKey=virtualNodeMap.firstKey();
}else{ 

nodeKey=tailMap.firstKey();
}
String virtualNodeName = virtualNodeMap.get(nodeKey);
return virtualNodeName.substring(0,virtualNodeName.length()-1);
}
public static void main(String[] args) { 

ConsistencyHash consistencyHash = new ConsistencyHash();
String[] nodes = { 
"192.168.1.1","192.168.1.2","192.168.1.3"};
for(String node:nodes){ 

consistencyHash.addNode(node);
}
Map<String,List<Integer>> taskDistributionMap = new HashMap();
for(int i=0;i<100;i++){ 

String server = consistencyHash.getServer("abc"+i + "def" );
List<Integer> list = taskDistributionMap.get(server);
if(list==null){ 

list = new ArrayList<>();
taskDistributionMap.put(server,list);
}
list.add(i);
}
for(Map.Entry<String,List<Integer>> entry:taskDistributionMap.entrySet()){ 

System.out.print(entry.getKey()+" "+entry.getValue().size()+" tasks:");
for(int t:entry.getValue()){ 

System.out.print(t+" ");
}
System.out.println();
}
consistencyHash.addNode("192.168.1.4");
taskDistributionMap = new HashMap();
for(int i=0;i<100;i++){ 

String server = consistencyHash.getServer("abc"+i + "def" );
List<Integer> list = taskDistributionMap.get(server);
if(list==null){ 

list = new ArrayList<>();
taskDistributionMap.put(server,list);
}
list.add(i);
}
for(Map.Entry<String,List<Integer>> entry:taskDistributionMap.entrySet()){ 

System.out.print(entry.getKey()+" "+entry.getValue().size()+" tasks:");
for(int t:entry.getValue()){ 

System.out.print(t+" ");
}
System.out.println();
}
}
}
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/164584.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • tomcat安装配置详解_tomcat下载安装及配置教程

    tomcat安装配置详解_tomcat下载安装及配置教程tomcat保姆级安装教程Tomcat安装教程(以tomcat-9.0.62为例:)1.下载安装包可以从官网下载安装包:(1)从官网下载输入网址进入官网sshttp://tomcat.apache.org/

  • java 卸载_java安装与卸载[通俗易懂]

    java 卸载_java安装与卸载[通俗易懂]1.安装JDK进行安装,安装过程中会有两次选择安装目录的时候,第一次选择的是jdk(java开发工具包),第二次选择的是jre(java的运行环境)我的安装目录:【我都使用的默认目录,占用内存并不大】jdk的C:\ProgramFiles\Java\jdk1.8.0_281\jre的C:\ProgramFiles\Java\jdk1.8.0_2812.设置环境变量1)JAVA_HO…

  • 怎么保存退出 vim 编辑

    怎么保存退出 vim 编辑保存命令按ESC键跳到命令模式,然后::w保存文件但不退出vim:wfile将修改另外保存到file中,不退出vim:w!强制保存,不推出vim:wq保存文件并退出vim:wq!强制保存文件,并退出vimq:不保存文件,退出vim:q!不保存文件,强制退出vim:e!放弃所有修改,从上次保存文件开始再编辑本文来自ij2155的CSDN博客…

  • JSTAT分析_jstat命令详解

    JSTAT分析_jstat命令详解S0S1EOMCCSYGCYGCTFGCFGCTGCT21.220.0040.5976.4381.2580.972212513.28633.413516.69921.220.0040.5976.4381.2580.9

  • jQuery省市区三级联动插件

    体验效果:http://hovertree.com/texiao/bootstrap/4/支持PC和手机移动端.手机扫描二维码体验效果:代码如下:数据来源:http://hovertree.co

    2021年12月22日
  • tensorRT7+ DEB安装教程

    tensorRT7+ DEB安装教程ONNX转tensorRT1.安装环境建议基于nvidia/cuda镜像,搭建环境!

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号