一致性哈希算法 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)


相关推荐

  • Angular 图片懒加载

    Angular图片懒加载有很多写好的nglibrary可以用,我这里用的是ng-lazyload-image。可以在npm官网直接搜索。安装npminstallng-lazyload-image–save在module中导入:import{CommonModule}from’@angular/common’;import{LazyLoad…

  • Protostuff开发

    Protostuff开发Protostuff开发作者:chszs,未经博主允许不得转载。经许可的转载需注明作者和博客主页:http://blog.csdn.net/chszs五、Protostuff用法1、为Java实体产生schemasio.protostuffprotostuff-core<

  • 运维架构层级

    运维架构层级运维架构层级/运维角度内容描述/主要技术关键词监控体系自动化/DevOps云计算客户端层浏览器Cookie、浏览器缓存协商(Last-Modified、Expires、Etag)、组件分离、前端优化、运维检测工具舆论监控外部网络监控APM故障检测工具DNS服务CDN服务移动服务云

  • 大数据分析应用领域有哪些[通俗易懂]

    大数据分析应用领域有哪些[通俗易懂]  软件和服务的大数据分析市场收入预计将从2018年的$42B增长到2027年的$103B,复合年增长率(CAGR)为10.48%。这就是为什么,大数据分析认证是业内最全神贯注的技能之一。在这个“大数据分析应用领域”文章中,我将带您进入各个行业领域,在这里我将解释大数据分析如何使它们发生革命性变化。  大数据分析应用  大数据分析应用程序的主要目标是通过分析大量数据来帮助公司做出更具信息量的业务决策。它可能包括Web服务器日志,Internet点击流数据,社交媒体内容和活动报告,来自客户电子邮

  • 【二分查找】详细图解[通俗易懂]

    【二分查找】详细图解[通俗易懂]二分查找文章目录二分查找1.简介2.例子3.第一种写法(左闭右闭)3.1正向写法(正确演示)3.2反向写法(错误演示)4.第二种写法(左闭右开)4.1正向写法(正确演示)4.2反向写法(错误演示)5.总结写在前面:(一)二分法的思想十分容易理解,但是二分法边界处理问题大多数人都是记忆模板,忘记模板后处理边界就一团乱(????:“我懂了”,✋:”你懂个????”​)因为我此前也是记忆模板,所以现在想通过一边学习,一边将所学记录成博客教出去(费曼学习法),希望以后能自己推导出边界如

  • 聊聊自学,让你事半功倍的学习网站和工具「建议收藏」

    聊聊自学,让你事半功倍的学习网站和工具「建议收藏」压箱底的藏货~

发表回复

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

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