Redis使用

package com.test.util;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.serializer.SerializerFeature;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.List;
import java.util.Map;

public abstract class JsonUtil {
private static transient Logger log = LoggerFactory.getLogger(JsonUtil.class);

/**
* 反序列化
*
* @param s
* @return
*/
public static Object deserialize(String s) {

return deserialize(s,Object.class);
}
/**
* 反序列化
*
* @param s
* @param cls
* @return
*/
public static Object deserialize(String s, Class<?> cls) {
Object vo = null;
if (s != null && s.trim().length() > 0) {
try {
vo = JSON.parseObject(s, cls);
} catch (Exception e) {
log.error("deserialize error:" + s, e);
}
}
return vo;
}
/**
* 序列化
*
* @param obj
* @return
*/
public static String serialize(Object obj) {
String jsonString = null;
if (obj != null) {
try {
jsonString = JSON.toJSONString(obj, SerializerFeature.WriteDateUseDateFormat);
} catch (Exception e) {
log.error("serialize error:", e);
}
}
return jsonString;
}

/**
* 实体转map
* @param obj
* @return
*/
public static Map toMap(Object obj) {
if (obj instanceof Map) {
return (Map) obj;
} else {
return (Map)deserialize(serialize(obj));
}
}

/**
* 将list内的元素转成MAP
* @param list
* @return
*/
public static List<Map> listItemToMap(List list){
return (List<Map>) deserialize(serialize(list));
}

/**
* Json字符串特殊字符处理
* @param s
* @return String
*/
public static String filterJsonString(String s) {
StringBuffer sb = new StringBuffer();
for (int i=0; i<s.length(); i++) {
char c = s.charAt(i);
switch (c){
case '\"':
sb.append("\\\"");
break;
case '\\':
sb.append("\\\\");
break;
case '/':
sb.append("\\/");
break;
case '\b':
sb.append("\\b");
break;
case '\f':
sb.append("\\f");
break;
case '\n':
sb.append("\\n");
break;
case '\r':
sb.append("\\r");
break;
case '\t':
sb.append("\\t");
break;
default:
sb.append(c);
}
}
return sb.toString();
}
}

package com.test.redis;

import com.test.util.JsonUtil;
import org.apache.commons.collections4.CollectionUtils;
import org.springframework.beans.factory.annotation.Autowired;
import redis.clients.jedis.*;
import java.io.Closeable;
import java.util.*;
import java.util.concurrent.atomic.AtomicInteger;

