170103、Redis官方集群方案 Redis Cluster

前面我们谈了Redis Sharding多服务器集群技术,Redis Sharding是客户端Sharding技术,对于服务端来说,各个Redis服务器彼此是相互独立的,这对于服务端根据需要灵活部署Redis非常轻便,Redis Sharding具有很好的灵活性、可伸缩性,是一种轻量级集群技术。

本篇,介绍另外一种多Redis服务器集群技术,即Redis Cluster。Redis Cluster是一种服务器Sharding技术,3.0版本开始正式提供。

Redis Cluster中,Sharding采用slot(槽)的概念,一共分成16384个槽,这有点儿类似前面讲的pre sharding思路。对于每个进入Redis的键值对,根据key进行散列,分配到这16384个slot中的某一个中。使用的hash算法也比较简单,就是CRC16后16384取模。

Redis集群中的每个node(节点)负责分摊这16384个slot中的一部分,也就是说,每个slot都对应一个node负责处理。当动态添加或减少node节点时,需要将16384个槽做个再分配,槽中的键值也要迁移。当然,这一过程,在目前实现中,还处于半自动状态,需要人工介入。

Redis集群,要保证16384个槽对应的node都正常工作,如果某个node发生故障,那它负责的slots也就失效,整个集群将不能工作。

为了增加集群的可访问性,官方推荐的方案是将node配置成主从结构,即一个master主节点,挂n个slave从节点。这时,如果主节点失效,Redis Cluster会根据选举算法从slave节点中选择一个上升为主节点,整个集群继续对外提供服务。这非常类似前篇文章提到的Redis Sharding场景下服务器节点通过Sentinel监控架构成主从结构,只是Redis Cluster本身提供了故障转移容错的能力。

Redis Cluster的新节点识别能力、故障判断及故障转移能力是通过集群中的每个node都在和其它nodes进行通信,这被称为集群总线(cluster bus)。它们使用特殊的端口号,即对外服务端口号加10000。例如如果某个node的端口号是6379,那么它与其它nodes通信的端口号是16379。nodes之间的通信采用特殊的二进制协议。

对客户端来说,整个cluster被看做是一个整体,客户端可以连接任意一个node进行操作,就像操作单一Redis实例一样,当客户端操作的key没有分配到该node上时,Redis会返回转向指令,指向正确的node,这有点儿像浏览器页面的302 redirect跳转。

Redis Cluster是Redis 3.0以后才正式推出,时间较晚,目前能证明在大规模生产环境下成功的案例还不是很多,需要时间检验。

集群搭建R

下面,我们就实际操作建立一个Redis Cluster。我们将建立3个node,每个node架构成一主一从,故总共有6个redis实例,端口号从7000-7005。

Cluster下的Redis实例,和普通Redis实例一样,只是处于cluster模式方式下运行。

实操步骤如下:

1. 以3.0.5为例,建立cluster目录,其下再建6个子目录代表6实例环境

mkdir cluster

mkdir 7000 7001 7002 7003 7004 7005

2. 将redis.conf模板分别copy到上面6子目录中,并做如下修改,以7000为例:

修改如下信息

daemonize yes

pidfile /var/run/redis-7000.pid

port 7000

logfile "/var/log/redis-7000.log"

注释掉如下信息, 不需要RDB持久化

#save 900 1

#save 300 10

#save 60 10000

修改如下信息

appendonly yes

appendfilename "appendonly-7000.aof"

取消如下注释,让Redis在集群模式下运行

cluster-enabled yes 启动cluster模式

cluster-config-file nodes-7000.conf 集群信息文件名,由redis自己维护

cluster-node-timeout 15000 15秒中联系不到对方node,即认为对方有故障可能

3. 在各个目录下执行 redis-server redis.conf 启动redis实例

这时,这几个实例都是各自是一个集群状态在运行,并没有形成一个整体集群态,我们需要Redis提供的基于ruby开发的工具进行人工设置。

4.安装ruby环境

yum install ruby ruby-devel rubygems

5.安装Redis的ruby依赖接口

gem install redis

6.利用脚本工具建立集群

./redis-trib.rb create --replicas 1 192.168.1.142:7000 192.168.1.142:7001 192.168.1.142:7002 192.168.1.142:7003 192.168.1.142:7004 192.168.1.142:7005

