Redis集群基本介绍
Redis
集群是一个可以在多个 Redis
节点之间进行数据共享的设施installation
。
Redis
集群不支持那些需要同时处理多个键的 Redis
命令, 因为执行这些命令需要在多个 Redis
节点之间移动数据, 并且在高负载的情况下, 这些命令将降低Redis
集群的性能, 并导致不可预测的行为。
Redis
集群通过分区partition
来提供一定程度的可用性availability
: 即使集群中有一部分节点失效或者无法进行通讯, 集群也可以继续处理命令请求。
Redis
集群提供了以下两个好处:
- 将数据自动切分
split
到多个节点的能力。 - 当集群中的一部分节点失效或者无法进行通讯时, 仍然可以继续处理命令请求的能力。
- 将数据自动切分
Redis集群原理
所有的
redis
节点彼此互联(PING
-PONG
机制),内部使用二进制协议优化传输速度和带宽。节点的
fail
是通过集群中超过半数的节点检测失效时才生效。客户端与
redis
节点直连,不需要中间proxy
层.客户端不需要连接集群所有节点,连接集群中任何一个可用节点即可。redis-cluster
把所有的物理节点映射到[0-16383
]slot
上,cluster
负责维护node
<->slot
<->value
Redis
集群中内置了 16384
个哈希槽,当需要在 Redis
集群中放置一个 key-value
时,redis
先对key
使用 crc16
算法算出一个结果,然后把结果对 16384
求余数,这样每个 key
都会对应一个编号在 0-16383
之间的哈希槽,redis
会根据节点数量大致均等的将哈希槽映射到不同的节点
redis-cluster投票:容错
投票过程是集群中所有
master
参与,如果半数以上master
节点与master
节点通信超时(cluster-node-timeout
),认为当前master
节点挂掉.-
什么时候整个集群不可用(
cluster_state:fail
)?- 如果集群任意
master
挂掉,且当前master
没有slave
.集群进入fail
状态,也可以理解成集群的slot
映射[0-16383
]不完整时进入fail状态.-
redis-3.0.0.rc1
加入cluster-require-full-coverage
参数,默认关闭,打开集群兼容部分失败.
-
- 如果集群超过半数以上
master
挂掉,无论是否有slave
,集群进入fail
状态.
- 如果集群任意
Redis集群搭建
环境:Linux CentOS 7.2
1、新建一个redis-cluster目录,在目录中安装单个redis应用,参考【Redis】安装及简单使用,并复制5份,结构如下
2、对6份Redis配置文件进行配置,修改对应端口即可
配置文件redis.conf (配置文件小技巧:可以利用inlude包含公用配置文件,其他不同的文件内容可以覆盖)
# include redis-base.conf bind 192.168.1.1 #绑定服务器IP地址,不用使用127.0.0.1,绑定客户端可访问IP port 7001 #端口 daemonize yes #后台运行 pidfile redis_7001.pid #pid文件 logfile "/redis-7001/redis.log" #日志文件 maxmemory 10485760 #最大内存10M,一般为机器内存的3/4 maxmemory-policy volatile-lru #内存达到最大时策略,可选择其他策略 cluster-enabled yes #启用集群 cluster-config-file nodes-7001.conf #配置每个节点的配置文件 cluster-node-timeout 15000 #配置集群节点的超时时间,可改可不改 dir ./redis-7001/ # 目录
dbfilename dump-7001.rdb # 快照文件
3、编写集群启动脚本和停止脚本
启动脚本start-all.sh
cd redis-7001
./bin/redis-server redis.conf
cd ../redis-7002
./bin/redis-server redis.conf
cd ../redis-7003
./bin/redis-server redis.conf
cd ../redis-7004
./bin/redis-server redis.conf
cd ../redis-7005
./bin/redis-server redis.conf
cd ../redis-7006
./bin/redis-server redis.conf
停止脚本stop-all.sh
cd redis-7001
./bin/redis-cli -h 192.168.1.1 -p 7001 shutdown
cd ../redis-7002
./bin/redis-cli -h 192.168.1.1 -p 7002 shutdown
cd ../redis-7003
./bin/redis-cli -h 192.168.1.1 -p 7003 shutdown
cd ../redis-7004
./bin/redis-cli -h 192.168.1.1 -p 7004 shutdown
cd ../redis-7005
./bin/redis-cli -h 192.168.1.1 -p 7005 shutdown
cd ../redis-7006
./bin/redis-cli -h 192.168.1.1 -p 7006 shutdown
脚本放在redis-cluster中,给脚本授权
命令:chmod -u+x start-all.sh stop-all.sh
4、安装Redis的Cluster集群,需要使用Ruby命令(还可以采用源码安装ruby,推荐)
命令:yum install ruby // 安装ruby
命令:yum install rubygems //安装rubygems,最新版本ruby会自动安装rubygems
5、安装Redis的Ruby接口程序
命令:gem install redis
注意:可能出现安装错误,如下:ruby的版本够,解决方案参考:【Redis】安装 Redis接口时异常 ,系统ruby版本过低
6、创建集群,执行redis-trib.rb脚本,这个脚本在源文件的src目录中,可以拷贝到redis-cluster文件中
命令:cp /data/download/redis-4.0.11/src/redis-trib.rb /app/soft/redis-cluster/
启动6个redis实例,使用文件start-all.sh,命令:./start-all.sh,然后在创建集群
创建命令:ruby redis-trib.rb create --replicas 1 192.168.1.1:7001 192.168.1.1:7002 192.168.1.1:7003 192.168.1.1:7004 192.168.1.1:7005 192.168.1.1:7006
7、到此三主三从的redis集群已经搭建完成
查询Redis集群信息
集群创建成功登陆任意redis
结点查询集群中的节点情况。
1、客户端以集群方式登陆,命令:./redis-7001/bin/redis-cli -c -h 192.168.1.1 -p 7001
,其中-c
表示以集群方式连接redis
,-h
指定ip
地址,-p
指定端口号
2、查看节点信息,命令:./redis-7001/bin/redis-cli -c -h 192.168.1.1 -p 7001
3、查询集群状态信息,命令:cluster info
使用Jedis测试Redis集群
1、搭建环境项目,参考:【Redis】使用Jedis操作Redis
2、代码测试
@Test
public void run3 () throws IOException {
// 创建并填充节点信息
Set<HostAndPort> nodes = new HashSet<>();
nodes.add(new HostAndPort("192.168.1.1", 7001));
nodes.add(new HostAndPort("192.168.1.1", 7002));
nodes.add(new HostAndPort("192.168.1.1", 7003));
nodes.add(new HostAndPort("192.168.1.1", 7004));
nodes.add(new HostAndPort("192.168.1.1", 7005));
nodes.add(new HostAndPort("192.168.1.1", 7006)); // 创建JedisCluster对象
JedisCluster jedisCluster = new JedisCluster(nodes); // 使用jedisCluster操作redis
String key = "jedisCluster";
String setResult = jedisCluster.set(key, "hello redis!");
System.out.println(setResult); String getResult = jedisCluster.get(key);
System.out.println(getResult); // 关闭jedisCluster(程序执行完后才能关闭,内部封装了连接池)
jedisCluster.close(); }