Java操作redis的工具类详解大数据

通过jedispool操作redis的工具类，通过大量测试和高并发测试。

在使用jedispool 的时候一定要注意两点

1. 在获取 jedisPool和jedis的时候加上线程同步，保证不要创建过多的jedispool 和 jedis

2.用完Jedis实例后需要返还给JedisPool

   
import org.apache.log4j.Logger;   
   
import redis.clients.jedis.Jedis;   
import redis.clients.jedis.JedisPool;   
import redis.clients.jedis.JedisPoolConfig;   
   
/**  
 * Redis 工具类  
 * @author caspar  
 * http://blog.csdn.net/tuposky  
 */   
public class RedisUtil {   
       
    protected static Logger logger = Logger.getLogger(RedisUtil.class);   
       
    //Redis服务器IP   
    private static String ADDR_ARRAY = FileUtil.getPropertyValue("/properties/redis.properties", "server");   
       
    //Redis的端口号   
    private static int PORT = FileUtil.getPropertyValueInt("/properties/redis.properties", "port");   
       
    //访问密码   
//    private static String AUTH = FileUtil.getPropertyValue("/properties/redis.properties", "auth");   
       
    //可用连接实例的最大数目，默认值为8；   
    //如果赋值为-1，则表示不限制；如果pool已经分配了maxActive个jedis实例，则此时pool的状态为exhausted(耗尽)。   
    private static int MAX_ACTIVE = FileUtil.getPropertyValueInt("/properties/redis.properties", "max_active");;   
       
    //控制一个pool最多有多少个状态为idle(空闲的)的jedis实例，默认值也是8。   
    private static int MAX_IDLE = FileUtil.getPropertyValueInt("/properties/redis.properties", "max_idle");;   
       
    //等待可用连接的最大时间，单位毫秒，默认值为-1，表示永不超时。如果超过等待时间，则直接抛出JedisConnectionException；   
    private static int MAX_WAIT = FileUtil.getPropertyValueInt("/properties/redis.properties", "max_wait");;   
   
    //超时时间   
    private static int TIMEOUT = FileUtil.getPropertyValueInt("/properties/redis.properties", "timeout");;   
       
    //在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的；   
    private static boolean TEST_ON_BORROW = FileUtil.getPropertyValueBoolean("/properties/redis.properties", "test_on_borrow");;   
       
    private static JedisPool jedisPool = null;   
       
    /**  
     * redis过期时间,以秒为单位  
     */   
    public final static int EXRP_HOUR = 60*60;          //一小时   
    public final static int EXRP_DAY = 60*60*24;        //一天   
    public final static int EXRP_MONTH = 60*60*24*30;   //一个月   
       
    /**  
     * 初始化Redis连接池  
     */   
    private static void initialPool(){   
        try {   
            JedisPoolConfig config = new JedisPoolConfig();   
            config.setMaxTotal(MAX_ACTIVE);   
            config.setMaxIdle(MAX_IDLE);   
            config.setMaxWaitMillis(MAX_WAIT);   
            config.setTestOnBorrow(TEST_ON_BORROW);   
            jedisPool = new JedisPool(config, ADDR_ARRAY.split(",")[0], PORT, TIMEOUT);   
        } catch (Exception e) {   
            logger.error("First create JedisPool error : "+e);   
            try{   
                //如果第一个IP异常，则访问第二个IP   
                JedisPoolConfig config = new JedisPoolConfig();   
                config.setMaxTotal(MAX_ACTIVE);   
                config.setMaxIdle(MAX_IDLE);   
                config.setMaxWaitMillis(MAX_WAIT);   
                config.setTestOnBorrow(TEST_ON_BORROW);   
                jedisPool = new JedisPool(config, ADDR_ARRAY.split(",")[1], PORT, TIMEOUT);   
            }catch(Exception e2){   
                logger.error("Second create JedisPool error : "+e2);   
            }   
        }   
    }   
       
       
    /**  
     * 在多线程环境同步初始化  
     */   
    private static synchronized void poolInit() {   
        if (jedisPool == null) {     
            initialPool();   
        }   
    }   
   
       
    /**  
     * 同步获取Jedis实例  
     * @return Jedis  
     */   
    public synchronized static Jedis getJedis() {     
        if (jedisPool == null) {     
            poolInit();   
        }   
        Jedis jedis = null;   
        try {     
            if (jedisPool != null) {     
                jedis = jedisPool.getResource();    
            }   
        } catch (Exception e) {     
            logger.error("Get jedis error : "+e);   
        }finally{   
            returnResource(jedis);   
        }   
        return jedis;   
    }     
       
       
    /**  
     * 释放jedis资源  
     * @param jedis  
     */   
    public static void returnResource(final Jedis jedis) {   
        if (jedis != null && jedisPool !=null) {   
            jedisPool.returnResource(jedis);   
        }   
    }   
       
       
    /**  
     * 设置 String  
     * @param key  
     * @param value  
     */   
    public static void setString(String key ,String value){   
        try {   
            value = StringUtil.isEmpty(value) ? "" : value;   
            getJedis().set(key,value);   
        } catch (Exception e) {   
            logger.error("Set key error : "+e);   
        }   
    }   
       
    /**  
     * 设置 过期时间  
     * @param key  
     * @param seconds 以秒为单位  
     * @param value  
     */   
    public static void setString(String key ,int seconds,String value){   
        try {   
            value = StringUtil.isEmpty(value) ? "" : value;   
            getJedis().setex(key, seconds, value);   
        } catch (Exception e) {   
            logger.error("Set keyex error : "+e);   
        }   
    }   
       
    /**  
     * 获取String值  
     * @param key  
     * @return value  
     */   
    public static String getString(String key){   
        if(getJedis() == null || !getJedis().exists(key)){   
            return null;   
        }   
        return getJedis().get(key);   
    }   
       
}