文章目录

  • 分布式存储
    • 顺序分区 Sequential partitioning
    • 哈希分区 Hash partitioning
      • 方案总览
      • 节点取余分区 Hashing
      • 一致性哈希分区 Consistent hashing
        • 初始化
        • 节点的扩容与缩容
      • 虚拟哈希分区
      • 虚拟哈希分区 (Version2)
    • 顺序分区 VS 哈希分区


分布式存储

了解Redis集群原理之前我们先来梳理一下分布式存储的相关知识

拆分在算法中是一个非常重要的思想,当你的数据集巨大时,你可以按照特定的规则将大数据拆分成小数据集,降低因数据量增长过大带来的问题。

基本方案有两种:顺序分布 & 哈希分布 。 需要根据具体业务选择分片方式

数据分区虽好 ,但是有没有哪些棘手的问题要处理呢? 当然有了,比如

  • 自动负载均衡

    分布式存储系统需要自动识别负载高的节点,当某台机器的负载高时,自动将其上的部分数据迁移到其他机器。

  • 一致性

    分片后数据可能分布在不同存储服务器上,无法使用数据库自带的单机事务,需通过分布式应用事务一致性模型来解决


顺序分区 Sequential partitioning

从名字上也很好理解顺序分布的含义, 就是将大表按一定顺序划分为连续的子表,然后将子表按一定策略分配到存储节点上。

举个简单的例子

优点呢?

  1. 可顺序读

缺点呢?

  1. 数据可能分布不均匀
  2. 数据量大的时候,为了性能 ,需要使用索引来记录子表信息

哈希分区 Hash partitioning

方案总览

节点取余分区 Hashing

通过数据的某个特征计算哈希值,并将哈希值与集群中的服务器建立映射关系,从而将不同数据分布到不同服务器上。

hash(object) % N

举个例子:

假设这个时候我要添加一个节点 ,我们拿 1-10 来说,来计算下从3个节点到4个节点的迁移率

先 1 % 3 , 2 % 3 … 10 % 3 , 算出来 在哪个分区,如下图左侧 (0 ,1 ,2 三个分区)

重新对4进行 1 %4 , 2 % 4 … 10 % 4, 计算后 ,如右侧

比对一下, 只有 1 (分区0) 和 2 (分区1) 这两个值 还在原来的分区里 ,其余8个数字 都迁移到了其他的分区中。

解释下迁移率 是指: 你的这个缓存区域中已经没有数据了,需要DB查询,回写到缓存,80%的数据都要这样重新构建…


咋解决呢?

稍微挫一点的方案 翻倍扩容 ,迁移率可以降低到 50%

我们还是那1-10 这10个数字,3个分区变6个分区来计算下迁移率

原来1 % 3 , 2 % 3 … 10 % 3 , 算出来 在哪个分区
翻倍扩容 重新对6进行 1 %6 , 2 % 6 … 10 % 6, 计算

建议: 看场景,如果你的业务对缓存依赖没这没强,查不到从DB查就是,并发也不高,也不是不可以,毕竟这个最简单。

当然了,最好不用,太古老


一致性哈希分区 Consistent hashing

刚才根据节点数量来分区的方式,缺点也看到了,迁移率太高。 刚才的翻倍扩容的方案也差强人意,有没有更好的呢? 那就是 Consistent hashing

我们使用 哈希环来解决 slot 数发生变化时,尽量减少数据的移动。

一致性哈希算法在1997年由麻省理工学院的Karger等人在解决分布式Cache中提出的.

初始化

  • 首先求出节点 的哈希值 (比如可以选择服务器的ip或主机名作为关键字进行哈希),并将其配置到0~2^32的环上
  • 然后采用同样的方法求出存储数据的键的哈希值,并映射到相同的环上
  • 紧接着从数据映射到的位置开始顺时针查找,将数据保存到找到的第一个服务器上。
  • 如果超过2^32仍然找不到服务器,就会保存到第一个节点上

节点的扩容与缩容

节点取余的算法当节点动态的调整大大的影响缓存的命中率,但Consistent Hashing中,只有在环上增加服务器的地点逆时针方向的第一个节点上的键会受到影响

举个例子: 假设我们要在node1 和 node2 之间 增加一个 node5节点,看看哪些数据会受到影响?

增加node5 后

是不是 右上方的 两条数据 你下次再查找的时候 ,你会去node5找 (因为这两条数据的下一个节点是node5 ,已经不是node2了),找不到,失效了,会重新从数据源获取,重新构建。

仍然存在小规模的失效,但比第一种hash算法,如果节点很多,这种影响的数据范围降低了很多。

总结下 :

  1. 客户端分片: hash + 顺时针(优化取余)
  2. 节点伸缩:只影响邻近节点,但是还有数据迁移
  3. 翻倍伸缩: 保证最小迁移数据和负债均衡 , 这个其实还是有可能数据分部不均匀,比如你4个节点,大部分的key做hash以后,有可能集中在node1 和 nod2上,node3 和 node4 只有少量的数据,所以还是建议翻倍扩容。 这个就是我们常说的: 服务节点少时数据倾斜的问题

