redis jedis 单机、集群、分片存储连接操作redis

/* * 文件名：SimpleJedisDemo.java * 版权：Copyright by www.huawei.com * 描述： * 修改人：yazuo * 修改时间：2015-8-18 * 跟踪单号： * 修改单号： * 修改内容： */ package com.yazuo.redisdemo; import java.util.Iterator; import java.util.List; import java.util.Set; import redis.clients.jedis.Jedis; /** * 该类主要完成redis基础功能，若redis为单机版时，该方式即可。 * 但若连接redis集群时，该方式只能获取指定库的键值，表现形式为 * 取数据不完整。 * 〈一句话功能简述〉 * 〈功能详细描述〉 * @author yazuo * @version 2015-8-18 * @see SimpleJedisConnection * @since */ public class SimpleJedisConnection { //声明jedis对象 private static Jedis jedis = null; private SimpleJedisConnection(){ } /** * 创建Jedis连接 * Description: <br> * 1、…<br> * 2、…<br> * Implement: <br> * 1、…<br> * 2、…<br> * * @param host IP * @see */ public static Jedis getJedisConnection(String host){ if(host !=null && host.length()>0 ){ jedis = new Jedis(host); } return jedis; } /** * 创建jedis连接 * Description: <br> * 1、…<br> * 2、…<br> * Implement: <br> * 1、…<br> * 2、…<br> * * @param host IP * @param post 端口 * @see */ public static Jedis getJedisConnection(String host,int post){ if(host !=null && host.length()>0 && post !=0){ jedis = new Jedis(host,post); } return jedis; } /** * 程序主方法 * Description: <br> * 1、…<br> * 2、…<br> * Implement: <br> * 1、…<br> * 2、…<br> * * @param args * @see */ public static void main(String[] args) { //获取连接 Jedis jedis = SimpleJedisConnection.getJedisConnection("192.168.234.190",7000); //取得所有key Set<String> keys = jedis.keys("*"); //显示 Iterator<String> iter = keys.iterator(); //遍历 while(iter.hasNext()){ String tempKey = iter.next(); String type = jedis.type(tempKey); System.out.println("type :"+type); //分类处理 //字符串处理 if("string".equals(type)){ System.out.println("key :"+tempKey +" value:"+jedis.get(tempKey)); } //哈希处理 else if("hash".equals(type)){ Set<String> hashFields = jedis.hkeys(tempKey); Iterator<String> hashIter = hashFields.iterator(); while(hashIter.hasNext()){ String hashField = hashIter.next(); System.out.print("key :"+tempKey+" field:"+hashField +" value:"+jedis.hget(tempKey, hashField)); } } //有序列表 else if("list".equals(type)){ List<String> memberList = jedis.lrange(tempKey, 0, -1); System.out.print("key :"+ tempKey+" value:"); for(String memeber : memberList){ System.out.print(" "+memeber); } System.out.println(); } //集合 else if("set".equals(type)){ Set<String> sMembers = jedis.smembers(tempKey); Iterator<String> iMembers = sMembers.iterator(); System.out.print("key :"+ tempKey+" value:"); while(iMembers.hasNext()){ String sMember = iMembers.next(); System.out.print(" "+sMember); } System.out.println(); } //有序集合 else if("zset".equals(type)){ Set<String> sMembers = jedis.zrange(tempKey, 0, -1); Iterator<String> iMembers = sMembers.iterator(); System.out.print("key :"+ tempKey+" value:"); while(iMembers.hasNext()){ String sMember = iMembers.next(); System.out.print(" "+sMember); } System.out.println(); } } //关闭连接 jedis.close(); } }