首页 > 代码库 > 第九课——redis集群

第九课——redis集群

第九课时作业

静哥

by 2016.4.18~2016.4.25

1、节点

1)节点概念:一个节点就是redis集群里的一台redis服务器。一个redis集群是由多个节点(node)组成,最初每个节点是相互独立的,可以理解成都处于一个只包含自己的集群当中,要组建一个真正可用的集群环境,必须将各个独立的节点连接起来。

2)将一个redis服务器以集群模式启动:

Redis服务器在启动时会根据cluster-enabled参数选项来决定是否开启集群模式;

技术分享技术分享

3)节点之间相互连接成一个集群:

按照(2)中以集群模式分别启动3redis服务器,分别占用端口6379 73798379。如下:

技术分享

客户端连接其中一个节点(例如6379端口所在redis服务器),执行cluster meet命令来完成连接各个节点的工作

技术分享

 

技术分享

4)查看当前集群状态

技术分享

因为虽然指定了8379  73792个节点,但是这2个节点都没有在处理任何槽,所以集群处于下线状态(fail

2、槽指派

1)概念—槽指派:

redis集群是通过分片方式来存储键值的,集群默认将整个redis数据库分成16384个槽(slot(index016383),集群里的每个节点可以处理最少0个,最多16384个槽,每个节点处理槽的情况,就需要做槽指派;

需要注意,16384个槽,但凡有一个槽没被指派到,整个集群就处在fail状态;即只有16384个槽全部被指派完,集群才处于上线状态(cluter_state:ok

2)槽指派的实现:

技术分享

16384个槽位必须全部分配完,不同节点不能重复,目前没有按照区间进行分配的命令,只能通过shell脚本:

for i in {0..10000}; do redis-cli -p 8379 cluster addslots $i; done

 

将槽0…10000指派给10.7.12.98:8379;将槽10001…16383指派给10.7.12.98:7379

通过脚本来实现槽指派:

技术分享技术分享

查看节点上槽分配信息:

技术分享

集群是上线状态了;

或者:

技术分享

3)插入数据进行测试:

技术分享技术分享技术分享

当节点发现键所在的槽并非由自己负责处理时,节点会向客户端返回一个MOVED错误,指引客户端转向至正在负责槽的节点,MOVED错误格式是:

MOVED <slot> <ip>:<port>

Redis-cli命令不带-c参数,表示单点客户端模式,单点客户端模式下,客户端会打印MOVED错误,不会字自动进行节点转向;

下图,带上-c参数,表示集群模式的redis-cli客户端,在接收到MOVEDc错误时,不会打印MOVED错误,而是根据MOVED错误自动进行节点转向,并打印转向信息;

技术分享

一共插入10条数据,如下:

值得注意的是:节点和单机服务器在数据库方面的一个区别是:节点只能使用0号库,单机redis则可以用select命令选择不同的数据库;

技术分享

技术分享

 

3、重新分片

1)概念:

Redis集群的重新分片,可以将任意数量已经指派给某个节点的槽改为指派给另一个节点,且相关槽所属的键值也会从源节点被移动给目标节点;

重新分片可以在线(online)进行,重新分片过程中,集群不需要下线,且源节点和目标节点可以继续处理命令请求。

2)重新分片:

案例:当前,10.7.12.98:8379节点上处理的槽位是0~1000010.7.12.98:7379节点处理的槽位是10001~16383

现做重新分片:新增10.7.12.98:6379节点到当前集群,并且将8379节点的槽位重新指派给6379节点,重新指派5000个槽位;

现将6379节点添加到当前集群里

技术分享

以下是槽位重新指派,要用到redis集群管理软件redis-trib.rb

技术分享技术分享

技术分享

 

publicclass ListTypeTests extends ClusterBaseTests {

 

    @Test

    publicvoid testLSetGet() {

        // 测试新增和获取

        doTest(new Executor() {

            @Override

            publicvoid execute(ShardedJedis jedis) {

                String key = "testLset";

                jedis.lpush(key"test0""test1");

                jedis.rpush(key"test2");

                MatcherAssert.assertThat(jedis.lrange(key, 0, -1), Matchers.contains("test1""test0""test2"));

            }

        });

    }

   

    @Test

    publicvoid testAddByIndex() {

        doTest(new Executor() {

            @Override

            publicvoid execute(ShardedJedis jedis) {

                jedis.lpush("testAddByIndex""value1");

                jedis.lpush("testAddByIndex""value2");

                jedis.rpush("testAddByIndex""value3");

                MatcherAssert.assertThat(jedis.lrange("testAddByIndex", 0, -1), Matchers.contains("value2""value1""value3"));

            }

        });

    }

 

    @Test

    publicvoid testLength() {

        doTest(new Executor() {

            @Override

            publicvoid execute(ShardedJedis jedis) {

                for(inti = 0; i < 10; i++) {

                    jedis.rpush("testLength"i + "");

                }

               

                assertThat(jedis.llen("testLength")).isEqualTo(10);

                assertThat(jedis.lindex("testLength", 2)).isEqualTo("2");

            }

        });

    }

 

 

publicclass SetTypeTests extends ClusterBaseTests {

 

    @Test

    publicvoid testSetGet() {

        doTest(new Executor() {

            @Override

            publicvoid execute(ShardedJedis jedis) {

                jedis.sadd("testSet""value1""value2""value3");

               

                MatcherAssert.assertThat(jedis.smembers("testSet"), Matchers.containsInAnyOrder("value1""value2""value3"));

            }

        });

    }

   

    @Test

    publicvoid testIsMember() {

        doTest(new Executor() {

            @Override

            publicvoid execute(ShardedJedis jedis) {

                jedis.sadd("testIsMember""value1""value2""value3""value1");

               

                assertThat(jedis.sismember("testIsMember""value2")).isTrue();

            }

        });

    }

   

}

 



来自为知笔记(Wiz)



第九课——redis集群