`
hot66hot
  • 浏览: 457371 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

redis-cluster研究和使用

rediscluster分布式存储 
阅读更多
最近研究redis-cluster,正好搭建了一个环境,遇到了很多坑,系统的总结下,等到redis3 release出来后，换掉memCache 集群. 转载请注明出处哈:http://hot66hot.iteye.com/admin/blogs/2050676

一:关于redis cluster

1:redis cluster的现状

reids-cluster计划在redis3.0中推出，可以看作者antirez的声明:http://antirez.com/news/49 (ps:跳票了好久，今年貌似加快速度了),目前的最新版本见:https://raw.githubusercontent.com/antirez/redis/3.0/00-RELEASENOTES

作者的目标:Redis Cluster will support up to ~1000 nodes. 赞...

目前redis支持的cluster特性(已测试):

1):节点自动发现

2):slave->master 选举,集群容错

3):Hot resharding:在线分片

4):集群管理:cluster xxx

5):基于配置(nodes-port.conf)的集群管理

6):ASK 转向/MOVED 转向机制.

2:redis cluster 架构

1)redis-cluster架构图

 

架构细节:

(1)所有的redis节点彼此互联(PING-PONG机制),内部使用二进制协议优化传输速度和带宽.

(2)节点的fail是通过集群中超过半数的master节点检测失效时才生效.

(3)客户端与redis节点直连,不需要中间proxy层.客户端不需要连接集群所有节点,连接集群中任何一个可用节点即可

(4)redis-cluster把所有的物理节点映射到[0-16383]slot上,cluster 负责维护node<->slot<->key

2) redis-cluster选举:容错

 

(1)领着选举过程是集群中所有master参与,如果半数以上master节点与故障节点通信超过(cluster-node-timeout),认为该节点故障，自动触发故障转移操作.

(2):什么时候整个集群不可用(cluster_state:fail)? 

    a:如果集群任意master挂掉,且当前master没有slave.集群进入fail状态,也可以理解成集群的slot映射[0-16383]不完成时进入fail状态. ps : redis-3.0.0.rc1加入cluster-require-full-coverage参数,默认关闭,打开集群兼容部分失败.

    b:如果集群超过半数以上master挂掉，无论是否有slave集群进入fail状态.

  ps:当集群不可用时,所有对集群的操作做都不可用，收到((error) CLUSTERDOWN The cluster is down)错误

二:redis cluster的使用

1:安装redis cluster

1):安装redis-cluster依赖:redis-cluster的依赖库在使用时有兼容问题,在reshard时会遇到各种错误,请按指定版本安装.

(1)确保系统安装zlib,否则gem install会报(no such file to load -- zlib)
#download:zlib-1.2.6.tar
./configure
make
make install
 (2)安装ruby:version(1.9.2)
# ruby1.9.2 
cd /path/ruby
./configure -prefix=/usr/local/ruby
make
make install
sudo cp ruby /usr/local/bin
(3)安装rubygem:version(1.8.16)
# rubygems-1.8.16.tgz
cd /path/gem
sudo ruby setup.rb
sudo cp bin/gem /usr/local/bin
(4)安装gem-redis:version(3.0.0)
gem install redis --version 3.0.0
#由于源的原因，可能下载失败，就手动下载下来安装
#download地址:http://rubygems.org/gems/redis/versions/3.0.0
gem install -l /data/soft/redis-3.0.0.gem
(5)安装redis-cluster
cd /path/redis
make
sudo cp /opt/redis/src/redis-server /usr/local/bin
sudo cp /opt/redis/src/redis-cli /usr/local/bin
sudo cp /opt/redis/src/redis-trib.rb /usr/local/bin

 

2:配置redis cluster

1)redis配置文件结构:


 使用包含(include)把通用配置和特殊配置分离,方便维护.

2)redis通用配置.

#GENERAL
daemonize no
tcp-backlog 511
timeout 0
tcp-keepalive 0
loglevel notice
databases 16
dir /opt/redis/data
slave-serve-stale-data yes
#slave只读
slave-read-only yes
#not use default
repl-disable-tcp-nodelay yes
slave-priority 100
#打开aof持久化
appendonly yes
#每秒一次aof写
appendfsync everysec
#关闭在aof rewrite的时候对新的写操作进行fsync
no-appendfsync-on-rewrite yes
auto-aof-rewrite-min-size 64mb
lua-time-limit 5000
#打开redis集群
cluster-enabled yes
#节点互连超时的阀值
cluster-node-timeout 15000
cluster-migration-barrier 1
slowlog-log-slower-than 10000
slowlog-max-len 128
notify-keyspace-events ""
hash-max-ziplist-entries 512
hash-max-ziplist-value 64
list-max-ziplist-entries 512
list-max-ziplist-value 64
set-max-intset-entries 512
zset-max-ziplist-entries 128
zset-max-ziplist-value 64
activerehashing yes
client-output-buffer-limit normal 0 0 0
client-output-buffer-limit slave 256mb 64mb 60
client-output-buffer-limit pubsub 32mb 8mb 60
hz 10
aof-rewrite-incremental-fsync yes

3)redis特殊配置.

#包含通用配置
include /opt/redis/redis-common.conf
#监听tcp端口
port 6379
#最大可用内存
maxmemory 100m
#内存耗尽时采用的淘汰策略:
# volatile-lru -> remove the key with an expire set using an LRU algorithm
# allkeys-lru -> remove any key accordingly to the LRU algorithm
# volatile-random -> remove a random key with an expire set
# allkeys-random -> remove a random key, any key
# volatile-ttl -> remove the key with the nearest expire time (minor TTL)
# noeviction -> don't expire at all, just return an error on write operations
maxmemory-policy allkeys-lru
#aof存储文件
appendfilename "appendonly-6379.aof"
#不开启rdb存储,只用于添加slave过程
dbfilename dump-6379.rdb
#cluster配置文件(启动自动生成)
cluster-config-file nodes-6379.conf
#部署在同一机器的redis实例，把auto-aof-rewrite搓开，因为cluster环境下内存占用基本一致.
#防止同意机器下瞬间fork所有redis进程做aof rewrite,占用大量内存
auto-aof-rewrite-percentage 80-100

3:cluster 操作

cluster集群相关命令,更多redis相关命令见文档:http://redis.readthedocs.org/en/latest/

 

集群
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 槽中的键。
 

4:redis cluster 运维操作

1)初始化并构建集群

(1)启动集群相关节点（必须是无数据的空节点）,指定配置文件和输出日志

 

redis-server /opt/redis/conf/redis-6380.conf > /opt/redis/logs/redis-6380.log 2>&1 &
redis-server /opt/redis/conf/redis-6381.conf > /opt/redis/logs/redis-6381.log 2>&1 &
redis-server /opt/redis/conf/redis-6382.conf > /opt/redis/logs/redis-6382.log 2>&1 &
redis-server /opt/redis/conf/redis-7380.conf > /opt/redis/logs/redis-7380.log 2>&1 &
redis-server /opt/redis/conf/redis-7381.conf > /opt/redis/logs/redis-7381.log 2>&1 &
redis-server /opt/redis/conf/redis-7382.conf > /opt/redis/logs/redis-7382.log 2>&1 &

 

(2):使用自带的ruby工具(redis-trib.rb)构建集群

 

#redis-trib.rb的create子命令构建
#--replicas 则指定了为Redis Cluster中的每个Master节点配备几个Slave节点
#节点角色由顺序决定,先master之后是slave(为方便辨认,slave的端口比master大1000)
redis-trib.rb create --replicas 1 10.10.34.14:6380 10.10.34.14:6381 10.10.34.14:6382 10.10.34.14:7380 10.10.34.14:7381 10.10.34.14:7382

(3):检查集群状态

#redis-trib.rb的check子命令构建
#ip:port可以是集群的任意节点
redis-trib.rb check 10.10.34.14:6380
 最后输出如下信息,没有任何警告或错误，表示集群启动成功并处于ok状态 
[OK] All nodes agree about slots configuration.
>>> Check for open slots...
>>> Check slots coverage...
[OK] All 16384 slots covered.

2):添加新master节点

(1)添加一个master节点:创建一个空节点（empty node），然后将某些slot移动到这个空节点上,这个过程目前需要人工干预

a):根据端口生成配置文件(ps:establish_config.sh是我自己写的输出配置脚本)

 

sh establish_config.sh 6386 > conf/redis-6386.conf
 

b):启动节点

 

redis-server /opt/redis/conf/redis-6386.conf > /opt/redis/logs/redis-6386.log 2>&1 &

c):加入空节点到集群
add-node  将一个节点添加到集群里面， 第一个是新节点ip:port, 第二个是任意一个已存在节点ip:port

 

redis-trib.rb add-node 10.10.34.14:6386 10.10.34.14:6381

node:新节点没有包含任何数据， 因为它没有包含任何slot。新加入的加点是一个主节点， 当集群需要将某个从节点升级为新的主节点时， 这个新节点不会被选中，同时新的主节点因为没有包含任何slot，不参加选举和failover。

 

d):为新节点分配slot

 

redis-trib.rb reshard 10.10.34.14:6386
#根据提示选择要迁移的slot数量(ps:这里选择500)
How many slots do you want to move (from 1 to 16384)? 500
#选择要接受这些slot的node-id
What is the receiving node ID? f51e26b5d5ff74f85341f06f28f125b7254e61bf
#选择slot来源:
#all表示从所有的master重新分配，
#或者数据要提取slot的master节点id,最后用done结束
Please enter all the source node IDs.
  Type 'all' to use all the nodes as source nodes for the hash slots.
  Type 'done' once you entered all the source nodes IDs.
Source node #1:all
#打印被移动的slot后，输入yes开始移动slot以及对应的数据.
#Do you want to proceed with the proposed reshard plan (yes/no)? yes
#结束

3):添加新的slave节点

a):前三步操作同添加master一样

b)第四步:redis-cli连接上新节点shell,输入命令:cluster replicate 对应master的node-id

 

cluster replicate 2b9ebcbd627ff0fd7a7bbcc5332fb09e72788835
 

注意:在线添加slave 时，需要bgsave整个master数据，并传递到slave，再由 slave加载rdb文件到内存，rdb生成和传输的过程中消耗Master大量内存和网络IO,以此不建议单实例内存过大，线上小心操作。

例如本次添加slave操作产生的rdb文件

 

-rw-r--r-- 1 root root  34946 Apr 17 18:23 dump-6386.rdb
-rw-r--r-- 1 root root  34946 Apr 17 18:23 dump-7386.rdb

4):在线reshard 数据:

对于负载/数据不均匀的情况，可以在线reshard slot来解决,方法与添加新master的reshard一样，只是需要reshard的master节点是已存在的老节点.

5):删除一个slave节点

#redis-trib del-node ip:port '<node-id>'
redis-trib.rb del-node 10.10.34.14:7386 'c7ee2fca17cb79fe3c9822ced1d4f6c5e169e378'

 6):删除一个master节点

  a):删除master节点之前首先要使用reshard移除master的全部slot,然后再删除当前节点

     (redis-trib.rb一次只能把下线节点的slot迁移到一个节点上,如果需要均衡的迁移到其它节点需要执行多次reshard命令)

 

#把10.10.34.14:6386节点slot和数据迁移到10.10.34.14:6380上
redis-trib.rb reshard 10.10.34.14:6380
#根据提示选择要迁移的slot数量(ps:这里选择500)
How many slots do you want to move (from 1 to 16384)? 500(被删除master的所有slot数量)
#选择要接受这些slot的node-id(10.10.34.14:6380)
What is the receiving node ID? c4a31c852f81686f6ed8bcd6d1b13accdc947fd2 (ps:10.10.34.14:6380的node-id)
Please enter all the source node IDs.
  Type 'all' to use all the nodes as source nodes for the hash slots.
  Type 'done' once you entered all the source nodes IDs.
Source node #1:f51e26b5d5ff74f85341f06f28f125b7254e61bf(被删除master的node-id)
Source node #2:done
#打印被移动的slot后，输入yes开始移动slot以及对应的数据.
#Do you want to proceed with the proposed reshard plan (yes/no)? yes
 

b):删除空master节点

 

redis-trib.rb del-node 10.10.34.14:6386 'f51e26b5d5ff74f85341f06f28f125b7254e61bf'
三:redis cluster 客户端(Jedis)

1:客户端基本操作使用

 

 private static BinaryJedisCluster jc;
  static {
       //只给集群里一个实例就可以
        Set<HostAndPort> jedisClusterNodes = new HashSet<HostAndPort>();
        jedisClusterNodes.add(new HostAndPort("10.10.34.14", 6380));
        jedisClusterNodes.add(new HostAndPort("10.10.34.14", 6381));
        jedisClusterNodes.add(new HostAndPort("10.10.34.14", 6382));
        jedisClusterNodes.add(new HostAndPort("10.10.34.14", 6383));
        jedisClusterNodes.add(new HostAndPort("10.10.34.14", 6384));
        jedisClusterNodes.add(new HostAndPort("10.10.34.14", 7380));
        jedisClusterNodes.add(new HostAndPort("10.10.34.14", 7381));
        jedisClusterNodes.add(new HostAndPort("10.10.34.14", 7382));
        jedisClusterNodes.add(new HostAndPort("10.10.34.14", 7383));
        jedisClusterNodes.add(new HostAndPort("10.10.34.14", 7384));
        jc = new BinaryJedisCluster(jedisClusterNodes);
    }
@Test
    public void testBenchRedisSet() throws Exception {
        final Stopwatch stopwatch = new Stopwatch();
        List list = buildBlogVideos();
        for (int i = 0; i < 1000; i++) {
            String key = "key:" + i;
            stopwatch.start();
            byte[] bytes1 = protostuffSerializer.serialize(list);
            jc.setex(key, 60 * 60, bytes1);
            stopwatch.stop();
        }
        System.out.println("time=" + stopwatch.toString());
    }

2:redis-cluster客户端的一些坑.

1)cluster环境下slave默认不接受任何读写操作，在slave执行readonly命令后，可执行读操作

2)client端不支持多key操作(mget,mset等)，但当keys集合对应的slot相同时支持mget操作见:hash_tag

3)不支持多数据库，只有一个db，select 0。

4)JedisCluster 没有针对byte[]的API，需要自己扩展(附件是我加的基于byte[]的BinaryJedisCluster  api)

Jedis-2.8.0-SNAPSHOT 之后已支持BinaryJedisCluster和基于hash_tag的mget操作.

 

 

参考文档:

http://redis.io/topics/cluster-spec

http://redis.io/topics/cluster-tutorial

  • 大小: 43.6 KB
  • 大小: 29.5 KB
  • 大小: 28.6 KB
分享到：
| 分享MySQL操作规范
评论
29 楼 hot66hot 2015-11-03  
qqj_1979 写道
jedis  cluster 初始化时，没地方输入密码？

https://github.com/xetorthio/jedis/pull/966#issue-71806456
28 楼 qqj_1979 2015-11-02  
jedis  cluster 初始化时，没地方输入密码？
27 楼 javer 2015-08-07  
hot66hot 写道
javer 写道
javer 写道
hot66hot 写道
javer 写道
使用ShardedJedisPool连接池，获取cluster的一个连接，进行set操作时有时会报错
redis.clients.jedis.exceptions.JedisMovedDataException: MOVED xxx 127.0.0.1:xxxx
请问可能是哪儿的问题？

ShardedJedisPool是以前分片操作的API，不适用于cluster，
cluster环境用JedisCluster API， Jedis版本在2.7以上。

谢谢，我昨天刚搞明白。
顺便问下，你说的BinaryJedisCluster附件在哪儿呢？


没事，我以为单独的，原来是在你那个jar包里

jedis3.0已经支持BinaryJedisCluster,用Jedis官方的吧。
github:https://github.com/xetorthio/jedis/blob/a196d3e86e4dd686d4295e40233c42b2bb8d5cb0/src/main/java/redis/clients/jedis/BinaryJedisCluster.java


好的，谢谢提醒~
26 楼 hot66hot 2015-08-06  
javer 写道
javer 写道
hot66hot 写道
javer 写道
使用ShardedJedisPool连接池，获取cluster的一个连接，进行set操作时有时会报错
redis.clients.jedis.exceptions.JedisMovedDataException: MOVED xxx 127.0.0.1:xxxx
请问可能是哪儿的问题？

ShardedJedisPool是以前分片操作的API，不适用于cluster，
cluster环境用JedisCluster API， Jedis版本在2.7以上。

谢谢，我昨天刚搞明白。
顺便问下，你说的BinaryJedisCluster附件在哪儿呢？


没事，我以为单独的，原来是在你那个jar包里

jedis3.0已经支持BinaryJedisCluster,用Jedis官方的吧。
github:https://github.com/xetorthio/jedis/blob/a196d3e86e4dd686d4295e40233c42b2bb8d5cb0/src/main/java/redis/clients/jedis/BinaryJedisCluster.java
25 楼 javer 2015-08-06  
javer 写道
hot66hot 写道
javer 写道
使用ShardedJedisPool连接池，获取cluster的一个连接，进行set操作时有时会报错
redis.clients.jedis.exceptions.JedisMovedDataException: MOVED xxx 127.0.0.1:xxxx
请问可能是哪儿的问题？

ShardedJedisPool是以前分片操作的API，不适用于cluster，
cluster环境用JedisCluster API， Jedis版本在2.7以上。

谢谢，我昨天刚搞明白。
顺便问下，你说的BinaryJedisCluster附件在哪儿呢？


没事，我以为单独的，原来是在你那个jar包里
24 楼 javer 2015-08-06  
hot66hot 写道
javer 写道
使用ShardedJedisPool连接池，获取cluster的一个连接，进行set操作时有时会报错
redis.clients.jedis.exceptions.JedisMovedDataException: MOVED xxx 127.0.0.1:xxxx
请问可能是哪儿的问题？

ShardedJedisPool是以前分片操作的API，不适用于cluster，
cluster环境用JedisCluster API， Jedis版本在2.7以上。

谢谢，我昨天刚搞明白。
顺便问下，你说的BinaryJedisCluster附件在哪儿呢？
23 楼 hot66hot 2015-08-06  
javer 写道
使用ShardedJedisPool连接池，获取cluster的一个连接，进行set操作时有时会报错
redis.clients.jedis.exceptions.JedisMovedDataException: MOVED xxx 127.0.0.1:xxxx
请问可能是哪儿的问题？

ShardedJedisPool是以前分片操作的API，不适用于cluster，
cluster环境用JedisCluster API， Jedis版本在2.7以上。
22 楼 javer 2015-08-04  
使用ShardedJedisPool连接池，获取cluster的一个连接，进行set操作时有时会报错
redis.clients.jedis.exceptions.JedisMovedDataException: MOVED xxx 127.0.0.1:xxxx
请问可能是哪儿的问题？
21 楼 hot66hot 2015-07-08  
theday_2009 写道
请教一下，使用集群的JedisCluster，如何用pool连接池来操作，好像也没有pipeline的功能了，cli内如何检索更个集群的数据，而不是只检索一个port的数据

1)jedisCluster 维护整个集群节点的JedisPool列表，通过crc16计算key和slot的对应关系，在通过slot找到对应的jedisPool.
2:pipeline只能用于对应单个节点，不能对应集群操作。
3:“cli内如何检索更个集群的数据，而不是只检索一个port的数据”没看明白。
20 楼 theday_2009 2015-07-07  
请教一下，使用集群的JedisCluster，如何用pool连接池来操作，好像也没有pipeline的功能了，cli内如何检索更个集群的数据，而不是只检索一个port的数据
19 楼 larnsan 2015-06-02  
hot66hot 写道
yaogege 写道
我的每次都会出现这个问题？
是包不对吗？
请问应该怎么处理？
/var/lib/gems/1.8/gems/redis-3.2.1/lib/redis/client.rb:113:in `call': ERR Slot 15495 is already busy (Redis::CommandError)
from /var/lib/gems/1.8/gems/redis-3.2.1/lib/redis.rb:2556:in `method_missing'
from /var/lib/gems/1.8/gems/redis-3.2.1/lib/redis.rb:37:in `synchronize'
from /usr/lib/ruby/1.8/monitor.rb:242:in `mon_synchronize'
from /var/lib/gems/1.8/gems/redis-3.2.1/lib/redis.rb:37:in `synchronize'
from /var/lib/gems/1.8/gems/redis-3.2.1/lib/redis.rb:2555:in `method_missing'
from ./redis-trib.rb:205:in `flush_node_config'
from ./redis-trib.rb:657:in `flush_nodes_config'
from ./redis-trib.rb:656:in `each'
from ./redis-trib.rb:656:in `flush_nodes_config'
from ./redis-trib.rb:997:in `create_cluster_cmd'
from ./redis-trib.rb:1373:in `send'
from ./redis-trib.rb:1373

用redis-trib.rb check  ip:port检查下你的集群状态,
看错误应该是之前做过迁移失败了，
在slot=15495这个槽上正在分配中，尝试使用cluster setslot 15495 stable 取消对槽 slot 的导入或迁移

需要清理节点已配置的集群信息
18 楼 hot66hot 2015-06-02  
yaogege 写道
我的每次都会出现这个问题？
是包不对吗？
请问应该怎么处理？
/var/lib/gems/1.8/gems/redis-3.2.1/lib/redis/client.rb:113:in `call': ERR Slot 15495 is already busy (Redis::CommandError)
from /var/lib/gems/1.8/gems/redis-3.2.1/lib/redis.rb:2556:in `method_missing'
from /var/lib/gems/1.8/gems/redis-3.2.1/lib/redis.rb:37:in `synchronize'
from /usr/lib/ruby/1.8/monitor.rb:242:in `mon_synchronize'
from /var/lib/gems/1.8/gems/redis-3.2.1/lib/redis.rb:37:in `synchronize'
from /var/lib/gems/1.8/gems/redis-3.2.1/lib/redis.rb:2555:in `method_missing'
from ./redis-trib.rb:205:in `flush_node_config'
from ./redis-trib.rb:657:in `flush_nodes_config'
from ./redis-trib.rb:656:in `each'
from ./redis-trib.rb:656:in `flush_nodes_config'
from ./redis-trib.rb:997:in `create_cluster_cmd'
from ./redis-trib.rb:1373:in `send'
from ./redis-trib.rb:1373

用redis-trib.rb check  ip:port检查下你的集群状态,
看错误应该是之前做过迁移失败了，
在slot=15495这个槽上正在分配中，尝试使用cluster setslot 15495 stable 取消对槽 slot 的导入或迁移
17 楼 yaogege 2015-05-28  
我的每次都会出现这个问题？
是包不对吗？
请问应该怎么处理？
/var/lib/gems/1.8/gems/redis-3.2.1/lib/redis/client.rb:113:in `call': ERR Slot 15495 is already busy (Redis::CommandError)
from /var/lib/gems/1.8/gems/redis-3.2.1/lib/redis.rb:2556:in `method_missing'
from /var/lib/gems/1.8/gems/redis-3.2.1/lib/redis.rb:37:in `synchronize'
from /usr/lib/ruby/1.8/monitor.rb:242:in `mon_synchronize'
from /var/lib/gems/1.8/gems/redis-3.2.1/lib/redis.rb:37:in `synchronize'
from /var/lib/gems/1.8/gems/redis-3.2.1/lib/redis.rb:2555:in `method_missing'
from ./redis-trib.rb:205:in `flush_node_config'
from ./redis-trib.rb:657:in `flush_nodes_config'
from ./redis-trib.rb:656:in `each'
from ./redis-trib.rb:656:in `flush_nodes_config'
from ./redis-trib.rb:997:in `create_cluster_cmd'
from ./redis-trib.rb:1373:in `send'
from ./redis-trib.rb:1373
16 楼 hot66hot 2015-05-13  
wjhdtx 写道
hot66hot 写道
wjhdtx 写道
博主你好，spring redis的客户端目前支持redis3.0.0的集群吗？

jedis-3.0还在SNAPSHOT,现在的2.7可以使用，有些命令没有支持需要改jedis来适配。
github:https://github.com/xetorthio/jedis/tree/jedis-2.7.0


谢谢博主回复，我遇到的问题是：

我们之前用的spring的api来操作redis，如果换为jedis，工作量及稳定性测试需要一定的时间，和 http://stackoverflow.com/questions/29602657/spring-data-redis-with-cluster-support 这个问题一样，不知道博主有何建议？

自己适配一个redisTemplate吧，开发量不是很大。
15 楼 hot66hot 2015-05-13  
wzw_19850911 写道

jc = new BinaryJedisCluster(jedisClusterNodes, 120 * 1000);

JedisCluster timeout 超时单位是秒。
14 楼 hot66hot 2015-05-13  
wzw_19850911 写道
我用了楼主写的代码   连接不到redis集群  一直在重定向  请问是为啥呢 我的代码是这样的

我的集群部署在192.168.1.203上的  7000 7001 7002 7003 7004 7005这些端口上

重定向是指客户端报这个JedisClusterMaxRedirectionsException异常？
登录redis服务器，运行下 cluster info 命令线确认集群是否正常，slot是否完全覆盖。

13 楼 wzw_19850911 2015-05-11  
我用了楼主写的代码   连接不到redis集群  一直在重定向  请问是为啥呢 我的代码是这样的


public class Test2 {
private static BinaryJedisCluster jc; 
static {
//只给集群里一个实例就可以 
Set<HostAndPort> jedisClusterNodes = new HashSet<HostAndPort>();
jedisClusterNodes.add(new HostAndPort("192.168.1.203", 7000));
jedisClusterNodes.add(new HostAndPort("192.168.1.203", 7001));
jedisClusterNodes.add(new HostAndPort("192.168.1.203", 7002));
jedisClusterNodes.add(new HostAndPort("192.168.1.203", 7003));
jedisClusterNodes.add(new HostAndPort("192.168.1.203", 7004));
jedisClusterNodes.add(new HostAndPort("192.168.1.203", 7005));
jc = new BinaryJedisCluster(jedisClusterNodes, 120 * 1000);
}
 
public static void main(String[] args) throws Exception {
for (int i = 0; i < 10; i++) {
String res = jc.set("name" + i, "steven" + i);
System.out.println(res);
}
}
}


我的集群部署在192.168.1.203上的  7000 7001 7002 7003 7004 7005这些端口上
12 楼 wjhdtx 2015-04-24  
hot66hot 写道
wjhdtx 写道
博主你好，spring redis的客户端目前支持redis3.0.0的集群吗？

jedis-3.0还在SNAPSHOT,现在的2.7可以使用，有些命令没有支持需要改jedis来适配。
github:https://github.com/xetorthio/jedis/tree/jedis-2.7.0


谢谢博主回复，我遇到的问题是：

我们之前用的spring的api来操作redis，如果换为jedis，工作量及稳定性测试需要一定的时间，和 http://stackoverflow.com/questions/29602657/spring-data-redis-with-cluster-support 这个问题一样，不知道博主有何建议？
11 楼 hot66hot 2015-04-23  
wjhdtx 写道
博主你好，spring redis的客户端目前支持redis3.0.0的集群吗？

jedis-3.0还在SNAPSHOT,现在的2.7可以使用，有些命令没有支持需要改jedis来适配。
github:https://github.com/xetorthio/jedis/tree/jedis-2.7.0
10 楼 wjhdtx 2015-04-23  
博主你好，spring redis的客户端目前支持redis3.0.0的集群吗？
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    Reading-and-comprehense-redis-cluster_y123456yz.tar.gz

    分布式NOSQL redis源码阅读中文分析注释，带详尽注释以及相关流程调用注释，提出改造点，redis cluster集群功能、节点扩容、槽位迁移、failover故障切换、一致性选举完整分析，对理解redis源码很有帮助，解决了...

    DB-Redis-Cluster-Lib

    标题“DB-Redis-Cluster-Lib”...通过深入研究这个压缩包的内容，你可以获得实践经验，不仅学会如何部署和管理Redis集群，还能了解到集群环境中的常见问题及解决方案。这对于提升你的数据库管理和运维技能非常有帮助。

    南航移动Redis-Cluster趟坑记

    经过研究和测试环境的实践，2016年3月，Redis-Cluster正式投入生产使用。起初，缓存数据量较小，主要是系统配置信息，Redis-Cluster轻松应对。随后，团队将Redis-Cluster应用于机票信息和航班动态更新，显著提升了...

    redis-3.0-vs2017.zip

    Redis是世界上最受欢迎的开源内存数据结构存储系统，它可以用作数据库、缓存和消息代理。...同时，这个版本的Redis具备了当时最新的特性，如Stream和Cluster，以及经过优化的复制机制，是学习和研究Redis的宝贵资源。

    redis-7.0.0-x64-windows.rar

    7. **集群**: Redis Cluster是Redis的分布式解决方案，可以在多个节点之间分散数据，提供高可用性和可扩展性。用户可以通过集群来处理更大的数据量和更高的并发。 8. **安全**: Redis默认并不提供加密连接，但可以...

    开源项目-jw-s-redis-operator.zip

    2. `controllers/`: 包含了Redis运算符的主要逻辑，负责处理`RedisCluster`资源的创建、更新和删除事件。 3. `deploy/`: 提供了部署运算符到Kubernetes集群的yaml文件，包括服务账户、角色绑定和运算符部署。 4. `...

    redis-1.3.6.tar.gz

    在这个版本中，开发者可以研究 Redis 的核心数据结构和算法，如 SDS（Simple Dynamic Strings）替代 C 语言的原生字符串，以及ziplist 和 intset 等高效编码方式来节省内存。 解压 "redis-1.3.6.tar.gz" 文件后，你...

    linux redis-2[1].0.4.tar.gz

    了解Redis的基本操作后，你还可以深入研究它的高级特性，如Sorted Sets（有序集合）、HyperLogLog（基数估算）、Streams（数据流）等，以及主从复制、Sentinel高可用系统和Cluster分布式集群。 总的来说，"linux-...

    开源项目-go-redis-redis.zip

    【开源项目-go-redis-redis.zip】是一个包含Go语言实现...通过研究源代码和实践使用，开发者不仅可以学习到如何有效利用go-redis库，还能深入理解Redis Cluster的工作机制，提升自己在分布式存储和数据处理方面的技能。

    【Redis开发】资源Redis-v6.0.20.zip

    Redis，全称Remote Dictionary...总之，Redis-v6.0.20是一个值得研究和使用的版本，无论是初学者还是经验丰富的开发者，都能从中受益。通过学习和实践，你可以更好地掌握NoSQL数据库的应用，提升系统的性能和可扩展性。

    分布式缓存REDIS学习笔记

    01 Redis快速入门 - Redis教程 02-Redis环境安装 - Redis教程 03-Redis 的安装配置介绍 04-Redis数据类型 - Redis教程 05-Redis命令 - Redis教程 06-Redis键 - Redis教程。...27-redis-cluster研究和使用 。。。

    Redis--参考资料即总结

    6. **集群**：探究Redis Cluster，了解其分片、槽分配和故障检测机制，以及如何搭建和管理Redis集群。 7. **性能优化**：讨论内存管理策略，如过期策略、最大内存限制，以及如何调整配置以提升性能。 8. **安全**...

    redis-c#-web_winform解决方案集合.zip

    在实际开发中，还要考虑Redis的集群部署和高可用性，例如哨兵（Sentinel）系统和Redis Cluster，它们可以提供故障检测、自动故障转移和负载均衡。对于大型应用，还需要关注内存管理和数据淘汰策略，以确保资源的有效...

    xbhog-redis-master.zip

    7. **Cluster集群**：Redis Cluster提供了数据分区和高可用性，将数据分布在多个节点上，可以处理大量数据并避免单点故障。 8. **Lua脚本**：Redis支持内嵌的Lua脚本，可以在服务器端执行，提高了复杂操作的效率。 ...

    redis-demo.rar

    此外，还可以研究 Redis 的持久化策略、主从复制、Sentinel 系统和 Redis Cluster，以提升系统的稳定性和扩展性。 通过“redis-demo”，你可以深入理解 Redis 的消息队列功能，并将其应用到实际项目中。记得实践中...

    Redis数据库 v6.2.14.zip

    6.2.14可能对Redis Cluster进行了优化，提高了扩展性和可用性。 6. **持久化机制**：Redis支持RDB和AOF两种持久化方式，6.2.14可能对这两种方式的性能进行了改进，以确保数据在断电或故障后能够准确恢复。 7. **...

    Redis数据库 v6.0.20.zip

    8. **Cluster集群**：Redis Cluster提供了自动分片和故障转移的功能，支持大规模数据存储和高可用性。 9. **命令行接口**：Redis自带的`redis-cli`工具，是与Redis服务器交互的主要方式，也是进行测试和调试的重要...

    一种高效的Redis Cluster的分布式缓存系统.pdf

    在性能测试方面，本研究使用官方RedisBenchmark工具进行了QPS（每秒查询率）性能测试，并将RedisCluster与另一个流行的分布式缓存系统Codis进行了对比。实验结果表明，在高并发访问数（例如10000以上）的场景下，...

    Redis介绍，安装使用及集群介绍

    使用`redis-trib.rb`工具可以创建和管理集群，该工具位于`redis-3.0.3/utils`目录下。创建集群的基本步骤是： 1. 初始化节点：在每个节点上运行`redis-trib.rb create`命令，指定其他所有节点的IP和端口。 2. 加入...

    redis_cluster：一个开放式的nginx lua redis集群

    6. **Cluster集成**: 在"redis_cluster"项目中，开发者可能使用了OpenResty的lua模块和resty库来创建客户端，连接到Redis Cluster。这涉及到解析集群配置，发现节点，处理槽映射，以及在不同节点间进行命令路由。 7...

Magicbox
Global site tag (gtag.js) - Google Analytics