/** * 结合spring的redis单机版测试 */ @Test public void testSpringSingle(){ ApplicationContext context = new ClassPathXmlApplicationContext("classpath:/spring/applicationContext-*.xml"); JedisPool jedisPool = (JedisPool)context.getBean("redisClient"); Jedis jedis = jedisPool.getResource(); jedis.set("key1", "1111"); String str = jedis.get("key1"); System.out.println("--:"+str); jedis.close(); jedisPool.close(); }
这里可是自己封装一个工具类
package com.taotao.rest.dao.impl; import org.springframework.beans.factory.annotation.Autowired; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import com.taotao.rest.dao.JedisClient; /** * 在配置文件中注解 * * @author Administrator * */ public class JedisClientSingle implements JedisClient { @Autowired private JedisPool jedisPool; @Override public String get(String key) { Jedis jedis = jedisPool.getResource(); String str = jedis.get(key); jedis.close(); return str; } @Override public String set(String key, String value) { Jedis jedis = jedisPool.getResource(); String str = jedis.set(key, value); jedis.close(); return str; } @Override public String hget(String hkey, String key) { Jedis jedis = jedisPool.getResource(); String str = jedis.hget(hkey, key); jedis.close(); return str; } @Override public Long hset(String hkey, String key, String value) { Jedis jedis = jedisPool.getResource(); Long result = jedis.hset(hkey, key, value); jedis.close(); return result; } @Override public long incr(String key) { Jedis jedis = jedisPool.getResource(); Long result = jedis.incr(key); jedis.close(); return result; } @Override public long expire(String key, int seconds) { Jedis jedis = jedisPool.getResource(); Long result = jedis.expire(key, seconds); jedis.close(); return result; } @Override public long ttl(String key) { Jedis jedis = jedisPool.getResource(); Long result = jedis.ttl(key); return result; } @Override public long del(String key) { Jedis jedis = jedisPool.getResource(); Long result = jedis.del(key); return result; } @Override public long hdel(String hkey, String key) { Jedis jedis = jedisPool.getResource(); Long result = jedis.hdel(hkey, key); return result; } }
二、集群版redis搭建
1.1. 集群原理
1.1.1. redis-cluster架构图
架构细节:
(1)所有的redis节点彼此互联(PING-PONG机制),内部使用二进制协议优化传输速度和带宽.
(2)节点的fail是通过集群中超过半数的节点检测失效时才生效.
(3)客户端与redis节点直连,不需要中间proxy层.客户端不需要连接集群所有节点,连接集群中任何一个可用节点即可
(4)redis-cluster把所有的物理节点映射到[0-16383]slot上,cluster 负责维护node<->slot<->value
Redis 集群中内置了 16384 个哈希槽，当需要在 Redis 集群中放置一个 key-value 时，redis 先对 key 使用 crc16 算法算出一个结果，然后把结果对 16384 求余数，这样每个 key 都会对应一个编号在 0-16383 之间的哈希槽，redis 会根据节点数量大致均等的将哈希槽映射到���同的节点
1.1.2. redis-cluster投票:容错
(1)领着投票过程是集群中所有master参与,如果半数以上master节点与master节点通信超过(cluster-node-timeout),认为当前master节点挂掉.
(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)错误
2.安装ruby环境
redis集群管理工具redis-trib.rb依赖ruby环境，首先需要安装ruby环境：
安装ruby
yum install ruby yum install rubygems
安装ruby和redis的接口程序（需要安装文件redis-3.0.0.gem）
拷贝redis-3.0.0.gem至/usr/local下
执行：
gem install /usr/local/redis-3.0.0.gem
3.集群节点的规划
这里在同一台服务器用不同的端口表示不同的redis服务器，如下：
主节点：192.168.198.130:7001 192.168.198.130:7002 192.168.198.130:7003
从节点：192.168.198.130:7004 192.168.198.130:7005 192.168.198.130:7006
在/usr/local下创建redis-cluster目录，其下创建7001、7002。。7006目录，如下
将redis安装目录bin下的文件拷贝到每个700X目录内，同时修改每个的redis.conf中的端口为7001-7006，同时释放出redis.conf中的注释的
同时将redis源码目录src下的redis-trib.rb拷贝到redis-cluster目录下
[root@localhost redis-cluster]# cp /usr/soft/redis-3.0.7/src/redis-trib.rb /usr/local/redis-cluster/
使用后台启动的方式启动每个redis
执行redis-trib.rb，此脚本是ruby脚本，它依赖ruby环境