Jedis 使用范例

时间:2021-04-02 07:42:36

public class RedisUtil {

Logger logger = LoggerFactory.getLogger(RedisUtil.class);
private JedisPool pool = null;

/**

*在构造函数中初始化JedisPool

**/
public RedisUtil() {
  JedisPoolConfig config = new JedisPoolConfig();

  // 控制一个pool可分配多少个jedis实例,通过pool.getResource()来获取;    

  //如果赋值为-1,则表示不限制;如果pool已经分配了maxActive个jedis实例,则此时pool的状态为exhausted(耗尽)。

  config.setMaxActive(SystemConstants.REDIS_MAX_ACTIVE);  

  //控制一个pool最多有多少个状态为idle(空闲的)的jedis实例。

  config.setMaxIdle(SystemConstants.REDIS_MAX_IDLE); 

//表示当borrow一个jedis实例时,最大的等待时间,如果超过等待时间,则直接抛出     
  config.setMaxWait(SystemConstants.REDIS_MAX_WAIT);   

  //表示当borrow(引入)一个jedis实例时,最大的等待时间,如果超过等待时间,则直接抛出JedisConnectionException;  
  config.setTestOnBorrow(true);
  config.setTestOnReturn(true);
  pool = new JedisPool(config, SystemConstants.REDIS_IP,SystemConstants.REDIS_PORT,SystemConstants.TIMEOUT);  //
}
public JedisPool getPool() {
  return pool;
}
public void setPool(JedisPool pool) {
  this.pool = pool;
}

public Jedis getJedis() {
  Jedis jedis = null;
  int count =0;
  do{
    try{
      jedis = this.getPool().getResource();
    } catch (Exception e) {
      getPool().returnBrokenResource(jedis);
      logger.error("Redis Exception :"+e.toString());
      e.printStackTrace();
    }
    count++;
  }while(jedis==null&&count<SystemConstants.REDIS_RETRY_NUM);
  return jedis;
}

/**

*关闭一个Jedis 资源 return 给pool

*/
public void closeJedis(Jedis jedis) {
  if(jedis != null) {
    this.pool.returnResource(jedis);
  }
}

}

// 以下为使用方法

// 获取Jedis 对象

Jedis jedis = redisUtil.getJedis();

rsp.setTariff_version(jedis.get("tariff_version"));

jedis.rpush(key.getBytes(),data);

// 关闭jedis 对象
redisUtil.closeJedis(jedis);