IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 数据结构与算法 -> Ribbon最终实战——打造自定义一致性哈希负载均衡策略 -> 正文阅读

[数据结构与算法]Ribbon最终实战——打造自定义一致性哈希负载均衡策略

自定义IRule

本文,我们通过IRule接口,实现一个自定义的负载均衡策略——一致性哈希。
关于一致性哈希原理不是本文探讨的重点,如果不了解的同学可以看下这篇文章《一致性哈希算法的原理与实现》,写的还是挺不错的。
一致性哈希不仅在负载均衡的领域,在很多其他的领域都有广泛的应用。
我们废话不多说,直接开干!

首先我们在ribbon-consumer的模块下,创建一个类并继承AbstractLoadBalancerRule和实现IRule接口:
在这里插入图片描述

然后从上下文中获取HttpServletRequest对象:

HttpServletRequest request = ((ServletRequestAttributes) 
                Objects.requireNonNull(RequestContextHolder
                        .getRequestAttributes()))
                .getRequest();

我们通过request对象,获取一个作为摘要的信息,这里我们就采取uri作为摘要:

String uri = request.getServletPath() + "?" + request.getQueryString();

我们我们定义route方法,来实现寻找server的逻辑:

public Server route(int hashId, List<Server> addressList){
        if (CollectionUtils.isEmpty(addressList)) {
            return null;
        }
        TreeMap<Long, Server> address = new TreeMap<>();
        addressList.forEach(e->{
            //把每个server利用for循环计算出若干个(8个)个不同的hash值,分布在圆环当中。
            //这个方式并不是均匀的分布,这里只是配合一致性哈希算法的思想做一个简单的例子。
            for (int i = 0; i < 8; i++) {
                long hash = hash(e.getId() + i);
                address.put(hash, e);
            }
        });
        long hash = hash(String.valueOf(hashId));
        SortedMap<Long, Server> last = address.tailMap(hash);
        //当request Url的hash值大于任意一个服务器对应的hashKey,
        //取address中的第一个节点
        if (last.isEmpty()) {
            return address.firstEntry().getValue();
        }
        return last.get(last.firstKey());
    }

这里,我们利用TreeMap存储虚化的服务节点列表,然后利用tailMap的特性获取后面的server,如果last为空我们就返回第一个元素,因为last为空时就是表示这是最后一个元素了,这就相当于我们让它形成了一个闭环。

我们这里还需要一个返回hash值的方法:

	public long hash(String key) {
        MessageDigest md5;
        try {
            md5 = MessageDigest.getInstance("MD5");
        } catch (NoSuchAlgorithmException e){
            throw new RuntimeException(e);
        }

        byte [] bytes = key.getBytes(StandardCharsets.UTF_8);
        md5.update(bytes);

        byte[] digest = md5.digest();

        long hashCode = (digest[2] & 0xFF << 16)
                | (digest[1] & 0xFF << 8)
                | (digest[0] & 0xFF);

        return hashCode & 0xffffffffL;
    }

这里的digest就是我么要拿到的摘要,然后根据这个摘要我们来生成hashCode,这个digest是16位,我们就挑前三个就好了,我们先拿第二位往前移16位,第一位移8位,第0位就不需要移位了。

到这里我们的一致性哈希算法就已经编写完成了,下面我们就测试一把,
我们先加上无参构造:
在这里插入图片描述
然后我们通过配置,指定Ribbon的负载均衡策略为我们定义的MyRule:
在这里插入图片描述
紧接着,我们启动三个eureka-client和ribbon-consumer:
在这里插入图片描述
这样我们通过Postman测试一下:
在这里插入图片描述

这里我们测试可以发现,我们的请求永远都是打在了30001这个节点上。
然后我们换一下请求的参数:
在这里插入图片描述

可以看到这次请求落在了30000上。
紧接着我们尝试把30000这个节点下线:
在这里插入图片描述
再次利用Postman请求:
在这里插入图片描述
可以看到不论怎么请求,这次又一直落在了30002这个节点上了。
到这里,我们已经学会了如何利用IRule来实现自定义的负载均衡策略,并且能够把它应用在我们的实际项目当中了。

  数据结构与算法 最新文章
【力扣106】 从中序与后续遍历序列构造二叉
leetcode 322 零钱兑换
哈希的应用:海量数据处理
动态规划|最短Hamilton路径
华为机试_HJ41 称砝码【中等】【menset】【
【C与数据结构】——寒假提高每日练习Day1
基础算法——堆排序
2023王道数据结构线性表--单链表课后习题部
LeetCode 之 反转链表的一部分
【题解】lintcode必刷50题<有效的括号序列
上一篇文章      下一篇文章      查看所有文章
加:2021-11-20 18:38:52  更:2021-11-20 18:39:50 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2025年1日历 -2025/1/9 1:00:05-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码