package com.hbu.utils;
import java.util.List;
import java.util.Map;
import java.util.Set;
import org.apache.log4j.Logger;
import redis.clients.jedis.BinaryClient.LIST_POSITION;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
/**
* Redis工具类
* 调用格式:RedisUtil.getRu().方法
*/
public class RedisUtil {
private static RedisUtil ru = new RedisUtil();
private static Logger logger = Logger.getLogger(RedisUtil.class);
// private static JedisPool pool = null;
// private static RedisUtil ru = new RedisUtil();
// private static String AUTH="926459";
// private static Integer TIMEOUT = 10000;
// public RedisUtil() {
// if (pool == null) {
// //redis服务器IP
// String ip = "212.64.56.9" ;
// //redis服务器端口
// int port = 6379;
//
// JedisPoolConfig config = new JedisPoolConfig();
// // 控制一个pool可分配多少个jedis实例,通过pool.getResource()来获取;
// // 如果赋值为-1,则表示不限制;如果pool已经分配了maxActive个jedis实例,则此时pool的状态为exhausted(耗尽)。
// config.setMaxTotal(10000);
// // 控制一个pool最多有多少个状态为idle(空闲的)的jedis实例。
// config.setMaxIdle(2000);
// // 表示当borrow(引入)一个jedis实例时,最大的等待时间,如果超过等待时间,则直接抛出JedisConnectionException;
// config.setMaxWaitMillis(1000 * 100);
// //config.setTestOnBorrow(true);
// pool = new JedisPool(config,ip,port,TIMEOUT,AUTH);
// }
// }
//
//Redis服务器IP
private static String ADDR = "";
//Redis的端口号
private static Integer PORT = 6379;
//访问密码 有就写,无就空
private static String AUTH="";
//可用连接实例的最大数目,默认为8;
//如果赋值为-1,则表示不限制,如果pool已经分配了maxActive个jedis实例,则此时pool的状态为exhausted(耗尽)
private static Integer MAX_TOTAL = 1024;
//控制一个pool最多有多少个状态为idle(空闲)的jedis实例,默认值是8
private static Integer MAX_IDLE = 200;
//等待可用连接的最大时间,单位是毫秒,默认值为-1,表示永不超时。
//如果超过等待时间,则直接抛出JedisConnectionException
private static Integer MAX_WAIT_MILLIS = 10000;
private static Integer TIMEOUT = 10000;
//在borrow(用)一个jedis实例时,是否提前进行validate(验证)操作;
//如果为true,则得到的jedis实例均是可用的
private static Boolean TEST_ON_BORROW = true;
private static JedisPool pool = null;
/**
* 静态块,初始化Redis连接池
*/
static {
try {
JedisPoolConfig config = new JedisPoolConfig();
/*注意:
在高版本的jedis jar包,比如本版本2.9.0,JedisPoolConfig没有setMaxActive和setMaxWait属性了
这是因为高版本中官方废弃了此方法,用以下两个属性替换。
maxActive ==> maxTotal
maxWait==> maxWaitMillis
*/
config.setMaxTotal(MAX_TOTAL);
config.setMaxIdle(MAX_IDLE);
config.setMaxWaitMillis(MAX_WAIT_MILLIS);
config.setTestOnBorrow(TEST_ON_BORROW);
pool = new JedisPool(config,ADDR,PORT,TIMEOUT,AUTH);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 获取Jedis实例
* @return
*/
public synchronized static Jedis getJedis(){
try {
if(pool != null){
Jedis jedis = pool.getResource();
return jedis;
}else{
return null;
}
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
public static void returnResource(final Jedis jedis){
//方法参数被声明为final,表示它是只读的。
if(jedis!=null){
pool.returnResource(jedis);
//jedis.close()取代jedisPool.returnResource(jedis)方法将3.0版本开始
//jedis.close();
}
}
/**
* <p>通过key获取储存在redis中的value</p>
* <p>并释放连接</p>
* @param key
* @return 成功返回value 失败返回null
*/
public static String get(String key){
Jedis jedis = null;
String value = null;
try {
jedis = pool.getResource();
value = jedis.get(key);
} catch (Exception e) {
logger.error(e.getMessage());
} finally {
returnResource(pool, jedis);
}
return value;
}
/**
* <p>向redis存入key和value,并释放连接资源</p>
* <p>如果key已经存在 则覆盖</p>
* @param key
* @param value
* @return 成功 返回OK 失败返回 0
*/
public static String set(String key,String value){
Jedis jedis = null;
try {
jedis = pool.getResource();
return jedis.set(key, value);
} catch (Exception e) {
logger.error(e.getMessage());
return "0";
} finally {
returnResource(pool, jedis);
}
}
/**
* <p>删除指定的key,也可以传入一个包含key的数组</p>
* @param keys 一个key 也可以使 string 数组
* @return 返回删除成功的个数
*/
public Long del(String keys){
Jedis jedis = null;
try {
jedis = pool.getResource();
return jedis.del(keys);
} catch (Exception e) {
logger.error(e.getMessage());
return 0L;
} finally {
returnResource(pool, jedis);
}
}
/**
* <p>通过key向指定的value值追加值</p>
* @param key
* @param str
* @return 成功返回 添加后value的长度 失败 返回 添加的 value 的长度 异常返回0L
*/
public static Long append(String key ,String str){
Jedis jedis = null;
Long res = null;
try {
jedis = pool.getResource();
res = jedis.append(key, str);
} catch (Exception e) {
logger.error(e.getMessage());
return 0L;
} finally {
returnResource(pool, jedis);
}
return res;
}
/**
* <p>判断key是否存在</p>
* @param key
* @return true OR false
*/
public Boolean exists(String key){
Jedis jedis = null;
try {
jedis = pool.getResource();
return jedis.exists(key);
} catch (Exception e) {
logger.error(e.getMessage());
return false;
} finally {
returnResource(pool, jedis);
}
}
/**
* <p>设置key value,如果key已经存在则返回0,nx==> not exist</p>
* @param key
* @param value
* @return 成功返回1 如果存在 和 发生异常 返回 0
*/
public Long setnx(String key ,String value){
Jedis jedis = null;
try {
jedis = pool.getResource();
return jedis.setnx(key, value);
} catch (Exception e) {
logger.error(e.getMessage());
return 0L;
} finally {
returnResource(pool, jedis);