综上所述,一致性哈希算法对于节点的增减都只需重定位环空间中的一小部分数据,具有较好的容错性和可扩展性。

另外,一致性哈希算法在服务节点太少时,容易因为节点分部不均匀而造成数据倾斜问题


虚拟哈希分区

为了解决一致性hash在节点数量比较少的情况下出现数据倾斜问题,一致性哈希算法引入了虚拟节点机制,即对每一个服务节点计算多个哈希,每个计算结果位置都放置一个此服务节点,称为虚拟节点。

如何搞这些虚拟节点呢? 可以在服务器ip或主机名的后面增加编号来实现。例如上面的情况,可以为每台服务器计算三个虚拟节点,于是可以分别计算 “Node A#1”、“Node A#2”、“Node A#3”、“Node B#1”、“Node B#2”、“Node B#3”的哈希值,于是形成六个虚拟节点:

同时数据定位算法不变,只是多了一步虚拟节点到实际节点的映射,例如定位到“Node A#1”、“Node A#2”、“Node A#3”三个虚拟节点的数据均定位到Node A上。

这样就解决了服务节点少时数据倾斜的问题。在实际应用中,通常将虚拟节点数设置为32甚至更大,因此即使很少的服务节点也能做到相对均匀的数据分布。

import java.util.Collection;
import java.util.HashSet;
import java.util.Iterator;
import java.util.Set;
import java.util.SortedMap;
import java.util.SortedSet;
import java.util.TreeMap;
import java.util.TreeSet;public class ConsistentHash<T> {private final int numberOfReplicas;// 节点的复制因子,实际节点个数 * numberOfReplicas =// 虚拟节点个数private final SortedMap<Integer, T> circle = new TreeMap<Integer, T>();// 存储虚拟节点的hash值到真实节点的映射public ConsistentHash( int numberOfReplicas,Collection<T> nodes) {this.numberOfReplicas = numberOfReplicas;for (T node : nodes){add(node);}}public void add(T node) {for (int i = 0; i < numberOfReplicas; i++){// 对于一个实际机器节点 node, 对应 numberOfReplicas 个虚拟节点/** 不同的虚拟节点(i不同)有不同的hash值,但都对应同一个实际机器node* 虚拟node一般是均衡分布在环上的,数据存储在顺时针方向的虚拟node上*/String nodestr =node.toString() + i;int hashcode =nodestr.hashCode();System.out.println("hashcode:"+hashcode);circle.put(hashcode, node);}}public void remove(T node) {for (int i = 0; i < numberOfReplicas; i++)circle.remove((node.toString() + i).hashCode());}/** 获得一个最近的顺时针节点,根据给定的key 取Hash* 然后再取得顺时针方向上最近的一个虚拟节点对应的实际节点* 再从实际节点中取得 数据*/public T get(Object key) {if (circle.isEmpty())return null;int hash = key.hashCode();// node 用String来表示,获得node在哈希环中的hashCodeSystem.out.println("hashcode----->:"+hash);if (!circle.containsKey(hash)) {//数据映射在两台虚拟机器所在环之间,就需要按顺时针方向寻找机器SortedMap<Integer, T> tailMap = circle.tailMap(hash);hash = tailMap.isEmpty() ? circle.firstKey() : tailMap.firstKey();}return circle.get(hash);}public long getSize() {return circle.size();}/** 查看表示整个哈希环中各个虚拟节点位置*/public void testBalance(){Set<Integer> sets = circle.keySet();//获得TreeMap中所有的KeySortedSet<Integer> sortedSets= new TreeSet<Integer>(sets);//将获得的Key集合排序for(Integer hashCode : sortedSets){System.out.println(hashCode);}System.out.println("----each location 's distance are follows: ----");/** 查看相邻两个hashCode的差值*/Iterator<Integer> it = sortedSets.iterator();Iterator<Integer> it2 = sortedSets.iterator();if(it2.hasNext())it2.next();long keyPre, keyAfter;while(it.hasNext() && it2.hasNext()){keyPre = it.next();keyAfter = it2.next();System.out.println(keyAfter - keyPre);}}public static void main(String[] args) {Set<String> nodes = new HashSet<String>();nodes.add("A");nodes.add("B");nodes.add("C");ConsistentHash<String> consistentHash = new ConsistentHash<String>(2, nodes);consistentHash.add("D");System.out.println("hash circle size: " + consistentHash.getSize());System.out.println("location of each node are follows: ");consistentHash.testBalance();String node =consistentHash.get("apple");System.out.println("node----------->:"+node);}}

虚拟哈希分区 (Version2)

刚才虚节点这种靠数量取胜的策略增加了存储这些虚节点信息所需要的空间

在Redis Cluster中使用了一种比较特殊的方法来解决分布不均的问题,改进了这些数据分布的算法,将环上的空间均匀的映射到一个线性空间,这样,就保证分布的均匀性。


顺序分区 VS 哈希分区


Redis进阶-分布式存储 Sequential partitioning Hash partitioning相关推荐

  1. Redis进阶实践之一VMWare Pro虚拟机安装和Linux系统的安装

    2019独角兽企业重金招聘Python工程师标准>>> Redis进阶实践之一VMWare Pro虚拟机安装和Linux系统的安装 一.引言 设计模式写完了,相当于重新学了一遍,每次 ...

  2. Redis进阶-string底层数据结构精讲

    文章目录 Pre string 字符串 字符串的实现 字符串 内部结构 embstr vs raw Pre Redis进阶-核心数据结构进阶实战 Redis 有 5 种基础数据结构,分别为:strin ...

  3. Redis进阶-List底层数据结构精讲

    文章目录 Pre list 列表 队列 O(1) 栈 O(1) 查询 O(n) 快速列表 quicklist 压缩列表 ziplist ziplist 源码 entry 增加元素 快速列表 quick ...

  4. Redis进阶-布隆过滤器

    文章目录 Pre 布隆能解决哪些问题? BloomFilter实现原理 构建布隆过滤器 构建布隆的误差率 实际误差率推算 布隆过滤器 (JVM级别) 布隆过滤器 (分布式) Bloom Filter的 ...

  5. Redis进阶-如何发现和优雅的处理BigKey一二事

    文章目录 PreView 模拟写入一个BigKey 如何发现BigKey redis-cli --bigkeys debug object 如何优雅的删除BigKey (lazy delete) 关于 ...

  6. Redis进阶之持久化

    转载自  Redis进阶之持久化 一.Redis高可用概述 在介绍Redis高可用之前,先说明一下在Redis的语境中高可用的含义. 我们知道,在web服务器中,高可用是指服务器可以正常访问的时间,衡 ...

  7. redis 了 什么地方用到_细节拉满!美团首推“百万级”Redis进阶笔记究竟有什么魅力...

    Redis 相信大家现在项目里面都会用到一个技术--Redis.毫不夸张的说Redis作为现在最受欢迎的NoSQL数据库之一,不管是项目还是面试都会有所涉及!我们都知道在项目中使用redis,无非是从 ...

  8. Redis 进阶学习笔记

    Redis进阶学习笔记 阅读Redis.conf配置文件 # 61, 绑定的 IP , 一般注释掉该命令,这个吗,命令表示仅接受本机的(IP为本机)客户端连接, bind 127.0.0.1 # 80 ...

  9. Redis进阶学习08--多级缓存

    Redis进阶学习08--多级缓存 什么是多级缓存 JVM进程缓存 环境准备 docker安装mysql docker安装nginx 反向代理 初识Caffeine 实现JVM进程缓存 需求 实现 L ...

最新文章

  1. 计算机三级考试在线免费题库,国家三级计算机考试题库.docx
  2. 今天意外和身份证结缘
  3. USACO Broken Necklace 题解(环展开成链,枚举)
  4. jQuery easyUI--下拉菜单的制作
  5. c++ memset 语言_C++中memset函数用法详解
  6. Vue项目中一些常见的文件名及作用
  7. orton效果_如何使图片发光:Orton效果
  8. 【模拟】签订协议(nowcoder 217601)
  9. 视图机制对于数据库的安全意义
  10. Dune Analytics 发布 v2 版本,新增自动实时查询刷新
  11. ArcGIS Maritime Server 开发教程(八)ArcGIS Bathymetry 扩展模块
  12. 51NOD 1244 莫比乌斯函数之和
  13. 如何将Blocs v2项目迁移到Blocs v3?
  14. codematic2连接mysql失败_动软代码生成器Codematic
  15. stm32 代码加密
  16. 欧洲人“家里蹲”,差点把美国互联网搞“瘫痪”
  17. 【蓝桥杯每日一练:北斗七星数】
  18. LeetCode881. 救生艇
  19. 全志T3开发板——嵌入式入门学习测试教程(7)
  20. matlab中乘法“*”和点乘“.*”;除法“/”和点除“./”的联系和区别。

热门文章

  1. 使用 yolov3训练 voc2012
  2. cifar-10 cnn 分类
  3. shell 指令集锦
  4. 【数学建模】线性代数知识汇总,参加建模大赛的小伙伴看过来,它会是你的最优选
  5. Python爬虫应用实战案例-jsonpath在爬虫中的应用,爬取照片信息
  6. html5常见面试题,HTML5常见面试题及答案
  7. linux桌面文件夹改图标,Linux 给桌面程序设置个性化图标
  8. reactor线程模型_简单了解Java Netty Reactor三种线程模型
  9. 基于LSTM电商评论情感分析-多评价指标可视化版(内附源码)【自然语言处理NLP-100例】
  10. Matplotlib实例教程(十)边缘直方图