vlambda博客
学习文章列表

Jedis JedisCluster 常用方法和Redis消息订阅实现（带源码）

bsea/study_java_web - Gitee.com


Jedis demo 

package com.redis;  import org.junit.Test; import redis.clients.jedis.Jedis; import redis.clients.jedis.SortingParams;  import java.sql.Timestamp; import java.text.SimpleDateFormat; import java.util.*; import java.util.concurrent.TimeUnit; /** * 单机环境Redis操作：一台Redis服务器 */public class Standalone { private static Jedis jedis; static { jedis = new Jedis("localhost", 6379);// jedis.auth("123456"); // 之前我在redis配置中配置了权限密码，这里需要设置 }  /** * 测试key - value 的数据 * @throws InterruptedException */ @Test public void testKey() throws InterruptedException { System.out.println("清空数据："+jedis.flushDB()); System.out.println("判断某个键是否存在："+jedis.exists("username")); System.out.println("新增<'username','wukong'>的键值对："+jedis.set("username", "wukong")); System.out.println("是否存在:"+jedis.exists("name")); System.out.println("新增<'password','password'>的键值对："+jedis.set("password", "password")); Set<String> keys = jedis.keys("*"); System.out.println("系统中所有的键如下："+keys); System.out.println("删除键password:"+jedis.del("password")); System.out.println("判断键password是否存在："+jedis.exists("password")); System.out.println("设置键username的过期时间为5s:"+jedis.expire("username", 5)); TimeUnit.SECONDS.sleep(2); System.out.println("查看键username的剩余生存时间："+jedis.ttl("username")); System.out.println("移除键username的生存时间："+jedis.persist("username")); System.out.println("查看键username的剩余生存时间："+jedis.ttl("username")); System.out.println("查看键username所存储的值的类型："+jedis.type("username")); }  /*** * 字符串操作 * memcached和redis同样有append的操作，但是memcached有prepend的操作，redis中并没有。 * @throws InterruptedException */ @Test public void testString() throws InterruptedException { jedis.flushDB(); System.out.println("===========增加数据==========="); System.out.println(jedis.set("key1","value1")); System.out.println(jedis.set("key2","value2")); System.out.println(jedis.set("key3", "value3")); System.out.println("删除键key2:"+jedis.del("key2")); System.out.println("获取键key2:"+jedis.get("key2")); System.out.println("修改key1:"+jedis.set("key1", "value1Changed")); System.out.println("获取key1的值："+jedis.get("key1")); System.out.println("在key3后面加入值："+jedis.append("key3", "End")); System.out.println("key3的值："+jedis.get("key3")); System.out.println("增加多个键值对："+jedis.mset("key01","value01","key02","value02","key03","value03")); System.out.println("获取多个键值对："+jedis.mget("key01","key02","key03")); System.out.println("获取多个键值对："+jedis.mget("key01","key02","key03","key04")); System.out.println("删除多个键值对："+jedis.del(new String[]{"key01","key02"})); System.out.println("获取多个键值对："+jedis.mget("key01","key02","key03"));  jedis.flushDB(); System.out.println("===========新增键值对防止覆盖原先值=============="); System.out.println(jedis.setnx("key1", "value1")); System.out.println(jedis.setnx("key2", "value2")); System.out.println(jedis.setnx("key2", "value2-new")); System.out.println(jedis.get("key1")); System.out.println(jedis.get("key2"));  System.out.println("===========新增键值对并设置有效时间============="); System.out.println(jedis.setex("key3", 2, "value3")); System.out.println(jedis.get("key3")); TimeUnit.SECONDS.sleep(3); System.out.println(jedis.get("key3"));  System.out.println("===========获取原值，更新为新值==========");//GETSET is an atomic set this value and return the old value command. System.out.println(jedis.getSet("key2", "key2GetSet")); System.out.println(jedis.get("key2"));  System.out.println("获得key2的值的字串："+jedis.getrange("key2", 2, 4)); }  /*** * 整数和浮点数 */ @Test public void testNumber() { jedis.flushDB(); jedis.set("key1", "1"); jedis.set("key2", "2"); jedis.set("key3", "2.3"); System.out.println("key1的值："+jedis.get("key1")); System.out.println("key2的值："+jedis.get("key2")); System.out.println("key1的值加1："+jedis.incr("key1")); System.out.println("获取key1的值："+jedis.get("key1")); System.out.println("key2的值减1："+jedis.decr("key2")); System.out.println("获取key2的值："+jedis.get("key2")); System.out.println("将key1的值加上整数5："+jedis.incrBy("key1", 5)); System.out.println("获取key1的值："+jedis.get("key1")); System.out.println("将key2的值减去整数5："+jedis.decrBy("key2", 5)); System.out.println("获取key2的值："+jedis.get("key2")); }  /*** * 列表 */ @Test public void testList() { jedis.flushDB(); System.out.println("===========添加一个list==========="); jedis.lpush("collections", "ArrayList", "Vector", "Stack", "HashMap", "WeakHashMap", "LinkedHashMap"); jedis.lpush("collections", "HashSet"); jedis.lpush("collections", "TreeSet"); jedis.lpush("collections", "TreeMap"); System.out.println("collections的内容："+jedis.lrange("collections", 0, -1));//-1代表倒数第一个元素，-2代表倒数第二个元素 System.out.println("collections区间0-3的元素："+jedis.lrange("collections",0,3)); System.out.println("==============================="); // 删除列表指定的值 ，第二个参数为删除的个数（有重复时），后add进去的值先被删，类似于出栈 System.out.println("删除指定元素个数："+jedis.lrem("collections", 2, "HashMap")); System.out.println("collections的内容："+jedis.lrange("collections", 0, -1)); System.out.println("删除下表0-3区间之外的元素："+jedis.ltrim("collections", 0, 3)); System.out.println("collections的内容："+jedis.lrange("collections", 0, -1)); System.out.println("collections列表出栈（左端）："+jedis.lpop("collections")); System.out.println("collections的内容："+jedis.lrange("collections", 0, -1)); System.out.println("collections添加元素，从列表右端，与lpush相对应："+jedis.rpush("collections", "EnumMap")); System.out.println("collections的内容："+jedis.lrange("collections", 0, -1)); System.out.println("collections列表出栈（右端）："+jedis.rpop("collections")); System.out.println("collections的内容："+jedis.lrange("collections", 0, -1)); System.out.println("修改collections指定下标1的内容："+jedis.lset("collections", 1, "LinkedArrayList")); System.out.println("collections的内容："+jedis.lrange("collections", 0, -1)); System.out.println("==============================="); System.out.println("collections的长度："+jedis.llen("collections")); System.out.println("获取collections下标为2的元素："+jedis.lindex("collections", 2)); System.out.println("==============================="); jedis.lpush("sortedList", "3","6","2","0","7","4"); System.out.println("sortedList排序前："+jedis.lrange("sortedList", 0, -1)); System.out.println(jedis.sort("sortedList")); System.out.println("sortedList排序后："+jedis.lrange("sortedList", 0, -1)); }  /*** * set集合 */ @Test public void testSet() { jedis.flushDB(); System.out.println("============向集合中添加元素============"); System.out.println(jedis.sadd("eleSet", "e1","e2","e4","e3","e0","e8","e7","e5")); System.out.println(jedis.sadd("eleSet", "e6")); System.out.println(jedis.sadd("eleSet", "e6")); System.out.println("eleSet的所有元素为："+jedis.smembers("eleSet")); System.out.println("删除一个元素e0："+jedis.srem("eleSet", "e0")); System.out.println("eleSet的所有元素为："+jedis.smembers("eleSet")); System.out.println("删除两个元素e7和e6："+jedis.srem("eleSet", "e7","e6")); System.out.println("eleSet的所有元素为："+jedis.smembers("eleSet")); System.out.println("随机的移除集合中的一个元素："+jedis.spop("eleSet")); System.out.println("随机的移除集合中的一个元素："+jedis.spop("eleSet")); System.out.println("eleSet的所有元素为："+jedis.smembers("eleSet")); System.out.println("eleSet中包含元素的个数："+jedis.scard("eleSet")); System.out.println("e3是否在eleSet中："+jedis.sismember("eleSet", "e3")); System.out.println("e1是否在eleSet中："+jedis.sismember("eleSet", "e1")); System.out.println("e1是否在eleSet中："+jedis.sismember("eleSet", "e5")); System.out.println("================================="); System.out.println(jedis.sadd("eleSet1", "e1","e2","e4","e3","e0","e8","e7","e5")); System.out.println(jedis.sadd("eleSet2", "e1","e2","e4","e3","e0","e8")); System.out.println("将eleSet1中删除e1并存入eleSet3中："+jedis.smove("eleSet1", "eleSet3", "e1")); System.out.println("将eleSet1中删除e2并存入eleSet3中："+jedis.smove("eleSet1", "eleSet3", "e2")); System.out.println("eleSet1中的元素："+jedis.smembers("eleSet1")); System.out.println("eleSet3中的元素："+jedis.smembers("eleSet3")); System.out.println("============集合运算================="); System.out.println("eleSet1中的元素："+jedis.smembers("eleSet1")); System.out.println("eleSet2中的元素："+jedis.smembers("eleSet2")); System.out.println("eleSet1和eleSet2的交集:"+jedis.sinter("eleSet1","eleSet2")); System.out.println("eleSet1和eleSet2的并集:"+jedis.sunion("eleSet1","eleSet2")); System.out.println("eleSet1和eleSet2的差集:"+jedis.sdiff("eleSet1","eleSet2"));//eleSet1中有，eleSet2中没有 }  /*** * 散列 */ @Test public void testHash() { jedis.flushDB(); Map<String,String> map = new HashMap<String,String>(); map.put("key1","value1"); map.put("key2","value2"); map.put("key3","value3"); map.put("key4","value4"); jedis.hmset("hash",map); jedis.hset("hash", "key5", "value5"); System.out.println("散列hash的所有键值对为："+jedis.hgetAll("hash"));//return Map<String,String> System.out.println("散列hash的所有键为："+jedis.hkeys("hash"));//return Set<String> System.out.println("散列hash的所有值为："+jedis.hvals("hash"));//return List<String> System.out.println("将key6保存的值加上一个整数，如果key6不存在则添加key6："+jedis.hincrBy("hash", "key6", 6)); System.out.println("散列hash的所有键值对为："+jedis.hgetAll("hash")); System.out.println("将key6保存的值加上一个整数，如果key6不存在则添加key6："+jedis.hincrBy("hash", "key6", 3)); System.out.println("散列hash的所有键值对为："+jedis.hgetAll("hash")); System.out.println("删除一个或者多个键值对："+jedis.hdel("hash", "key2")); System.out.println("散列hash的所有键值对为："+jedis.hgetAll("hash")); System.out.println("散列hash中键值对的个数："+jedis.hlen("hash")); System.out.println("判断hash中是否存在key2："+jedis.hexists("hash","key2")); System.out.println("判断hash中是否存在key3："+jedis.hexists("hash","key3")); System.out.println("获取hash中的值："+jedis.hmget("hash","key3")); System.out.println("获取hash中的值："+jedis.hmget("hash","key3","key4")); }  /** * 有序集合 */ @Test public void testSortedSet() { jedis.flushDB(); Map<String,Double> map = new HashMap<String,Double>(); map.put("key2",1.2); map.put("key3",4.0); map.put("key4",5.0); map.put("key5",0.2); System.out.println(jedis.zadd("zset", 3,"key1")); System.out.println(jedis.zadd("zset",map)); System.out.println("zset中的所有元素："+jedis.zrange("zset", 0, -1)); System.out.println("zset中的所有元素："+jedis.zrangeWithScores("zset", 0, -1)); System.out.println("zset中的所有元素："+jedis.zrangeByScore("zset", 0,100)); System.out.println("zset中的所有元素："+jedis.zrangeByScoreWithScores("zset", 0,100)); System.out.println("zset中key2的分值："+jedis.zscore("zset", "key2")); System.out.println("zset中key2的排名："+jedis.zrank("zset", "key2")); System.out.println("删除zset中的元素key3："+jedis.zrem("zset", "key3")); System.out.println("zset中的所有元素："+jedis.zrange("zset", 0, -1)); System.out.println("zset中元素的个数："+jedis.zcard("zset")); System.out.println("zset中分值在1-4之间的元素的个数："+jedis.zcount("zset", 1, 4)); System.out.println("key2的分值加上5："+jedis.zincrby("zset", 5, "key2")); System.out.println("key3的分值加上4："+jedis.zincrby("zset", 4, "key3")); System.out.println("zset中的所有元素："+jedis.zrange("zset", 0, -1)); }  /** * 排序 */ @Test public void testSort() { jedis.flushDB(); jedis.lpush("collections", "ArrayList", "Vector", "Stack", "HashMap", "WeakHashMap", "LinkedHashMap"); System.out.println("collections的内容："+jedis.lrange("collections", 0, -1)); SortingParams sortingParameters = new SortingParams(); System.out.println(jedis.sort("collections",sortingParameters.alpha())); System.out.println("==============================="); jedis.lpush("sortedList", "3","6","2","0","7","4"); System.out.println("sortedList排序前："+jedis.lrange("sortedList", 0, -1)); System.out.println("升序："+jedis.sort("sortedList", sortingParameters.asc())); System.out.println("升序："+jedis.sort("sortedList", sortingParameters.desc())); System.out.println("==============================="); jedis.lpush("userlist", "33"); jedis.lpush("userlist", "22"); jedis.lpush("userlist", "55"); jedis.lpush("userlist", "11"); jedis.hset("user:66", "name", "66"); jedis.hset("user:55", "name", "55"); jedis.hset("user:33", "name", "33"); jedis.hset("user:22", "name", "79"); jedis.hset("user:11", "name", "24"); jedis.hset("user:11", "add", "beijing"); jedis.hset("user:22", "add", "shanghai"); jedis.hset("user:33", "add", "guangzhou"); jedis.hset("user:55", "add", "chongqing"); jedis.hset("user:66", "add", "xi'an"); sortingParameters = new SortingParams(); sortingParameters.get("user:*->name"); sortingParameters.get("user:*->add"); System.out.println(jedis.sort("userlist",sortingParameters)); }}JedisCluster demopackage com.redis; import org.junit.Test;import redis.clients.jedis.HostAndPort;import redis.clients.jedis.JedisCluster;import redis.clients.jedis.JedisPoolConfig;import redis.clients.jedis.SortingParams; import java.util.HashMap;import java.util.HashSet;import java.util.Map;import java.util.Set;import java.util.concurrent.TimeUnit; /** * 集群环境下Jedis操作 */public class Cluster { private static JedisCluster jedis; static { // 添加集群的服务节点Set集合 Set<HostAndPort> hostAndPortsSet = new HashSet<HostAndPort>(); // 添加节点 hostAndPortsSet.add(new HostAndPort("localhost", 6379));// hostAndPortsSet.add(new HostAndPort("192.168.56.180", 8888));// hostAndPortsSet.add(new HostAndPort("192.168.56.181", 7777));// hostAndPortsSet.add(new HostAndPort("192.168.56.181", 8888));// hostAndPortsSet.add(new HostAndPort("192.168.56.182", 7777));// hostAndPortsSet.add(new HostAndPort("192.168.56.182", 8888));  // Jedis连接池配置 JedisPoolConfig jedisPoolConfig = new JedisPoolConfig(); // 最大空闲连接数, 默认8个 jedisPoolConfig.setMaxIdle(100); // 最大连接数, 默认8个 jedisPoolConfig.setMaxTotal(500); //最小空闲连接数, 默认0 jedisPoolConfig.setMinIdle(0); // 获取连接时的最大等待毫秒数(如果设置为阻塞时BlockWhenExhausted),如果超时就抛异常, 小于零:阻塞不确定的时间, 默认-1 jedisPoolConfig.setMaxWaitMillis(2000); // 设置2秒 //对拿到的connection进行validateObject校验 jedisPoolConfig.setTestOnBorrow(true); jedis = new JedisCluster(hostAndPortsSet, jedisPoolConfig); }  /** * 测试key:value数据 * 集群中flushDB、keys废弃 */ @Test public void testKey() throws InterruptedException { //System.out.println("清空数据："+jedis.flushDB()); System.out.println("判断某个键是否存在："+jedis.exists("username")); System.out.println("新增<'username','wukong'>的键值对："+jedis.set("username", "xiaohai")); System.out.println("是否存在:"+jedis.exists("username")); System.out.println("新增<'password','password'>的键值对："+jedis.set("password", "123456")); //Set<String> keys = jedis.keys("*"); // System.out.println("系统中所有的键如下："+keys); System.out.println("删除键password:"+jedis.del("password")); System.out.println("判断键password是否存在："+jedis.exists("password")); System.out.println("设置键username的过期时间为10s:"+jedis.expire("username", 10)); TimeUnit.SECONDS.sleep(2); // 线程睡眠2秒System.out.println("查看键username的剩余生存时间："+jedis.ttl("username")); System.out.println("查看键username的剩余生存时间："+jedis.ttl("username")); System.out.println("移除键username的生存时间："+jedis.persist("username")); System.out.println("查看键username的剩余生存时间："+jedis.ttl("username")); System.out.println("查看键username所存储的值的类型："+jedis.type("username")); }  /*** * 字符串操作 * memcached和redis同样有append的操作，但是memcached有prepend的操作，redis中并没有。 * 集群中flushDB、keys、del(多个值)、mset(多个值)废弃 * @throws InterruptedException */ @Test public void testString() throws InterruptedException { //jedis.flushDB(); System.out.println("===========增加数据==========="); System.out.println(jedis.set("key1","value1")); System.out.println(jedis.set("key2","value2")); System.out.println(jedis.set("key3", "value3")); System.out.println("删除键key2:"+jedis.del("key2")); System.out.println("获取键key2:"+jedis.get("key2")); System.out.println("修改key1:"+jedis.set("key1", "value1Changed")); System.out.println("获取key1的值："+jedis.get("key1")); System.out.println("在key3后面加入值："+jedis.append("key3", "End")); System.out.println("key3的值："+jedis.get("key3")); //命令的时候才会去连接连接，集群中连接是对一个节点连接，不能判断多个key经过crc16算法所对应的槽在一个节点上，不支持多key获取、删除 //System.out.println("增加多个键值对："+jedis.mset("key01","value01","key02","value02")); //System.out.println("获取多个键值对："+jedis.mget("key01","key02","key03")); //System.out.println("获取多个键值对："+jedis.mget("key01","key02","key03","key04")); //System.out.println("删除多个键值对："+jedis.del(new String[]{"key01","key02"})); //System.out.println("获取多个键值对："+jedis.mget("key01","key02","key03"));  //jedis.flushDB(); System.out.println("===========新增键值对防止覆盖原先值=============="); System.out.println(jedis.setnx("key1", "value1")); System.out.println(jedis.setnx("key2", "value2")); System.out.println(jedis.setnx("key2", "value2-new")); System.out.println(jedis.get("key1")); System.out.println(jedis.get("key2"));  System.out.println("===========新增键值对并设置有效时间============="); System.out.println(jedis.setex("key3", 2, "value3")); System.out.println(jedis.get("key3")); TimeUnit.SECONDS.sleep(3); System.out.println(jedis.get("key3"));  System.out.println("===========获取原值，更新为新值==========");//GETSET is an atomic set this value and return the old value command. System.out.println(jedis.getSet("key2", "key2GetSet")); System.out.println(jedis.get("key2")); System.out.println("获得key2的值的字串："+jedis.getrange("key2", 2, 4)); // 相当截取字符串的第二个位置-第四个位置的字符串 }  /*** * 整数和浮点数 */ @Test public void testNumber() { jedis.set("key1", "1"); jedis.set("key2", "2"); jedis.set("key3", "2.3"); System.out.println("key1的值："+jedis.get("key1")); System.out.println("key2的值："+jedis.get("key2")); System.out.println("key1的值加1："+jedis.incr("key1")); System.out.println("获取key1的值："+jedis.get("key1")); System.out.println("key2的值减1："+jedis.decr("key2")); System.out.println("获取key2的值："+jedis.get("key2")); System.out.println("将key1的值加上整数5："+jedis.incrBy("key1", 5)); System.out.println("获取key1的值："+jedis.get("key1")); System.out.println("将key2的值减去整数5："+jedis.decrBy("key2", 5)); System.out.println("获取key2的值："+jedis.get("key2")); System.out.println("key3的值："+jedis.get("key3")); // 这里会报错，因为key3不是整数不能做计算:redis.clients.jedis.exceptions.JedisDataException: ERR value is not an integer or out of range // System.out.println("key2的值减1："+jedis.decr("key3")); }  /*** * 列表 */ @Test public void testList() { System.out.println("===========添加一个list==========="); jedis.lpush("collections", "ArrayList", "Vector", "Stack", "HashMap", "WeakHashMap", "LinkedHashMap"); jedis.lpush("collections", "HashSet"); // 叠加 jedis.lpush("collections", "TreeSet"); // 叠加 jedis.lpush("collections", "TreeMap"); // 叠加 System.out.println("collections的内容："+jedis.lrange("collections", 0, -1));//-1代表倒数第一个元素，-2代表倒数第二个元素 System.out.println("collections区间0-3的元素："+jedis.lrange("collections",0,3)); // 前面4个值 System.out.println("==============================="); // 删除列表指定的值 ，第二个参数为删除的个数（有重复时），后add进去的值先被删，类似于出栈 System.out.println("删除指定元素个数："+jedis.lrem("collections", 2, "HashMap")); System.out.println("collections的内容："+jedis.lrange("collections", 0, -1)); System.out.println("删除下表0-3区间之外的元素："+jedis.ltrim("collections", 0, 3)); System.out.println("collections的内容："+jedis.lrange("collections", 0, -1)); System.out.println("collections列表出栈（左端）："+jedis.lpop("collections")); System.out.println("collections的内容："+jedis.lrange("collections", 0, -1)); System.out.println("collections添加元素，从列表右端，与lpush相对应："+jedis.rpush("collections", "EnumMap")); System.out.println("collections的内容："+jedis.lrange("collections", 0, -1)); System.out.println("collections列表出栈（右端）："+jedis.rpop("collections")); System.out.println("collections的内容："+jedis.lrange("collections", 0, -1)); System.out.println("修改collections指定下标1的内容："+jedis.lset("collections", 1, "LinkedArrayList")); System.out.println("collections的内容："+jedis.lrange("collections", 0, -1)); System.out.println("==============================="); System.out.println("collections的长度："+jedis.llen("collections")); System.out.println("获取collections下标为2的元素："+jedis.lindex("collections", 2)); System.out.println("==============================="); jedis.lpush("sortedList", "3","6","2","0","7","4"); System.out.println("sortedList排序前："+jedis.lrange("sortedList", 0, -1)); System.out.println(jedis.sort("sortedList")); System.out.println("sortedList排序后："+jedis.lrange("sortedList", 0, -1)); }  /*** * set集合 */ @Test public void testSet() { System.out.println("============向集合中添加元素============"); System.out.println(jedis.sadd("eleSet", "e1","e2","e4","e3","e0","e8","e7","e5")); System.out.println(jedis.sadd("eleSet", "e6")); System.out.println(jedis.sadd("eleSet", "e6")); // 返回0，集合中已经存在 System.out.println("eleSet的所有元素为："+jedis.smembers("eleSet")); System.out.println("删除一个元素e0："+jedis.srem("eleSet", "e0")); System.out.println("eleSet的所有元素为："+jedis.smembers("eleSet")); System.out.println("删除两个元素e7和e6："+jedis.srem("eleSet", "e7","e6")); System.out.println("eleSet的所有元素为："+jedis.smembers("eleSet")); System.out.println("随机的移除集合中的一个元素："+jedis.spop("eleSet")); System.out.println("随机的移除集合中的一个元素："+jedis.spop("eleSet")); System.out.println("eleSet的所有元素为："+jedis.smembers("eleSet")); System.out.println("eleSet中包含元素的个数："+jedis.scard("eleSet")); System.out.println("e3是否在eleSet中："+jedis.sismember("eleSet", "e3")); System.out.println("e1是否在eleSet中："+jedis.sismember("eleSet", "e1")); System.out.println("e5是否在eleSet中："+jedis.sismember("eleSet", "e5"));  // 集群下并存会报错：redis.clients.jedis.exceptions.JedisClusterException: No way to dispatch this command to Redis Cluster because keys have different slots. // Redis集群，从key1集合与key2集合并存、交集、差集，两个键经过crc16算法可能有不同的槽。 /*System.out.println("================================="); System.out.println(jedis.sadd("eleSet1", "e1","e2","e4","e3","e0","e8","e7","e5")); System.out.println(jedis.sadd("eleSet2", "e1","e2","e4","e3","e0","e8")); System.out.println("将eleSet1中删除e1并存入eleSet3中："+jedis.smove("eleSet1", "eleSet3", "e1")); System.out.println("将eleSet1中删除e2并存入eleSet3中："+jedis.smove("eleSet1", "eleSet3", "e2")); System.out.println("eleSet1中的元素："+jedis.smembers("eleSet1")); System.out.println("eleSet3中的元素："+jedis.smembers("eleSet3"));*/  /*System.out.println("============集合运算================="); System.out.println("eleSet1中的元素："+jedis.smembers("eleSet1")); System.out.println("eleSet2中的元素："+jedis.smembers("eleSet2")); System.out.println("eleSet1和eleSet2的交集:"+jedis.sinter("eleSet1","eleSet2")); System.out.println("eleSet1和eleSet2的并集:"+jedis.sunion("eleSet1","eleSet2")); System.out.println("eleSet1和eleSet2的差集:"+jedis.sdiff("eleSet1","eleSet2"));*/ jedis.del("eleSet"); jedis.del("eleSet1"); jedis.del("eleSet2"); jedis.del("eleSet3"); }  /*** * 散列 */ @Test public void testHash() { Map<String,String> map = new HashMap<String,String>(); map.put("key1","value1"); map.put("key2","value2"); map.put("key3","value3"); map.put("key4","value4"); jedis.hmset("hash",map); jedis.hset("hash", "key5", "value5"); System.out.println("散列hash的所有键值对为："+jedis.hgetAll("hash"));//return Map<String,String> System.out.println("散列hash的所有键为："+jedis.hkeys("hash"));//return Set<String> System.out.println("散列hash的所有值为："+jedis.hvals("hash"));//return List<String> System.out.println("将key6保存的值加上一个整数，如果key6不存在则添加key6："+jedis.hincrBy("hash", "key6", 6)); System.out.println("散列hash的所有键值对为："+jedis.hgetAll("hash")); System.out.println("将key6保存的值加上一个整数，如果key6不存在则添加key6："+jedis.hincrBy("hash", "key6", 3)); System.out.println("散列hash的所有键值对为："+jedis.hgetAll("hash")); System.out.println("删除一个或者多个键值对："+jedis.hdel("hash", "key2")); System.out.println("散列hash的所有键值对为："+jedis.hgetAll("hash")); System.out.println("散列hash中键值对的个数："+jedis.hlen("hash")); System.out.println("判断hash中是否存在key2："+jedis.hexists("hash","key2")); System.out.println("判断hash中是否存在key3："+jedis.hexists("hash","key3")); System.out.println("获取hash中的值："+jedis.hmget("hash","key3")); System.out.println("获取hash中的值："+jedis.hmget("hash","key3","key4")); }  /** * 有序集合 */ @Test public void testSortedSet() { Map<String,Double> map = new HashMap<String,Double>(); map.put("key2",1.2); map.put("key3",4.0); map.put("key4",5.0); map.put("key5",0.2); // 将一个或多个 member 元素及其 score 值加入到有序集 key 当中，如果某个 member 已经是有序集的成员，那么更新这个 member 的 score 值 // score 值可以是整数值或双精度浮点数 System.out.println(jedis.zadd("zset", 3,"key1")); System.out.println(jedis.zadd("zset",map)); System.out.println("zset中的所有元素："+jedis.zrange("zset", 0, -1)); System.out.println("zset中的所有元素："+jedis.zrangeWithScores("zset", 0, -1)); System.out.println("zset中的所有元素："+jedis.zrangeByScore("zset", 0,100)); System.out.println("zset中的所有元素："+jedis.zrangeByScoreWithScores("zset", 0,100)); System.out.println("zset中key2的分值："+jedis.zscore("zset", "key2")); System.out.println("zset中key2的排名："+jedis.zrank("zset", "key2")); System.out.println("删除zset中的元素key3："+jedis.zrem("zset", "key3")); System.out.println("zset中的所有元素："+jedis.zrange("zset", 0, -1)); System.out.println("zset中元素的个数："+jedis.zcard("zset")); System.out.println("zset中分值在1-4之间的元素的个数："+jedis.zcount("zset", 1, 4)); System.out.println("key2的分值加上5："+jedis.zincrby("zset", 5, "key2")); System.out.println("key3的分值加上4："+jedis.zincrby("zset", 4, "key3")); System.out.println("zset中的所有元素："+jedis.zrange("zset", 0, -1)); }  /** * 排序 */ @Test public void testSort() { jedis.lpush("collections", "ArrayList", "Vector", "Stack", "HashMap", "WeakHashMap", "LinkedHashMap"); System.out.println("collections的内容："+jedis.lrange("collections", 0, -1)); SortingParams sortingParameters = new SortingParams(); // 当数据集中保存的是字符串值时，你可以用 ALPHA,默认是升序 System.out.println("alpha排序方式：" + jedis.sort("collections",sortingParameters.alpha())); System.out.println("==============================="); jedis.lpush("sortedList", "3","6","2","0","7","4"); System.out.println("sortedList排序前："+jedis.lrange("sortedList", 0, -1)); System.out.println("升序："+jedis.sort("sortedList", sortingParameters.asc())); System.out.println("降序："+jedis.sort("sortedList", sortingParameters.desc())); System.out.println("==============================="); // 集群下不支持分割表排序 /*jedis.lpush("userlist", "33"); jedis.lpush("userlist", "22"); jedis.lpush("userlist", "55"); jedis.lpush("userlist", "11"); jedis.hset("user:66", "name", "66"); jedis.hset("user:55", "name", "55"); jedis.hset("user:33", "name", "33"); jedis.hset("user:22", "name", "79"); jedis.hset("user:11", "name", "24"); jedis.hset("user:11", "add", "beijing"); jedis.hset("user:22", "add", "shanghai"); jedis.hset("user:33", "add", "guangzhou"); jedis.hset("user:55", "add", "chongqing"); jedis.hset("user:66", "add", "xi'an"); sortingParameters = new SortingParams(); // 符号 "->" 用于分割哈希表的键名(key name)和索引域(hash field)，格式为 "key->field" sortingParameters.get("user:*->name"); sortingParameters.get("user:*->add"); System.out.println(jedis.sort("userlist",sortingParameters));*/ }}Redis消息订阅实现通过实现监听器，来实现订阅消息

package com.xsz.pubsub; import redis.clients.jedis.JedisPubSub; public class ChannelListener extends JedisPubSub { public ChannelListener() { }  @Override public void onMessage(String channel, String message) { // 收到消息会调用 // 下面可以写你的业务处理代码 System.out.println(String.format("收到消息成功！channel：%s, message：%s", channel, message)); if (message.equals("close")) this.unsubscribe("可填,不填就全部主题关闭订阅了"); }  @Override public void onSubscribe(String channel, int subscribedChannels) { // 订阅频道会调用 System.out.println(String.format("订阅频道成功！channel：%s, subscribedChannels %d", channel, subscribedChannels)); }  @Override public void onUnsubscribe(String channel, int subscribedChannels) { // 取消订阅会调用 System.out.println(String.format("取消订阅频道！channel：%s, subscribedChannels：%d", channel, subscribedChannels));  } }测试：

package com.xsz.pubsub; import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisPool;import redis.clients.jedis.JedisPoolConfig; import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors; public class Test { public static void main(String[] args) { JedisPoolConfig config = new JedisPoolConfig(); config.setMaxTotal(1000); config.setMaxIdle(300); config.setMaxWaitMillis(1000); JedisPool jedisPool = new JedisPool(config, "localhost", 6379);  // 会阻塞,所以使用线程打开 ExecutorService service = Executors.newCachedThreadPool(); service.execute(new Runnable() { @Override public void run() { // TODO Auto-generated method stub Jedis jedis = jedisPool.getResource(); ChannelListener c= new ChannelListener(); try { System.out.println("打开订阅线程,执行下句代码后此线程会阻塞"); jedis.subscribe(c, "test"); System.out.println("关闭订阅时才会打印"); } finally { // TODO: handle finally clause System.out.println("线程关闭"); //取消订阅 jedis.close(); }  } }); service.execute(new Runnable() { @Override public void run() { // TODO Auto-generated method stub Jedis jedis = jedisPool.getResource(); try { // 每秒发送一条消息到对应主题 for (int i = 0; i < 10; i++) { jedis.publish("test", String.valueOf(i)); try { Thread.sleep(1000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } }  } finally { // TODO: handle finally clause System.out.println("关闭连接"); jedis.close(); }  } }); try { Thread.sleep(11000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } // 关闭线程,即使你换成now来强制关闭,如果没有下面的通知订阅关闭代码,jvm是无法关闭的 service.shutdown(); //通知订阅关闭 jedisPool.getResource().publish("test", "close"); // 关闭线程池 jedisPool.close(); }}


分区：怎样将数据分布到多个redis实例


分区是将你的数据分发到不同redis实例上的一个过程，每个redis实例只是你所有key的一个子集。文档第一部分将介绍分区概念，第二部分介绍分区的另外一种可选方案。

为什么分区非常有用

Redis分区主要有两个目的:

  • 分区可以让Redis管理更大的内存，Redis将可以使用所有机器的内存。如果没有分区，你最多只能使用一台机器的内存。

  • 分区使Redis的计算能力通过简单地增加计算机得到成倍提升,Redis的网络带宽也会随着计算机和网卡的增加而成倍增长。

分区基本概念

有许多分区标准。假如我们有4个Redis实例R0, R1, R2, R3,有一批用户数据user:1, user:2, … ,那么有很多存储方案可以选择。从另一方面说，有很多different systems to map方案可以决定用户映射到哪个Redis实例。

一种最简单的方法就是范围分区,就是将不同范围的对象映射到不同Redis实例。比如说，用户ID从0到10000的都被存储到R0,用户ID从10001到20000被存储到R1,依此类推。

这是一种可行方案并且很多人已经在使用。但是这种方案也有缺点，你需要建一张表存储数据到redis实例的映射关系。这张表需要非常谨慎地维护并且需要为每一类对象建立映射关系，所以redis范围分区通常并不像你想象的那样运行，比另外一种分区方案效率要低很多。

另一种可选的范围分区方案是散列分区，这种方案要求更低，不需要key必须是object_name:<id>的形式，如此简单：

  • 使用散列函数 (如 crc32 )将键名称转换为一个数字。例：键foobar, 使用crc32(foobar)函数将产生散列值93024922。

  • 对转换后的散列值进行取模，以产生一个0到3的数字，以便可以使这个key映射到4个Redis实例当中的一个。93024922 % 4 等于 2, 所以 foobar 会被存储到第2个Redis实例。 R2 注意: 对一个数字进行取模，在大多数编程语言中是使用运算符%

还有很多分区方法，上面只是给出了两个简单示例。有一种比较高级的散列分区方法叫一致性哈希，并且有一些客户端和代理（proxies)已经实现。

不同的分区实现方案

分区可以在程序的不同层次实现。

  • 客户端分区就是在客户端就已经决定数据会被存储到哪个redis节点或者从哪个redis节点读取。大多数客户端已经实现了客户端分区。

  • 代理分区 意味着客户端将请求发送给代理，然后代理决定去哪个节点写数据或者读数据。代理根据分区规则决定请求哪些Redis实例，然后根据Redis的响应结果返回给客户端。redis和memcached的一种代理实现就是Twemproxy

  • 查询路由(Query routing) 的意思是客户端随机地请求任意一个redis实例，然后由Redis将请求转发给正确的Redis节点。Redis Cluster实现了一种混合形式的查询路由，但并不是直接将请求从一个redis节点转发到另一个redis节点，而是在客户端的帮助下直接redirected到正确的redis节点。

分区的缺点

有些特性在分区的情况下将受到限制:

  • 涉及多个key的操作通常不会被支持。例如你不能对两个集合求交集，因为他们可能被存储到不同的Redis实例（实际上这种情况也有办法，但是不能直接使用交集指令）。

  • 同时操作多个key,则不能使用Redis事务.

  • 分区使用的粒度是key，不能使用一个非常长的排序key存储一个数据集（The partitioning granularity is the key, so it is not possible to shard a dataset with a single huge key like a very big sorted set）.

  • 当使用分区的时候，数据处理会非常复杂，例如为了备份你必须从不同的Redis实例和主机同时收集RDB / AOF文件。

  • 分区时动态扩容或缩容可能非常复杂。Redis集群在运行时增加或者删除Redis节点，能做到最大程度对用户透明地数据再平衡，但其他一些客户端分区或者代理分区方法则不支持这种特性。然而，有一种预分片的技术也可以较好的解决这个问题。

持久化数据还是缓存？

无论是把Redis当做持久化的数据存储还是当作一个缓存，从分区的角度来看是没有区别的。当把Redis当做一个持久化的存储（服务）时，一个key必须严格地每次被映射到同一个Redis实例。当把Redis当做一个缓存（服务）时，即使Redis的其中一个节点不可用而把请求转给另外一个Redis实例，也不对我们的系统产生什么影响，我们可用任意的规则更改映射，进而提高系统的高可用（即系统的响应能力）。

一致性哈希能够实现当一个key的首选的节点不可用时切换至其他节点。同样地，如果你增加了一个新节点，立刻就会有新的key被分配至这个新节点。

重要结论如下:

  • 如果Redis被当做缓存使用，使用一致性哈希实现动态扩容缩容。

  • 如果Redis被当做一个持久化存储使用，必须使用固定的keys-to-nodes映射关系，节点的数量一旦确定不能变化。否则的话(即Redis节点需要动态变化的情况），必须使用可以在运行时进行数据再平衡的一套系统，而当前只有Redis集群可以做到这样 - Redis 集群已经可用 2015.4.1.

预分片

从上面获知，除非我们把Redis当做缓存使用，否则（在生产环境动态）增加和删除节点将非常麻烦，但是使用固定的keys-instances则比较简单。

一般情况下随着时间的推移，数据存储需求总会发生变化。今天可能10个Redis节点就够了，但是明天可能就需要增加到50个节点。

既然Redis是如此的轻量（单实例只使用1M内存）,为防止以后的扩容，最好的办法就是一开始就启动较多实例。即便你只有一台服务器，你也可以一开始就让Redis以分布式的方式运行，使用分区，在同一台服务器上启动多个实例。

一开始就多设置几个Redis实例，例如32或者64个实例，对大多数用户来说这操作起来可能比较麻烦，但是从长久来看做这点牺牲是值得的。

这样的话，当你的数据不断增长，需要更多的Redis服务器时，你需要做的就是仅仅将Redis实例从一台服务迁移到另外一台服务器而已（而不用考虑重新分区的问题）。一旦你添加了另一台服务器，你需要将你一半的Redis实例从第一台机器迁移到第二台机器。

使用Redis复制技术，你可以做到极短或者不停机地对用户提供服务：

  • 在你新服务器启动一个空Redis实例。

  • 把新Redis实例配置为原实例的slave节点

  • 停止你的客户端

  • 更新你客户端配置，以便启用新的redis实例（更新IP）。

  • 在新Redis实例中执行SLAVEOF NO ONE命令

  • （更新配置后）重启你的客户端

  • 停止你原服务器的Redis实例

Redis分区实现

截止到目前，我们从理论上讨论了Redis分区，但是实际上是怎样的呢？你应该采用哪种实现方案呢？

Redis 集群

Redis集群是自动分片和高可用的首选方案。新的集群方案2015年4月1日就已经可用。2015.4.1 Google论文. 你可以从这里Cluster tutorial了解更多。

当Redis集群可用，并且有兼容Redis 集群客户端可用于你的编程语言，Redis 集群将成为Redis分区的实际标准.

Redis集群是 query routing 和 client side partitioning的一种混合实现。

Twemproxy

Twemproxy是Twitter维护的（缓存）代理系统，代理Memcached的ASCII协议和Redis协议。它是单线程程序，使用c语言编写，运行起来非常快。它是采用Apache 2.0 license的开源软件。

Twemproxy支持自动分区，如果其代理的其中一个Redis节点不可用时，会自动将该节点排除（这将改变原来的keys-instances的映射关系，所以你应该仅在把Redis当缓存时使用Twemproxy)。

Twemproxy本身不存在单点问题，因为你可以启动多个Twemproxy实例，然后让你的客户端去连接任意一个Twemproxy实例。

Twemproxy是Redis客户端和服务器端的一个中间层，由它来处理分区功能应该不算复杂，并且应该算比较可靠的。

更多关于Twemproxy in this antirez blog post.

支持一致性哈希的客户端

相对于Twemproxy，另一种可选的分区方案是在客户端实现一致性哈希或者其他类似算法。有很多客户端已经支持一致性哈希，如 Redis-rb 和 Predis.

请检查 Redis客户端完整列表 以确认在你想要使用的编程语言，有成熟的一致性哈希客户端实现。


推荐阅读

数码宝贝物语 时空异客 学习版 数码宝贝物语 时空异客 学习版
算法 | 动态规划实战，最长公共子序列 算法 | 动态规划实战，最长公共子序列

相关文章