Redis-cluster

集群结构

  

特点:
    1 所有redis节点(包括主和从)彼此互联(两两通信),底层使用内部的二进制传输协议,优化传输速度;(所有功能特点的基础)
    2 集群中也有主从,也有高可用的逻辑,但是没有哨兵进程,整合到主节点的功能里了;集群中的事件被主节点(大部分主节点);通过主节点的过半选举实现哨兵以前的逻辑;
    3 客户端与redis-cluster连接,无需关心分片的计算,客户端不在关心分片的计算逻辑,内部分发分布式数据(内部有分片计算逻辑),客户端将key交给redis节点后,集群内部判断key值的正确存储位置,转发存储;
    4 redis-cluster把所有的主节点对应到[0-16383]整数区间–槽道slot;各自的主节点维护一批槽道号(0-5000,5001-10000,10001-16383);在分片计算时,对key值做hash取模运算(就是取余,不在使用hashCode,CRC16);key值对应的取模运算结果,将会判断由哪个节点维护;将key–slot–node,如果我们想要迁移某个key值,必须将对应的slot一并迁移;

核心概念操作的工作原理
存储获取值时的转发逻辑

 

槽道迁移,数据key迁移

redis的集群槽道原理

槽道原理抛2个问题:
    1 节点接收数据计算槽道号后,如何判断当前槽道号是否归我管?
    2 判断不归本节点管理时,如何获取正确管理者信息
    
    
槽道逻辑结构

    槽道是一种计算逻辑
    计算逻辑:
        ○ 二进制16384位的位序列可以实现当前节点判断槽道号管理权的逻辑;(16384位二进制就是2048个元素的byte数组)
        计算二进制,获取人为定义的二进制下标号(人为定义,计算位移计算),每一位的下标号对应二进制(1/0),与下标号一直的槽道号到底归不归当前节点管理,是通过下标对应的二进制值判断1表示管理true,0表示不管理false;
        特点:
        1每个主节点都管理一批槽道,每个主节点的16384位的二进制不一样
        2从节点和没有槽道管理权的主节点的二进制是全是0
        
  模拟获取二进制下标和对应二进制值的代码(byte):

 1         @Test
 2         public void test(){
 3             byte a=55;
 4             //假设,这个byte二进制代表位序列中第一个byte
 5             System.out.println(Integer.toBinaryString(a));
 6             //获取定义的0号下标对应的二进制
 7             for(int i=0;i<8;i++){
 8                 //第一次移动7位,第二次移动6,第三次移动5
 9                 int move=8-i-1;
10                 int result=(a>>move)&1;
11                 System.out.println("当前"+i+"号下标对应的二进制"+result);
12             }
13         }

        ○ 索引数组
16384个元素的数组,下标0-16383,每个下标对应的元素引用的变量,指向内存中一个保存下标对应槽道号管理者的索引节点信息;

    总结:存入数据时,首先对存入的key值进行取模运算,通过计算,得到key值对应的槽道(16384个槽道,其实是一个16389个元素索引数组,每个数组元素变量保存着相对应槽道号管理者的节点信息), 获取槽道信息,根据对应槽道号数组元素变量的信息找到对应的主节点,并将数据存入主节点;
如何找到槽道号相对应的主节点???底层是根据二进制计算得出,是由16384个二进制位找到主节点的槽道号,并将主节点的相关信息保存在槽道号对应数组元素的变量中.当有数据存入或者取出时,计算key值得槽道号,找到对应的数组元素,通过这个数组元素中节点的信息,找到节点,进行存取操作.

 redis集群的命令

  集群
   cluster info :打印集群的信息
  cluster nodes :列出集群当前已知的所有节点( node),以及这些节点的相关信息。
  节点
  cluster meet <ip> <port> :将 ip 和 port 所指定的节点添加到集群当中,让它成为集群的一份子。
  cluster forget <node_id> :从集群中移除 node_id 指定的节点(保证空槽道)。
  cluster replicate <node_id> :将当前节点设置为 node_id 指定的节点的从节点。
  cluster saveconfig :将节点的配置文件保存到硬盘里面。
  槽(slot)
  cluster addslots <slot> [slot …] :将一个或多个槽( slot)指派( assign)给当前节点。
  cluster delslots <slot> [slot …] :移除一个或多个槽对当前节点的指派。
  cluster flushslots :移除指派给当前节点的所有槽,让当前节点变成一个没有指派任何槽的节点。
  cluster setslot <slot> node <node_id> :将槽 slot 指派给 node_id 指定的节点,如果槽已经指派给
  另一个节点,那么先让另一个节点删除该槽>,然后再进行指派。
  cluster setslot <slot> migrating <node_id> :将本节点的槽 slot 迁移到 node_id 指定的节点中。
  cluster setslot <slot> importing <node_id> :从 node_id 指定的节点中导入槽 slot 到本节点。
  cluster setslot <slot> stable :取消对槽 slot 的导入( import)或者迁移( migrate)。
  键
  cluster keyslot <key> :计算键 key 应该被放置在哪个槽上。
  cluster countkeysinslot <slot> :返回槽 slot 目前包含的键值对数量。
  cluster getkeysinslot <slot> <count> :返回 count 个 slot 槽中的键