该脚本自动执行节点分配方案,将前3个redis实例作为主节点,后三个作为从节点,如图:

170103、Redis官方集群方案 Redis Cluster

按提示敲入"yes",执行方案,将6个节点组成集群,3主3从。

执行redis-cli -p 7000 info Replication 命令,观察7000这个节点,发现其复制配置信息已配置成主节点,并有一个从节点7003

170103、Redis官方集群方案 Redis Cluster

再执行redis-cli -p 7003 info Replication发现,该节点已设置成从节点。这些主从设置,都是在创建集群时自动完成的。

170103、Redis官方集群方案 Redis Cluster

至此,3主3从的Redis集群建立起来了。接下来我们做个故障转移试验,将主节点7001 shutdown掉,看看发生什么?

170103、Redis官方集群方案 Redis Cluster

我们看到,从节点7004会上升为主节点继续提供集群服务。那又重新启动7001节点呢?

170103、Redis官方集群方案 Redis Cluster

我们发现7001节点已经成为从节点,不会成为取代7004成为主节点。那如果将主节点7001和从节点7004都shutdown掉呢?

170103、Redis官方集群方案 Redis Cluster

这时,整个cluster是拒绝提供服务的。因为原来7001分配的slot现在无节点接管,需要人工介入重新分配slots。

增删集群节点R

下面我们操作下,如果修改集群节点架构:

删除一个从节点。注意,如果删除主节点,其负责的slots必须为空。

./redis-trib.rb del-node 192.168.1.142:7000 ee2fc0ea6e630f54e3b811caedf8896b26a99cba

将7001节点的slot都转移到7000

./redis-trib.rb reshard 192.168.1.142:7000

按提示操作即可。

加一个节点。注意新添加的节点还没有分配slot,用reshard给它分配一定比例的slots

./redis-trib.rb add-node 192.168.1.142:7001 192.168.1.142:7000

给指定一个主节点添加一个从节点。

./redis-trib.rb add-node --slave --master-id f4d17d56a9dda1a102da7cd799192beff7cba69e 192.168.1.142:7004 192.168.1.142:7000

注意如果此redis实例参与过集群,需先cluster reset 清除重置一下。

Jedis客户端访问R

上面介绍了服务端Redis Cluster搭建过程。下面来看看客户端如何使用?

Java语言的客户端驱动Jedis是支持Redis Cluster的。我们具体实操下:

1. pom.xml中配置jedis jar包

<dependency>

<groupId>redis.clients</groupId>

<artifactId>jedis</artifactId>

<version>2.8.0</version> <!-- 最近升级了 -->

</dependency>

2. spring配置文件中配置JedisCluster

<bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">

<property name="maxTotal" value="4096"/>

<property name="maxIdle" value="200"/>

<property name="maxWaitMillis" value="3000"/>

<property name="testOnBorrow" value="true" />

<property name="testOnReturn" value="true" />

</bean>

<bean id = "jedisCluster" class = "redis.clients.jedis.JedisCluster">

<constructor-arg index="0">

<set>

<bean class="redis.clients.jedis.HostAndPort">

<constructor-arg index="0" value="192.168.1.142" />

<constructor-arg index="1" value="7002" />

</bean>

</set>

</constructor-arg>

<constructor-arg index="1" value="2000" type="int"/>

<constructor-arg index="2" value="2" type="int"/>

<constructor-arg index="3" ref="poolConfig"/>

</bean>

3.编写测试代码

@Test

public void basicOpTestForCluster(){

long begin = System.currentTimeMillis();

for(int i=0;i<10000; i++){

jedis.set("person." + i + ".name", "frank");

jedis.set("person." + i + ".city", "beijing");

String name = jedis.get("person." + i + ".name");

String city = jedis.get("person." + i + ".city");

assertEquals("frank",name);

assertEquals("beijing",city);

jedis.del("person." + i + ".name");

Boolean result = jedis.exists("person." + i + ".name");

assertEquals(false,result);

result = jedis.exists("person." + i + ".city");

assertEquals(true,result);

}

long end = System.currentTimeMillis(); 

System.out.println("total time: " + (end-begin)/1000);

}

 

上一篇:SQL语句将两个select语句查询结果合并一个


下一篇:Python利用Plotly实现对MySQL中的数据可视化