redis 简单应用

zhanghong

　　/**
　　*
　　*/
　　package redis;
　　import java.util.ArrayList;
　　import java.util.Iterator;
　　import java.util.List;
　　import java.util.Map.Entry;
　　import java.util.Set;
　　import redis.clients.jedis.Jedis;
　　import redis.clients.jedis.JedisPool;
　　import redis.clients.jedis.JedisPoolConfig;
　　import redis.clients.jedis.JedisShardInfo;
　　import redis.clients.jedis.ScanResult;
　　import redis.clients.jedis.ShardedJedis;
　　import redis.clients.jedis.ShardedJedisPool;

　　public>　　private Jedis jedis;// 非切片额客户端连接
　　private JedisPool jedisPool;// 非切片连接池
　　private ShardedJedis shardedJedis;// 切片额客户端连接
　　private ShardedJedisPool shardedJedisPool;// 切片连接池
　　public RedisClient() {
　　initialPool();
　　initialShardedPool();
　　shardedJedis = shardedJedisPool.getResource();
　　jedis = jedisPool.getResource();
　　}
　　/**
　　* 初始化非切片池
　　*/
　　private void initialPool() {
　　// 池基本配置
　　JedisPoolConfig config = new JedisPoolConfig();
　　config.setMaxIdle(20);
　　config.setMaxIdle(5);
　　config.setMaxWaitMillis(1000l);
　　config.setTestOnBorrow(false);
　　jedisPool = new JedisPool(config, "127.0.0.1", 6379);
　　}
　　/**
　　* 初始化切片池
　　*/
　　private void initialShardedPool() {
　　// 池基本配置
　　JedisPoolConfig config = new JedisPoolConfig();
　　config.setMaxIdle(20);
　　config.setMaxIdle(5);
　　config.setMaxWaitMillis(1000l);
　　config.setTestOnBorrow(false);
　　// slave链接
　　List shards = new ArrayList();
　　shards.add(new JedisShardInfo("127.0.0.1", 6379, "master"));
　　// 构造池
　　shardedJedisPool = new ShardedJedisPool(config, shards);
　　}
　　public void stringTest(){
　　Long l = jedis.getDB();
　　System.out.println(l);
　　jedis.set("strKey", "adfadfadsf");
　　System.out.println(jedis.get("strKey"));
　　}
　　public void KeysOpt(){
　　Set key = jedis.keys("*");
　　Iterator it = key.iterator();
　　System.out.println("----------key -----------");
　　while (it.hasNext()) {
　　String key1 = it.next();
　　String type = jedis.type(key1);
　　System.out.print("key = "+key1 +" type = "+type +" ");
　　if("string".equals(type)){
　　showStringValue(key1);
　　}else if("list".equals(type)){
　　showListValue(key1);
　　}else if("set".equals(type)){
　　showSetValue(key1);
　　}else if("zset".equals(type)){
　　showZSetValue(key1);
　　}else if("hash".equals(type)){
　　showHashValue(key1);
　　}
　　System.out.println();
　　}
　　}
　　private void showZSetValue(String key) {
　　System.out.print("value = "+jedis.zcard(key));
　　}
　　private void showSetValue(String key){
　　System.out.print("value = "+jedis.smembers(key));
　　}
　　private void showHashValue(String key){
　　System.out.print("value = "+jedis.hgetAll(key));
　　}
　　private void showListValue(String key){
　　System.out.print("value = "+jedis.lpop(key));
　　}
　　private void showStringValue(String key){
　　System.out.print("value = "+jedis.get(key));
　　}
　　public void Optation(){
　　jedis.flushDB();
　　//键操作
　　KeysOpt();
　　//字符串操作
　　stringOpt();
　　stringOpt1();
　　//列表操作
　　listOpt();
　　listOpt1();
　　//集合
　　setOpt();
　　setOpt1();
　　//hash
　　hashOpt();
　　hashOpt1();
　　KeysOpt();
　　}
　　private void hashOpt1() {
　　System.out.println("----------------shardedJedis set --------------");
　　shardedJedis.hset("hash","hashKey1","hashValue1");
　　shardedJedis.hset("hash","hashKey2","hashValue2");
　　shardedJedis.hset("hash","hashKey3","hashValue3");
　　shardedJedis.hset("hash","hashKey4","hashValue4");
　　System.out.println("删除hashKey1 = "+shardedJedis.hdel("hash", "hashKey1"));
　　jedis.hset("hash", "hashKey2", "hashValue222222222222");
　　System.out.println("查询单个 hashKey2="+shardedJedis.hget("hash", "hashKey2"));
　　System.out.println("查询多个  hash key"+shardedJedis.hmget("hash", "hashKey2","hashKey3","hashKey4"));
　　ScanResult scanResult = shardedJedis.hscan("hash", 2);
　　System.out.println("获取多个value "+scanResult.getResult());
　　}
　　private void hashOpt() {
　　System.out.println("----------------jedis set --------------");
　　jedis.hset("hash","hashKey1","hashValue1");
　　jedis.hset("hash","hashKey2","hashValue2");
　　jedis.hset("hash","hashKey3","hashValue3");
　　jedis.hset("hash","hashKey4","hashValue4");
　　System.out.println("删除hashKey1 = "+jedis.hdel("hash", "hashKey1"));
　　jedis.hset("hash", "hashKey2", "hashValue222222222222");
　　System.out.println("查询单个 hashKey2="+jedis.hget("hash", "hashKey2"));
　　System.out.println("查询多个  hash key"+jedis.hmget("hash", "hashKey2","hashKey3","hashKey4"));
　　ScanResult scanResult = jedis.hscan("hash", 2);
　　System.out.println("获取多个value "+scanResult.getResult());
　　}
　　private void setOpt1() {
　　System.out.println("----------------shardedJedis set --------------");
　　shardedJedis.sadd("set1", "sValue1");
　　shardedJedis.sadd("set2", "sValue2");
　　shardedJedis.sadd("set3", "sValue3");
　　shardedJedis.sadd("set4", "sValue4");
　　shardedJedis.sadd("set4", "sValue4444");
　　shardedJedis.sadd("set4", "sValue555");
　　shardedJedis.sadd("set5", "sValue5");
　　shardedJedis.sadd("set5", "sValue555");
　　shardedJedis.sadd("set5", "sValue5555555");
　　System.out.println("删除 " +shardedJedis.del("set1"));
　　System.out.println("删除" + shardedJedis.srem("set5", "sValue5"));
　　shardedJedis.sadd("set5", "sValue555555555555");
　　System.out.println("查询"+shardedJedis.smembers("set5"));
　　System.out.println("值的个数："+shardedJedis.scard("set5"));
　　System.out.println("键值的值判断："+shardedJedis.sismember("set5","sValue5555555"));
　　}
　　private void setOpt() {
　　System.out.println("----------------无序 jedis set --------------");
　　jedis.sadd("set1", "sValue1");
　　jedis.sadd("set2", "sValue2");
　　jedis.sadd("set3", "sValue3");
　　jedis.sadd("set4", "sValue4");
　　jedis.sadd("set4", "sValue4444");
　　jedis.sadd("set4", "sValue555");
　　jedis.sadd("set5", "sValue5");
　　jedis.sadd("set5", "sValue555");
　　jedis.sadd("set5", "sValue5555555");
　　System.out.println("删除 " +jedis.del("set1"));
　　System.out.println("删除" + jedis.srem("set5", "sValue5"));
　　jedis.sadd("set5", "sValue555555555555");
　　System.out.println("查询"+jedis.smembers("set5"));
　　System.out.println("值的个数："+jedis.scard("set5"));
　　System.out.println("键值的值判断："+jedis.sismember("set5","sValue5555555"));
　　System.out.println("并集 "+jedis.sunion("set4","set5"));
　　System.out.println("交集 "+jedis.sinter("set4","set5"));
　　System.out.println("差集 "+jedis.sdiff("set4","set5"));
　　System.out.println("并集 "+jedis.sunion("set5","set4"));
　　System.out.println("交集 "+jedis.sinter("set5","set4"));
　　System.out.println("差集 "+jedis.sdiff("set5","set4"));
　　System.out.println("---------------- 有序 jedis set --------------");
　　jedis.zadd("zset1",9,"sValue1");
　　jedis.zadd("zset2", 8,"sValue2");
　　jedis.zadd("zset3", 7,"sValue3");
　　jedis.zadd("zset4", 6,"sValue4");
　　jedis.zadd("zset4", 5,"sValue4444");
　　jedis.zadd("zset4", 4,"sValue555");
　　jedis.zadd("zset5", 3,"sValue5");
　　jedis.zadd("zset5", 2,"sValue555");
　　jedis.zadd("zset5", 1,"sValue5555555");
　　System.out.println("删除 " +jedis.del("zset1"));
　　jedis.zadd("zset5",10, "sValue555555555555");
　　System.out.println("值的个数："+jedis.zcard("zset5"));
　　System.out.println(jedis.zscore("zset5",""));
　　}
　　private void listOpt() {
　　System.out.println("----------------jedis list --------------");
　　jedis.lpush("list1", "lValue1");
　　jedis.lpush("list2", "lValue2");
　　jedis.lpush("list3", "lValue3");
　　jedis.lpush("list4", "lValue4");
　　jedis.lpush("list5", "lValue5");
　　jedis.lpush("list5", "lValue555");
　　jedis.lpush("list5", "lValue555555");
　　jedis.lpush("list5", "lValue5555555555");
　　System.out.println("删除键 list1" + jedis.del("list1"));
　　System.out.println("删除区间的值："+jedis.ltrim("list5", 0, 2));
　　jedis.lpush("list2", "lValue2222");
　　System.out.println("查询list2键的值 "+jedis.lpop("list2"));
　　System.out.println("键值的个数："+jedis.llen("list5"));
　　System.out.println("-----------范围取值----------");
　　List list = jedis.lrange("list5", 0, -1);
　　Iterator it = list.iterator();
　　while (it.hasNext()) {
　　System.out.println(it.next());
　　}
　　}
　　private void listOpt1() {
　　System.out.println("----------------shardedJedis list --------------");
　　shardedJedis.lpush("list1", "lValue1");
　　shardedJedis.lpush("list2", "lValue2");
　　shardedJedis.lpush("list3", "lValue3");
　　shardedJedis.lpush("list4", "lValue4");
　　shardedJedis.lpush("list5", "lValue5");
　　shardedJedis.lpush("list5", "lValue555");
　　shardedJedis.lpush("list5", "lValue555555");
　　shardedJedis.lpush("list5", "lValue5555555555");
　　System.out.println("删除键 list1" + shardedJedis.del("list1"));
　　System.out.println("删除区间的值："+shardedJedis.ltrim("list5", 0, 2));
　　shardedJedis.lpush("list2", "lValue2222");
　　System.out.println("查询list2键的值 "+shardedJedis.lpop("list2"));
　　System.out.println("键值的个数："+shardedJedis.llen("list5"));
　　System.out.println("-----------范围取值----------");
　　List list = shardedJedis.lrange("list5", 0, -1);
　　Iterator it = list.iterator();
　　while (it.hasNext()) {
　　System.out.println(it.next());
　　}
　　}
　　private void stringOpt() {
　　System.out.println("--------------- jedis string ---------------");
　　jedis.set("key1", "value1");
　　jedis.set("key2", "value2");
　　jedis.set("key3", "value3");
　　jedis.set("key4", "value4");
　　System.out.println("获取指定键key1 的值："+jedis.get("key1"));
　　System.out.println("获取指定键key2 的值："+jedis.get("key2"));
　　System.out.println("删除key1的值");
　　System.out.println("---------删除key内容-------");
　　jedis.del("key1");
　　System.out.println("获取指定键的值："+jedis.get("key1"));
　　System.out.println("---------追加内容-------");
　　jedis.append("key2", "value222");
　　System.out.println("获取指定键key2 的值："+jedis.get("key2"));
　　System.out.println("---------覆盖内容-------");
　　jedis.set("key2", "value222");
　　System.out.println("获取指定键key2 的值："+jedis.get("key2"));
　　System.out.println("---------合并内容-------");
　　System.out.println(jedis.mset("key2","key3","key4","adfad"));
　　System.out.println(jedis.mget("key2","key4"));
　　System.out.println("键是否存在"+jedis.exists("key2"));
　　System.out.println("键是否存在"+jedis.exists("key1"));
　　}
　　private void stringOpt1() {
　　System.out.println("--------------- shardedJedis string ---------------");
　　shardedJedis.set("key1", "value1");
　　shardedJedis.set("key2", "value2");
　　shardedJedis.set("key3", "value3");
　　shardedJedis.set("key4", "value4");
　　System.out.println("获取指定键key1 的值："+shardedJedis.get("key1"));
　　System.out.println("获取指定键key2 的值："+shardedJedis.get("key2"));
　　System.out.println("删除key1的值");
　　System.out.println("---------删除key内容-------");
　　shardedJedis.del("key1");
　　System.out.println("获取指定键的值："+jedis.get("key1"));
　　System.out.println("---------追加内容-------");
　　jedis.append("key2", "value222");
　　System.out.println("获取指定键key2 的值："+shardedJedis.get("key2"));
　　System.out.println("---------覆盖内容-------");
　　jedis.set("key2", "value222");
　　System.out.println("获取指定键key2 的值："+shardedJedis.get("key2"));
　　System.out.println("键是否存在"+shardedJedis.exists("key2"));
　　System.out.println("键是否存在"+shardedJedis.exists("key1"));
　　}
　　public static void main(String[] args) {
　　new RedisClient().Optation();
　　}
　　}