public class RedisHelper implements Closeable {
@Autowired
JedisConnFactory factory;
private AtomicInteger count = new AtomicInteger(0);

private ThreadLocal<Jedis> master = new ThreadLocal<>();
private ThreadLocal<Jedis> slave = new ThreadLocal<>();

private Jedis getMaster(){
Jedis masterJedis = master.get();

if(masterJedis == null){
masterJedis = factory.getMaster();
master.set(masterJedis);
}

return masterJedis;
}

private Jedis getSlave(){
Jedis slaveJedis = slave.get();

if(slaveJedis == null){
slaveJedis = factory.getSlave();
slave.set(slaveJedis);
}

return slaveJedis;
}

/**
* 获得管道
* @return
*/
public Pipeline getPipeline(){
Jedis jedis = getMaster();
return jedis.pipelined();
}

/**
* 存储数据到缓存中，若key已存在则覆盖 value的长度不能超过1073741824 bytes (1 GB)
*
* @param key
* @param value
* @return
*/
public String set(String key, String value){
String ret;
Jedis jedis = getMaster();
ret = jedis.set(key,value);

return ret;
}

/**
* 存储数据到缓存中，并制定过期时间和当Key存在时是否覆盖。
*
* @param key
* @param value
* @param nxxx
*            nxxx的值只能取NX或者XX，如果取NX，则只有当key不存在时才进行set，如果取XX，则只有当key已经存在时才进行set
*
* @param expx expx的值只能取EX或者PX，代表数据过期时间的单位，EX代表秒，PX代表毫秒。
* @param time 过期时间，单位是expx所代表的单位。
* @return
*/
public String set(String key, String value, String nxxx, String expx, long time){
String ret;
Jedis jedis = getMaster();
ret = jedis.set(key, value, nxxx, expx, time);

return ret;
}

/**
* 从缓存中根据key取得其String类型的值，如果key不存在则返回null，如果key存在但value不是string类型的，
* 则返回一个error。这个方法只能从缓存中取得value为string类型的值。
*
* @param key
* @return
*/
public String get(String key){
String ret;
Jedis jedis = getSlave();
ret = jedis.get(key);

return ret;
}

/**
* 检查某个key是否在缓存中存在，如果存在返回true，否则返回false；需要注意的是，即使该key所对应的value是一个空字符串，
* 也依然会返回true。
*
* @param key
* @return
*/
public Boolean exists(String key){
Boolean ret = Boolean.FALSE;

Jedis jedis = getMaster();
ret = jedis.exists(key);

return ret;
}

/**
*
* 如果一个key设置了过期时间，则取消其过期时间，使其永久存在。
*
* @param key
* @return 返回1或者0,1代表取消过期时间成功，0代表不成功(只有当key不存在时这种情况才会发生)
*/
public Long persist(String key){
Long ret;
Jedis jedis = getMaster();
ret = jedis.persist(key);

return ret;
}

/**
* 返回某个key所存储的数据类型，返回的数据类型有可能是"none", "string", "list", "set", "zset",
* "hash". "none"代表key不存在。
*
* @param key
* @return
*/
public String type(String key){
String ret;
Jedis jedis = getMaster();
ret = jedis.type(key);

return ret;
}

/**
* 将指定key的值减少某个值
*
* @param key
* @param integer
* @return 返回减少后的新值
*/
public Long decrBy(String key, long integer){
Long ret;
Jedis jedis = getMaster();
ret = jedis.decrBy(key,integer);

return ret;
}

/**
* 将指定Key的值减少1
*
* @param key
* @return 返回减少后的新值
*/
public Long decr(String key){
Long ret;
Jedis jedis = getMaster();
ret = jedis.decr(key);

return ret;
}

/**
* 将指定的key的值增加指定的值
*
* @param key
* @param integer
* @return 返回增加后的新值
*/
public Long incrBy(String key, long integer){
Long ret;
Jedis jedis = getMaster();
ret = jedis.incrBy(key,integer);

return ret;
}

/**
* 将指定的key的值增加指定的值(浮点数)
*
* @param key
* @param value
* @return 返回增加后的新值
*/
public Double incrByFloat(String key, double value){
Double ret;
Jedis jedis = getMaster();
ret = jedis.incrByFloat(key,value);

return ret;
}

/**
* 将指定的key的值增加1
*
* @param key
* @return 返回增加后的新值
*/
public Long incr(String key){
Long ret;
Jedis jedis = getMaster();
ret = jedis.incr(key);

return ret;
}

/**
* 若key存在，将value追加到原有字符串的末尾。若key不存在，则创建一个新的空字符串。
*
* @param key
* @param value
* @return 返回字符串的总长度
*/
public Long append(String key, String value){
Long ret;
Jedis jedis = getMaster();
ret = jedis.append(key,value);

return ret;
}

/**
* 删除一个Key,如果删除的key不存在，则直接忽略。
*
* @param key
* @return 被删除的keys的数量
*/
public Long del(String key){
Long ret;
Jedis jedis = getMaster();
ret = jedis.del(key);
return ret;
}

/**
* 删除多个key
* @param keys
* @return
*/
public Long del(String ...keys){
Long ret;
Jedis jedis = getMaster();
ret = jedis.del(keys);

return ret;
}

/**
* 设置hash表里field字段的值为value。如果key不存在，则创建一个新的hash表
*
* @param key
* @param field
* @param value
* @return 如果该字段已经存在，那么将会更新该字段的值，返回0.如果字段不存在，则新创建一个并且返回1.
*/
public Long hset(String key,String field,String value){
Long ret;
Jedis jedis = getMaster();
ret = jedis.hset(key, field, value);

return ret;
}

/**
* 当字段不存在时，才进行set。
*
* @param key
* @param field
* @param value
* @return 如果该字段已经存在，则返回0.若字段不存在，则创建后set，返回1.
*/
public Long hsetnx(String key, String field, String value){
Long ret;
Jedis jedis = getMaster();
ret = jedis.hsetnx(key, field, value);

return ret;
}

/**
* 设置多个字段和值，如果字段存在，则覆盖。
*
* @param key
* @param map
* @return 设置成功返回OK，设置不成功则返回EXCEPTION
*/
public Long hmset(String key,Map map){
final Long ret = 0l;
Jedis jedis = getMaster();
jedis.hmset(key,map);

return ret;
}

/**
* 如果该key对应的值是一个Hash表，则返回对应字段的值。 如果不存在该字段，或者key不存在，则返回一个"nil"值。
*
* @param key
* @param field
* @return
*/
public String hget(String key,String field){
String ret;
Jedis jedis = getSlave();
ret = jedis.hget(key, field);

return ret;
}

/**
* 在hash中获取多个字段的值，若字段不存在，则其值为nil。
*
* @param key
* @param fields
* @return 按顺序返回多个字段的值。
*/
public List<String> hmget(String key, String... fields){
List<String> ret = new ArrayList();

Jedis jedis = getSlave();
ret = jedis.hmget(key, fields);

return ret;
}

/**
* 对hash中指定字段的值增加指定的值
*
* @param key
* @param field
* @param value
* @return 返回增加后的新值
*/
public Long hincrBy(String key, String field, long value){
Long ret;
Jedis jedis = getMaster();
ret = jedis.hincrBy(key, field, value);

return ret;
}

/**
* 判断hash中指定字段是否存在
*
* @param key
* @param field
* @return 若存在返回1，若不存在返回0
*/
public Boolean hexists(String key, String field){
Boolean ret;
Jedis jedis = getMaster();
ret = jedis.hexists(key, field);

return ret;
}

/**
* 删除hash中指定字段
*
* @param key
* @param field
* @return 删除成功返回1， 删除不成功返回0
*/
public Long hdel(String key, String... field){
Long ret;
Jedis jedis = getMaster();
ret = jedis.hdel(key, field);

return ret;
}

/**
* 返回 key 指定的哈希集包含的字段的数量
*
* @param key
* @return 哈希集中字段的数量，当 key 指定的哈希集不存在时返回 0
*/
public Long hlen(String key){
Long ret;
Jedis jedis = getSlave();
ret = jedis.hlen(key);

return ret;
}

/**
* 返回 key 指定的哈希集中所有字段的名字。
*
* @param key
* @return 哈希集中的字段列表，当 key 指定的哈希集不存在时返回空列表。
*/
public Set<String> hkeys(String key){
Set<String>  ret;
Jedis jedis = getSlave();
ret = jedis.hkeys(key);

return ret;
}

/**
* 返回 key 指定的哈希集中所有字段的值。
*
* @param key
* @return 哈希集中的值的列表，当 key 指定的哈希集不存在时返回空列表。
*/
public List<String> hvals(String key){
List<String> ret = new ArrayList();
Jedis jedis = getSlave();
ret = jedis.hvals(key);

return ret;
}

/**
* 返回 key 指定的哈希集中所有的字段和值
*
* @param key
* @return 返回 key 指定的哈希集中所有的字段和值,若key不存在返回空map。
*/
public Map hgetAll(String key){
Map ret;
Jedis jedis = getSlave();
ret = jedis.hgetAll(key);

return ret;
}
/**
* 一次从获取多个key对应的hash表，并放到list中
*
* @param keys
* @return List
*/
public List<Map> hgetAll(String ...keys){
List<Map>ret = new ArrayList();
Jedis jedis = getSlave();
Map map;
for(int i = 0;i < keys.length;i++){
map = jedis.hgetAll(keys[i]);
ret.add(map);
}

return ret;
}

/**
* 向存于 key 的列表的尾部插入所有指定的值。如果 key 不存在，那么会创建一个空的列表然后再进行 push 操作。 当 key
* 保存的不是一个列表，那么会返回一个错误。
*
* 可以使用一个命令把多个元素打入队列，只需要在命令后面指定多个参数。元素是从左到右一个接一个从列表尾部插入。 比如命令 RPUSH mylist a
* b c 会返回一个列表，其第一个元素是 a ，第二个元素是 b ，第三个元素是 c。
*
* @param key
* @param string
* @return 在 push 操作后的列表长度。
*/
public Long rpush(String key, String... string){
Long ret;
Jedis jedis = getMaster();
ret = jedis.rpush(key, string);

return ret;
}

/**
* 将所有指定的值插入到存于 key 的列表的头部。如果 key 不存在，那么在进行 push 操作前会创建一个空列表。 如果 key
* 对应的值不是一个 list 的话，那么会返回一个错误。
*
* 可以使用一个命令把多个元素 push 进入列表，只需在命令末尾加上多个指定的参数。元素是从最左端的到最右端的、一个接一个被插入到 list
* 的头部。 所以对于这个命令例子 LPUSH mylist a b c，返回的列表是 c 为第一个元素， b 为第二个元素， a 为第三个元素。
*
* @param key
* @param string
* @return 在 push 操作后的列表长度。
*/
public Long lpush(String key, String... string){
Long ret;
Jedis jedis = getMaster();
ret = jedis.lpush(key, string);

return ret;
}

/**
* 返回存储在 key 里的list的长度。 如果 key 不存在，那么就被看作是空list，并且返回长度为 0。 当存储在 key
* 里的值不是一个list的话，会返回error。
*
* @param key
* @return key对应的list的长度。
*/
public Long llen(String key){
Long ret;
Jedis jedis = getSlave();
ret = jedis.llen(key);

return ret;
}

/**
* 返回存储在 key 的列表里指定范围内的元素。 start 和 end
* 偏移量都是基于0的下标，即list的第一个元素下标是0（list的表头），第二个元素下标是1，以此类推。
*
* 偏移量也可以是负数，表示偏移量是从list尾部开始计数。 例如， -1 表示列表的最后一个元素，-2 是倒数第二个，以此类推。
*
* @param key
* @param start
* @param end
* @return 指定范围里的列表元素。
*/
public List<String> lrange(String key, long start, long end){
List<String> ret;
Jedis jedis = getSlave();
ret = jedis.lrange(key,start,end);

return ret;
}

/**
* 修剪(trim)一个已存在的 list，这样 list 就会只包含指定范围的指定元素。start 和 stop 都是由0开始计数的， 这里的 0
* 是列表里的第一个元素（表头），1 是第二个元素，以此类推。
*
* @param key
* @param start
* @param end
* @return
*/
public String ltrim(String key, long start, long end){
String ret;
Jedis jedis = getMaster();
ret = jedis.ltrim(key,start,end);

return ret;
}

/**
* 返回列表里的元素的索引 index 存储在 key 里面。 下标是从0开始索引的，所以 0 是表示第一个元素， 1 表示第二个元素，并以此类推。
* 负数索引用于指定从列表尾部开始索引的元素。在这种方法下，-1 表示最后一个元素，-2 表示倒数第二个元素，并以此往前推。
*
* 当 key 位置的值不是一个列表的时候，会返回一个error。
*
* @param key
* @param index
* @return 请求的对应元素，或者当 index 超过范围的时候返回 nil。
*/
public String lindex(String key, long index){
String ret;
Jedis jedis = getSlave();
ret = jedis.lindex(key,index);

return ret;
}

/**
* 设置 index 位置的list元素的值为 value。
*
* 当index超出范围时会返回一个error。
*
* @param key
* @param index
* @param value
* @return 状态恢复
*/
public String lset(String key, long index, String value){
String ret;
Jedis jedis = getMaster();
ret = jedis.lset(key,index,value);

return ret;
}

/**
* 从存于 key 的列表里移除前 count 次出现的值为 value 的元素。 这个 count 参数通过下面几种方式影响这个操作：
*
* count > 0: 从头往尾移除值为 value 的元素。 count < 0: 从尾往头移除值为 value 的元素。 count = 0:
* 移除所有值为 value 的元素。
*
* 比如， LREM list -2 "hello" 会从存于 list 的列表里移除最后两个出现的 "hello"。
*
* 需要注意的是，如果list里没有存在key就会被当作空list处理，所以当 key 不存在的时候，这个命令会返回 0。
*
* @param key
* @param count
* @param value
* @return 返回删除的个数
*/
public Long lrem(String key, long count, String value){
Long ret;
Jedis jedis = getMaster();
ret = jedis.lrem(key,count,value);

return ret;
}

/**
* 移除并且返回 key 对应的 list 的第一个元素。
*
* @param key
* @return 返回第一个元素的值，或者当 key 不存在时返回 nil。
*/
public String lpop(String key){
String ret;
Jedis jedis = getMaster();
ret = jedis.lpop(key);

return ret;
}

/**
* 移除并返回存于 key 的 list 的最后一个元素。
*
* @param key
* @return 最后一个元素的值，或者当 key 不存在的时候返回 nil。
*/
public String rpop(String key){
String ret;
Jedis jedis = getMaster();
ret = jedis.rpop(key);

return ret;
}

/**
* 添加一个或多个指定的member元素到集合的 key中.指定的一个或者多个元素member 如果已经在集合key中存在则忽略.如果集合key
* 不存在，则新建集合key,并添加member元素到集合key中.
*
* 如果key 的类型不是集合则返回错误.
*
* @param key
* @param member
* @return 返回新成功添加到集合里元素的数量，不包括已经存在于集合中的元素.
*/
public Long sadd(String key, String... member){
Long ret;
Jedis jedis = getMaster();
ret = jedis.sadd(key,member);

return ret;
}

/**
* 返回key集合所有的元素.
*
* 该命令的作用与使用一个参数的SINTER 命令作用相同.
*
* @param key
* @return 集合中的所有元素.
*/
public Set<String> smembers(String key){
Set<String> ret;
Jedis jedis = getSlave();
ret = jedis.smembers(key);

return ret;
}

/**
* 在key集合中移除指定的元素. 如果指定的元素不是key集合中的元素则忽略 如果key集合不存在则被视为一个空的集合，该命令返回0.
*
* 如果key的类型不是一个集合,则返回错误.
*
* @param key
* @param member
* @return 从集合中移除元素的个数，不包括不存在的成员.
*/
public Long srem(String key, String... member){
Long ret;
Jedis jedis = getMaster();
ret = jedis.srem(key,member);

return ret;
}

/**
* 移除并返回一个集合中的随机元素
*
* 该命令与 SRANDMEMBER相似,不同的是srandmember命令返回一个随机元素但是不移除.
*
* @param key
* @return 被移除的元素, 当key不存在的时候返回 nil .
*/
public String spop(String key){
String ret;
Jedis jedis = getMaster();
ret = jedis.spop(key);

return ret;
}

/**
* 移除并返回多个集合中的随机元素
*
* @param key
* @param count
* @return 被移除的元素, 当key不存在的时候值为 nil .
*/
public Set<String> spop(String key, long count){
Set<String> ret;
Jedis jedis = getMaster();
ret = jedis.spop(key,count);

return ret;
}

/**
* 返回集合存储的key的基数 (集合元素的数量).
*
* @param key
* @return 集合的基数(元素的数量),如果key不存在,则返回 0.
*/
public Long scard(String key){
Long ret;
Jedis jedis = getSlave();
ret = jedis.scard(key);

return ret;
}

/**
* 返回成员 member 是否是存储的集合 key的成员.
*
* @param key
* @param member
* @return 如果member元素是集合key的成员，则返回1.如果member元素不是key的成员，或者集合key不存在，则返回0
*/
public Boolean sismember(String key, String member){
Boolean ret;
Jedis jedis = getSlave();
ret = jedis.sismember(key,member);

return ret;
}

/**
* 仅提供key参数,那么随机返回key集合中的一个元素.该命令作用类似于SPOP命令, 不同的是SPOP命令会将被选择的随机元素从集合中移除,
* 而SRANDMEMBER仅仅是返回该随记元素,而不做任何操作.
*
* @param key
* @return 返回随机的元素,如果key不存在则返回nil
*/
public String srandmember(String key){
String ret;
Jedis jedis = getSlave();
ret = jedis.srandmember(key);

return ret;
}

/**
* 如果count是整数且小于元素的个数，返回含有 count
* 个不同的元素的数组,如果count是个整数且大于集合中元素的个数时,仅返回整个集合的所有元素
* ,当count是负数,则会返回一个包含count的绝对值的个数元素的数组
* ，如果count的绝对值大于元素的个数,则返回的结果集里会出现一个元素出现多次的情况.
*
* @param key
* @param count
* @return 返回一个随机的元素数组,如果key不存在则返回一个空的数组.
*/
public List<String> srandmember(String key, int count){
List<String> ret;
Jedis jedis = getSlave();
ret = jedis.srandmember(key,count);

return ret;
}

/**
* 返回key的string类型value的长度。如果key对应的非string类型，就返回错误。
*
* @param key
* @return key对应的字符串value的长度，或者0（key不存在）
*/
public Long strlen(String key){
Long ret;
Jedis jedis = getSlave();
ret = jedis.strlen(key);

return ret;
}

/**
* 该命令添加指定的成员到key对应的有序集合中，每个成员都有一个分数。你可以指定多个分数/成员组合。如果一个指定的成员已经在对应的有序集合中了，
* 那么其分数就会被更新成最新的
* ，并且该成员会重新调整到正确的位置，以确保集合有序。如果key不存在，就会创建一个含有这些成员的有序集合，就好像往一个空的集合中添加一样
* 。如果key存在，但是它并不是一个有序集合，那么就返回一个错误。
*
* 分数的值必须是一个表示数字的字符串，并且可以是double类型的浮点数。
*
* @param key
* @param score
* @param member
* @return 返回添加到有序集合中元素的个数，不包括那种已经存在只是更新分数的元素。
*/
public Long zadd(String key, double score, String member){
Long ret;
Jedis jedis = getMaster();
ret = jedis.zadd(key, score, member);

return ret;
}

/**
* 该命令添加指定的成员到key对应的有序集合中，每个成员都有一个分数。你可以指定多个分数/成员组合。如果一个指定的成员已经在对应的有序集合中了，
* 那么其分数就会被更新成最新的
* ，并且该成员会重新调整到正确的位置，以确保集合有序。如果key不存在，就会创建一个含有这些成员的有序集合，就好像往一个空的集合中添加一样
* 。如果key存在，但是它并不是一个有序集合，那么就返回一个错误。
*
* 分数的值必须是一个表示数字的字符串，并且可以是double类型的浮点数。
*
* @param key
* @param scoreMembers
* @return 返回添加到有序集合中元素的个数，不包括那种已经存在只是更新分数的元素。
*/
public Long zadd(String key, Map<String, Double> scoreMembers){
Long ret;
Jedis jedis = getMaster();
ret = jedis.zadd(key, scoreMembers);

return ret;
}

/**
* 返回有序集key中，指定区间内的成员。其中成员按score值递增(从小到大)来排序。具有相同score值的成员按字典序来排列。
*
* 如果你需要成员按score值递减(score相等时按字典序递减)来排列，请使用ZREVRANGE命令。
* 下标参数start和stop都以0为底，也就是说，以0表示有序集第一个成员，以1表示有序集第二个成员，以此类推。
* 你也可以使用负数下标，以-1表示最后一个成员，-2表示倒数第二个成员，以此类推。
*
* 超出范围的下标并不会引起错误。如果start的值比有序集的最大下标还要大，或是start >
* stop时，ZRANGE命令只是简单地返回一个空列表。
* 另一方面，假如stop参数的值比有序集的最大下标还要大，那么Redis将stop当作最大下标来处理。
*
* @param key
* @param start
* @param end
* @return 指定范围的元素列表
*/
public Set<String> zrange(String key, long start, long end){
Set<String> ret;
Jedis jedis = getSlave();
ret = jedis.zrange(key, start,end);

return ret;
}

/**
* 从集合中删除指定member元素，当key存在，但是其不是有序集合类型，就返回一个错误。
*
* @param key
* @param member
* @return 返回的是从有序集合中删除的成员个数，不包括不存在的成员。
*/
public Long zrem(String key, String... member){
Long ret;
Jedis jedis = getMaster();
ret = jedis.zrem(key, member);

return ret;
}

/**
* 为有序集key的成员member的score值加上增量increment。如果key中不存在member，就在key中添加一个member，
* score是increment（就好像它之前的score是0.0）。如果key不存在，就创建一个只含有指定member成员的有序集合。
*
* 当key不是有序集类型时，返回一个错误。
*
* score值必须整数值或双精度浮点数。也有可能给一个负数来减少score的值。
*
* @param key
* @param score
* @param member
* @return member成员的新score值.
*/
public Double zincrby(String key, double score, String member){
Double ret;
Jedis jedis = getMaster();
ret = jedis.zincrby(key, score, member);

return ret;
}

/**
* 返回有序集key中成员member的排名。其中有序集成员按score值递增(从小到大)顺序排列。排名以0为底，也就是说，
* score值最小的成员排名为0。
*
* 使用ZREVRANK命令可以获得成员按score值递减(从大到小)排列的排名。
*
* @param key
* @param member
* @return 如果member是有序集key的成员，返回member的排名的整数。 如果member不是有序集key的成员，返回 nil。
*/
public Long zrank(String key, String member){
Long ret;
Jedis jedis = getSlave();
ret = jedis.zrank(key, member);

return ret;
}

/**
* 返回有序集key中成员member的排名，其中有序集成员按score值从大到小排列。排名以0为底，也就是说，score值最大的成员排名为0。
*
* 使用ZRANK命令可以获得成员按score值递增(从小到大)排列的排名。
*
* @param key
* @param member
* @return 如果member是有序集key的成员，返回member的排名。整型数字。 如果member不是有序集key的成员，返回Bulk
*         reply: nil.
*/
public Long zrevrank(String key, String member){
Long ret;
Jedis jedis = getSlave();
ret = jedis.zrevrank(key, member);

return ret;
}

/**
* 返回有序集key中，指定区间内的成员。其中成员的位置按score值递减(从大到小)来排列。具有相同score值的成员按字典序的反序排列。
* 除了成员按score值递减的次序排列这一点外，ZREVRANGE命令的其他方面和ZRANGE命令一样。
*
* @param key
* @param start
* @param end
* @return 指定范围的元素列表(可选是否含有分数)。
*/
public Set<String> zrevrange(String key, long start, long end){
Set<String>  ret;
Jedis jedis = getSlave();
ret = jedis.zrevrange(key, start, end);

return ret;
}

/**
* 返回有序集key中，指定区间内的成员。其中成员按score值递增(从小到大)来排序。具有相同score值的成员按字典序来排列。
*
* 如果你需要成员按score值递减(score相等时按字典序递减)来排列，请使用ZREVRANGE命令。
* 下标参数start和stop都以0为底，也就是说，以0表示有序集第一个成员，以1表示有序集第二个成员，以此类推。
* 你也可以使用负数下标，以-1表示最后一个成员，-2表示倒数第二个成员，以此类推。
*
* 超出范围的下标并不会引起错误。如果start的值比有序集的最大下标还要大，或是start >
* stop时，ZRANGE命令只是简单地返回一个空列表。
* 另一方面，假如stop参数的值比有序集的最大下标还要大，那么Redis将stop当作最大下标来处理。
*
* 使用WITHSCORES选项，来让成员和它的score值一并返回，返回列表以value1,score1, ...,
* valueN,scoreN的格式表示，而不是value1,...,valueN。客户端库可能会返回一些更复杂的数据类型，比如数组、元组等。
*
* @param key
* @param start
* @param end
* @return 指定范围的元素列表(以元组集合的形式)。
*/
public Set<Tuple> zrangeWithScores(String key, long start, long end){
Set<Tuple>  ret;
Jedis jedis = getSlave();
ret = jedis.zrangeWithScores(key, start, end);

return ret;
}

/**
* 返回有序集key中，指定区间内的成员。其中成员的位置按score值递减(从大到小)来排列。具有相同score值的成员按字典序的反序排列。
* 除了成员按score值递减的次序排列这一点外，ZREVRANGE命令的其他方面和ZRANGE命令一样。
*
* @param key
* @param start
* @param end
* @return 指定范围的元素列表(可选是否含有分数)。
*/
public Set<Tuple> zrevrangeWithScores(String key, long start, long end){
Set<Tuple>  ret;
Jedis jedis = getSlave();
ret = jedis.zrevrangeWithScores(key, start, end);

return ret;
}

/**
* 返回key的有序集元素个数。
*
* @param key
* @return key存在的时候，返回有序集的元素个数，否则返回0。
*/
public Long zcard(String key){
Long  ret;
Jedis jedis = getSlave();
ret = jedis.zcard(key);

return ret;
}

/**
* 返回有序集key中，成员member的score值。
*
* 如果member元素不是有序集key的成员，或key不存在，返回nil。
*
* @param key
* @param member
* @return member成员的score值（double型浮点数）
*/
public Double zscore(String key, String member){
Double  ret;
Jedis jedis = getSlave();
ret = jedis.zscore(key,member);

return ret;
}

/**
* 对一个集合或者一个列表排序
*
* 对集合，有序集合，或者列表的value进行排序。默认情况下排序只对数字排序，双精度浮点数。
*
* @see #sort(String, redis.clients.jedis.SortingParams)
* @param key
* @return 假设集合或列表包含的是数字元素，那么返回的将会是从小到大排列的一个列表。
*/
public List<String> sort(String key){
List<String>  ret;
Jedis jedis = getSlave();
ret = jedis.sort(key);

return ret;
}

/**
* 根据指定参数来对列表或集合进行排序.
* <p>
* <b>examples:</b>
* <p>
* 一下是一些例子列表或者key-value:
*
* <pre>
* x = [1, 2, 3]
* y = [a, b, c]
*
* k1 = z
* k2 = y
* k3 = x
*
* w1 = 9
* w2 = 8
* w3 = 7
* </pre>
*
* 排序:
*
* <pre>
* sort(x) or sort(x, sp.asc())
* -> [1, 2, 3]
*
* sort(x, sp.desc())
* -> [3, 2, 1]
*
* sort(y)
* -> [c, a, b]
*
* sort(y, sp.alpha())
* -> [a, b, c]
*
* sort(y, sp.alpha().desc())
* -> [c, b, a]
* </pre>
*
* Limit (e.g. for Pagination):
*
* <pre>
* sort(x, sp.limit(0, 2))
* -> [1, 2]
*
* sort(y, sp.alpha().desc().limit(1, 2))
* -> [b, a]
* </pre>
*
* 使用外部键来排序:
*
* <pre>
* sort(x, sb.by(w*))
* -> [3, 2, 1]
*
* sort(x, sb.by(w*).desc())
* -> [1, 2, 3]
* </pre>
*
* Getting external keys:
*
* <pre>
* sort(x, sp.by(w*).get(k*))
* -> [x, y, z]
*
* sort(x, sp.by(w*).get(#).get(k*))
* -> [3, x, 2, y, 1, z]
* </pre>
*
* @see #sort(String)
* @param key
* @param sortingParameters
* @return a list of sorted elements.
*/
public List<String> sort(String key, SortingParams sortingParameters){
List<String>  ret;
Jedis jedis = getSlave();
ret = jedis.sort(key,sortingParameters);

return ret;
}

/**
* 返回有序集key中，score值在min和max之间(默认包括score值等于min或max)的成员。
*
* @param key
* @param min
* @param max
* @return 指定分数范围的元素个数。
*/
public Long zcount(String key, double min, double max){
Long  ret;
Jedis jedis = getSlave();
ret = jedis.zcount(key,min,max);

return ret;
}

/**
* 返回有序集key中，score值在min和max之间(默认包括score值等于min或max)的成员。
*
* @param key
* @param min
* @param max
* @return 指定分数范围的元素个数。
*/
public Long zcount(String key, String min, String max){
Long  ret;
Jedis jedis = getSlave();
ret = jedis.zcount(key,min,max);

return ret;
}

/**
* 返回key的有序集合中的分数在min和max之间的所有元素（包括分数等于max或者min的元素）。元素被认为是从低分到高分排序的。
* 具有相同分数的元素按字典序排列
*
* @param key
* @param min
* @param max
* @return 指定分数范围的元素列表
*/
public Set<String> zrangeByScore(String key, double min, double max){
Set<String>  ret;
Jedis jedis = getSlave();
ret = jedis.zrangeByScore(key,min,max);

return ret;
}

/**
* 返回key的有序集合中的分数在min和max之间的所有元素（包括分数等于max或者min的元素）。元素被认为是从低分到高分排序的。
* 具有相同分数的元素按字典序排列
*
* @param key
* @param min
* @param max
* @return 指定分数范围的元素列表
*/
public Set<String> zrangeByScore(String key, String min, String max){
Set<String>  ret;
Jedis jedis = getSlave();
ret = jedis.zrangeByScore(key,min,max);

return ret;
}

/**
* 返回key的有序集合中的分数在min和max之间的所有元素（包括分数等于max或者min的元素）。元素被认为是从低分到高分排序的。
* 具有相同分数的元素按字典序排列, 指定返回结果的数量及区间。
*
* @param key
* @param min
* @param max
* @param offset
* @param count
* @return 指定分数范围的元素列表
*/
public Set<String> zrangeByScore(String key, double min, double max, int offset, int count){
Set<String>  ret;
Jedis jedis = getSlave();
ret = jedis.zrangeByScore(key,min,max,offset,count);

return ret;
}

/**
* 返回key的有序集合中的分数在min和max之间的所有元素（包括分数等于max或者min的元素）。元素被认为是从低分到高分排序的。
* 具有相同分数的元素按字典序排列, 指定返回结果的数量及区间。
*
* @param key
* @param min
* @param max
* @param offset
* @param count
* @return 指定分数范围的元素列表
*/
public Set<String> zrangeByScore(String key, String min, String max, int offset, int count){
Set<String>  ret;
Jedis jedis = getSlave();
ret = jedis.zrangeByScore(key,min,max,offset,count);

return ret;
}

/**
* 返回key的有序集合中的分数在min和max之间的所有元素（包括分数等于max或者min的元素）。元素被认为是从低分到高分排序的。
* 具有相同分数的元素按字典序排列。返回元素和其分数，而不只是元素。
*
* @param key
* @param min
* @param max
* @return
*/
public Set<Tuple> zrangeByScoreWithScores(String key, double min, double max){
Set<Tuple>  ret;
Jedis jedis = getSlave();
ret = jedis.zrangeByScoreWithScores(key,min,max);

return ret;
}

/**
* 返回key的有序集合中的分数在min和max之间的所有元素（包括分数等于max或者min的元素）。元素被认为是从低分到高分排序的。
* 具有相同分数的元素按字典序排列, 指定返回结果的数量及区间。 返回元素和其分数，而不只是元素。
*
* @param key
* @param min
* @param max
* @param offset
* @param count
* @return
*/
public Set<Tuple> zrangeByScoreWithScores(String key, double min, double max, int offset,
int count){
Set<Tuple>  ret;
Jedis jedis = getSlave();
ret = jedis.zrangeByScoreWithScores(key,min,max,offset,count);

return ret;
}

/**
* 返回key的有序集合中的分数在min和max之间的所有元素（包括分数等于max或者min的元素）。元素被认为是从低分到高分排序的。
* 具有相同分数的元素按字典序排列。返回元素和其分数，而不只是元素。
*
* @param key
* @param min
* @param max
* @return
*/
public Set<Tuple> zrangeByScoreWithScores(String key, String min, String max){
Set<Tuple>  ret;
Jedis jedis = getSlave();
ret = jedis.zrangeByScoreWithScores(key,min,max);

return ret;
}

/**
* 返回key的有序集合中的分数在min和max之间的所有元素（包括分数等于max或者min的元素）。元素被认为是从低分到高分排序的。
* 具有相同分数的元素按字典序排列, 指定返回结果的数量及区间。 返回元素和其分数，而不只是元素。
*
* @param key
* @param min
* @param max
* @param offset
* @param count
* @return
*/
public Set<Tuple> zrangeByScoreWithScores(String key, String min, String max, int offset,
int count){
Set<Tuple>  ret;
Jedis jedis = getSlave();
ret = jedis.zrangeByScoreWithScores(key,min,max,offset,count);

return ret;
}

/**
* 机制与zrangeByScore一样，只是返回结果为降序排序。
*
* @param key
* @param max
* @param min
* @return
*/
public Set<String> zrevrangeByScore(String key, double max, double min){
Set<String>  ret;
Jedis jedis = getSlave();
ret = jedis.zrevrangeByScore(key,min,max);

return ret;
}

/**
* 机制与zrangeByScore一样，只是返回结果为降序排序。
*
* @param key
* @param max
* @param min
* @return
*/
public Set<String> zrevrangeByScore(String key, String max, String min){
Set<String>  ret;
Jedis jedis = getSlave();
ret = jedis.zrevrangeByScore(key,min,max);

return ret;
}

/**
* 机制与zrangeByScore一样，只是返回结果为降序排序。
*
* @param key
* @param max
* @param min
* @param offset
* @param count
* @return
*/
public Set<String> zrevrangeByScore(String key, double max, double min, int offset, int count){
Set<String>  ret;
Jedis jedis = getSlave();
ret = jedis.zrevrangeByScore(key,min,max,offset,count);

return ret;
}

/**
* 机制与zrangeByScoreWithScores一样，只是返回结果为降序排序。
*
* @param key
* @param max
* @param min
* @return
*/
public Set<Tuple> zrevrangeByScoreWithScores(String key, double max, double min){
Set<Tuple>  ret;
Jedis jedis = getSlave();
ret = jedis.zrevrangeByScoreWithScores(key,min,max);

return ret;
}

/**
* 机制与zrangeByScore一样，只是返回结果为降序排序。
*
* @param key
* @param max
* @param min
* @param offset
* @param count
* @return
*/
public Set<String> zrevrangeByScore(String key, String max, String min, int offset, int count){
Set<String>  ret;
Jedis jedis = getSlave();
ret = jedis.zrevrangeByScore(key,min,max,offset,count);

return ret;
}

/**
* 机制与zrangeByScoreWithScores一样，只是返回结果为降序排序。
*
* @param key
* @param max
* @param min
* @return
*/
public Set<Tuple> zrevrangeByScoreWithScores(String key, String max, String min){
Set<Tuple>  ret;
Jedis jedis = getSlave();
ret = jedis.zrevrangeByScoreWithScores(key,min,max);

return ret;
}
/**
* 机制与zrangeByScoreWithScores一样，只是返回结果为降序排序。
*
* @param key
* @param max
* @param min
* @param offset
* @param count
* @return
*/
public Set<Tuple> zrevrangeByScoreWithScores(String key, double max, double min, int offset,
int count){
Set<Tuple>  ret;
Jedis jedis = getSlave();
ret = jedis.zrevrangeByScoreWithScores(key,min,max,offset,count);

return ret;
}

/**
* 机制与zrangeByScoreWithScores一样，只是返回结果为降序排序。
*
* @param key
* @param max
* @param min
* @param offset
* @param count
* @return
*/
public Set<Tuple> zrevrangeByScoreWithScores(String key, String max, String min, int offset,
int count){
Set<Tuple>  ret;
Jedis jedis = getSlave();
ret = jedis.zrevrangeByScoreWithScores(key,min,max,offset,count);

return ret;
}

/**
* 移除有序集key中，指定排名(rank)区间内的所有成员。下标参数start和stop都以0为底，0处是分数最小的那个元素。这些索引也可是负数，
* 表示位移从最高分处开始数。例如，-1是分数最高的元素，-2是分数第二高的，依次类推。
*
* @param key
* @param start
* @param end
* @return 被移除成员的数量。
*/
public Long zremrangeByRank(String key, long start, long end){
Long  ret;
Jedis jedis = getMaster();
ret = jedis.zremrangeByRank(key,start,end);

return ret;
}

/**
* 移除有序集key中，所有score值介于min和max之间(包括等于min或max)的成员。
*
* 自版本2.1.6开始，score值等于min或max的成员也可以不包括在内，语法请参见ZRANGEBYSCORE命令。
*
* @param key
* @param start
* @param end
* @return 删除的元素的个数
*/
public Long zremrangeByScore(String key, double start, double end){
Long  ret;
Jedis jedis = getMaster();
ret = jedis.zremrangeByScore(key,start,end);

return ret;
}

/**
* 移除有序集key中，所有score值介于min和max之间(包括等于min或max)的成员。
*
* 自版本2.1.6开始，score值等于min或max的成员也可以不包括在内，语法请参见ZRANGEBYSCORE命令。
*
* @param key
* @param start
* @param end
* @return 删除的元素的个数
*/
public Long zremrangeByScore(String key, String start, String end){
Long  ret;
Jedis jedis = getMaster();
ret = jedis.zremrangeByScore(key,start,end);

return ret;
}

/**
* 当插入到有序集合中的元素都具有相同的分数时，这个命令可以返回min和max指定范围内的元素的数量。
*
* @param key
* @param min
* @param max
* @return
*/
public Long zlexcount(final String key, final String min, final String max){
Long  ret;
Jedis jedis = getSlave();
ret = jedis.zlexcount(key,min,max);

return ret;
}

/**
* 把 value 插入存于 key 的列表中在基准值 pivot 的前面或后面。
*
* 当 key 不存在时，这个list会被看作是空list，任何操作都不会发生。
*
* 当 key 存在，但保存的不是一个list的时候，会返回error。
*
* @param key
* @param where
* @param pivot 前或后
* @param value
* @return 在 insert 操作后的 list 长度。
*/
public Long linsert(String key, Client.LIST_POSITION where, String pivot, String value){
Long  ret;
Jedis jedis = getMaster();
ret = jedis.linsert(key, where, pivot, value);

return ret;
}

/**
* 只有当 key 已经存在并且存着一个 list 的时候，在这个 key 下面的 list 的头部插入 value。 与 LPUSH 相反，当
* key 不存在的时候不会进行任何操作。
*
* @param key
* @param string
* @return 在 push 操作后的 list 长度。
*/
public Long lpushx(String key, String... string){
Long  ret;
Jedis jedis = getMaster();
ret = jedis.lpushx(key, string);

return ret;
}

/**
* 将值 value 插入到列表 key 的表尾, 当且仅当 key 存在并且是一个列表。 和 RPUSH 命令相反, 当 key
* 不存在时，RPUSHX 命令什么也不做。
*
* @param key
* @param string
* @return 在Push操作后List的长度
*/
public Long rpushx(String key, String... string){
Long  ret;
Jedis jedis = getMaster();
ret = jedis.rpushx(key, string);

return ret;
}

/**
* @deprecated unusable command, this will be removed in 3.0.0.
*/
@Deprecated
public List<String> blpop(String arg){
return null;
}

/**
* BLPOP 是阻塞式列表的弹出原语。 它是命令 LPOP 的阻塞版本，这是因为当给定列表内没有任何元素可供弹出的时候， 连接将被 BLPOP
* 命令阻塞。 当给定多个 key 参数时，按参数 key 的先后顺序依次检查各个列表，弹出第一个非空列表的头元素。
*
* @param timeout
* @param key
* @return
*/
public List<String> blpop(int timeout, String key){
List<String>  ret;
Jedis jedis = getMaster();
ret = jedis.blpop(timeout, key);

return ret;
}

/**
* @deprecated unusable command, this will be removed in 3.0.0.
*/
@Deprecated
public List<String> brpop(String arg){
return null;
}

/**
* BRPOP 是一个阻塞的列表弹出原语。 它是 RPOP 的阻塞版本，因为这个命令会在给定list无法弹出任何元素的时候阻塞连接。
* 该命令会按照给出的 key 顺序查看 list，并在找到的第一个非空 list 的尾部弹出一个元素。
*
* 请在 BLPOP 文档 中查看该命令的准确语义，因为 BRPOP 和 BLPOP
* 基本是完全一样的，除了它们一个是从尾部弹出元素，而另一个是从头部弹出元素。
*
*
* @param timeout
* @param key
* @return
*/
public List<String> brpop(int timeout, String key){
List<String>  ret;
Jedis jedis = getMaster();
ret = jedis.brpop(timeout, key);

return ret;
}

/**
* 回显
*
* @param string
* @return 回显输入的字符串
*/
public String echo(String string){
String  ret;
Jedis jedis = getSlave();
ret = jedis.echo(string);

return ret;
}

/**
* 将当前数据库的 key 移动到给定的数据库 db 当中。
*
* 如果当前数据库(源数据库)和给定数据库(目标数据库)有相同名字的给定 key ，或者 key 不存在于当前数据库，那么 MOVE 没有任何效果。
*
* 因此，也可以利用这一特性，将 MOVE 当作锁(locking)原语(primitive)。
*
* @param key
* @param dbIndex
* @return 移动成功返回 1 失败则返回 0
*/
public Long move(String key, int dbIndex){
Long  ret;
Jedis jedis = getMaster();
ret = jedis.move(key,dbIndex);

return ret;
}

/**
* 统计字符串的字节数
*
* @param key
* @return 字节数
*/
public Long bitcount(final String key){
Long  ret;
Jedis jedis = getMaster();
ret = jedis.bitcount(key);

return ret;
}

/**
* 统计字符串指定起始位置的字节数
*
* @param key
* @param start
* @param end
* @return
*/
public Long bitcount(final String key, long start, long end){
Long  ret;
Jedis jedis = getMaster();
ret = jedis.bitcount(key, start, end);

return ret;
}

/**
* 迭代hash里面的元素
*
* @param key
* @param cursor
* @return
*/
public ScanResult<Map.Entry<String, String>> hscan(final String key, final String cursor){
ScanResult<Map.Entry<String, String>>   ret;
Jedis jedis = getMaster();
ret = jedis.hscan(key,cursor);

return ret;
}

/**
* 迭代set里面的元素
*
* @param key
* @param cursor
* @return
*/
public ScanResult<String> sscan(final String key, final String cursor){
ScanResult<String>  ret;
Jedis jedis = getMaster();
ret = jedis.sscan(key,cursor);

return ret;
}

/**
* 迭代zset里面的元素
*
* @param key
* @param cursor
* @return
*/
public ScanResult<Tuple> zscan(final String key, final String cursor){
ScanResult<Tuple>  ret;
Jedis jedis = getMaster();
ret = jedis.zscan(key,cursor);

return ret;
}

/**
* 返回所有匹配的key值 支持正则表达式
* @param key
* @return
*/
public Set<String> keys(String key){
Set<String> ret;

Jedis jedis = getSlave();
ret = jedis.keys(key);

return ret;
}

public void setFactory(JedisConnFactory factory) {
this.factory = factory;
}

@Override
public void close() {

Jedis masterJedis = master.get();
System.out.println("in close masterJedis="+masterJedis);
if(masterJedis != null){
masterJedis.close();
}
master.set(null);

Jedis slaveJedis = slave.get();
System.out.println("in close slaveJedis="+slaveJedis);
if(slaveJedis != null){
slaveJedis.close();
}
slave.set(null);

}

public List<?> getList(Class<?> tableClass,String key){
List resultList = null;
List list = hvals(key);
if(CollectionUtils.isNotEmpty(list)){
resultList = new ArrayList<>(list.size());
Iterator iterator = list.iterator();
while (iterator.hasNext()){
String str = (String)iterator.next();
Object object = JsonUtil.deserialize(str, tableClass);
resultList.add(object);
}

}
return resultList;
}

public List<?> getList(Class<?> tableClass,String key,String... filed){
List resultList = null;
List list = hmget(key,filed);
if(CollectionUtils.isNotEmpty(list)){
resultList = new ArrayList<>(list.size());
Iterator iterator = list.iterator();
while (iterator.hasNext()){
String str = (String)iterator.next();
Object object = JsonUtil.deserialize(str, tableClass);
resultList.add(object);
}
}
return resultList;
}

}

package com.test.redis;

import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.DisposableBean;
import org.springframework.beans.factory.InitializingBean;
import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
import redis.clients.util.Pool;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;

public class JedisConnFactory implements InitializingBean, DisposableBean {
private final static Log log = LogFactory.getLog(JedisConnFactory.class);
private String hostName = "localhost";
private int port = 6379;
private int timeout = 2000;
private String password;
private boolean usePool = true;
private Pool<Jedis> pool;
private List<Pool<Jedis>> slavePool;
private JedisPoolConfig poolConfig = new JedisPoolConfig();
private int dbIndex = 0;
private List<HostAndPort> slave;
private AtomicInteger coutner = new AtomicInteger(1);
public JedisConnFactory(){}

public JedisConnFactory(JedisPoolConfig poolConfig) {
this.poolConfig = poolConfig;
};

@Override
public void destroy() throws Exception {
if (usePool && pool != null) {
try {
pool.destroy();
} catch (Exception ex) {
log.warn("无法关闭redis连接池", ex);
}
pool = null;
}
}

@Override
public void afterPropertiesSet() throws Exception {
if (usePool) {
this.pool = createRedisPool();
if(slave != null && slave.size() > 0){
this.slavePool = createRedisSlavePool();
}

}
}

private List<Pool<Jedis>> createRedisSlavePool(){
List<Pool<Jedis>> list = new ArrayList();

slave.forEach(x->{

JedisPool jedisPool = new JedisPool(getPoolConfig(),x.getHost(),x.getPort(),getTimeout(),getPassword());
list.add(jedisPool);
});

return list;
}
public Jedis getMaster(){
if(usePool){
return pool.getResource();
}else{
return new Jedis(getHostName(),getPort(),getTimeout());
}
}

public Jedis getSlave(){
//没有从的时候 返回主
if(CollectionUtils.isEmpty(slave)){
return getMaster();
}

int index = getSlaveIndex();
if(usePool){
return slavePool.get(index).getResource();
}else{
HostAndPort hostAndPort = slave.get(index);
return new Jedis(hostAndPort.getHost(),hostAndPort.getPort(),getTimeout());
}
}

private int getSlaveIndex(){
coutner.incrementAndGet();
int index = coutner.intValue()%slave.size();

return index;
}

protected Pool<Jedis> createRedisPool() {
return new JedisPool(getPoolConfig(), getHostName(), getPort(),
getTimeout(), getPassword());
}

public String getHostName() {
return hostName;
}

public void setHostName(String hostName) {
this.hostName = hostName;
}

public int getPort() {
return port;
}

public void setPort(int port) {
this.port = port;
}

public int getTimeout() {
return timeout;
}

public void setTimeout(int timeout) {
this.timeout = timeout;
}

public String getPassword() {
return password;
}

public void setPassword(String password) {
this.password = password;
}

public Pool<Jedis> getPool() {
return pool;
}

public void setPool(Pool<Jedis> pool) {
this.pool = pool;
}

public JedisPoolConfig getPoolConfig() {
return poolConfig;
}

public void setSlave(List<HostAndPort> slave) {
this.slave = slave;
}

public void setUsePool(boolean usePool) {
this.usePool = usePool;
}
}

redis.host=192.168.116.107
redis.port=6379
redis.usePool=false

redis.pool.maxTotal=10
redis.pool.maxIdle=10
redis.pool.maxWaitMillis=3000

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd"> <!-- redis配置 -->
<bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">
<property name="maxTotal" value="${redis.pool.maxTotal}"/>
<property name="maxIdle" value="${redis.pool.maxIdle}"/>
<property name="maxWaitMillis" value="${redis.pool.maxWaitMillis}"/>
<property name="testOnBorrow" value="true"/>
<property name="testOnReturn" value="true"/>
</bean>
<bean id="redisHelper" class="com.test.redis.RedisHelper" >
<property name="factory" ref="redisFactory"/>
</bean>

<bean id="redisFactory" class="com.test.redis.JedisConnFactory">
<constructor-arg ref="poolConfig" />
<property name="hostName" value="${redis.host}" />
<property name="port" value="${redis.port}" />
<property name="usePool" value="${redis.usePool}" />
</bean>
</beans>