try{
 //cacheManager就相當(dāng)從redis鏈接池獲取一個連接，具體工廠類獲取在后面?zhèn)渥?
 cacheManager = (RedisCacheManager) CacheManagerFactory.getCacheManager();
 totalMonCount = Float.parseFloat(cacheManager.getString(monthKey)) + centCount;
 if (centLimitByMonth != -1){
   if (totalMonCount > centLimitByMonth) {
      // 超出月上限不再累計(jì)
      logger.error("exceeds the month limit cents! [" + totalMonCount + "]  code:[" + code + "]");
      return null;
   }
}

//當(dāng)未超出月額度，此時要對日額度進(jìn)行判斷；只需判斷其是否超出日上限積分
if (dayKey != null){
  //累積積分;因?yàn)楹灥狡鋵?shí)是沒有每日積分的，是按次數(shù)規(guī)則累積的；但為了統(tǒng)一，直接用centCount代替（都是簽一次1分）
  totalDayCount = Float.parseFloat(cacheManager.getString(dayKey)) + centCount;
  if (centLimitByDay != -1){
     if (totalDayCount > centLimitByDay){
      logger.info("[ERROR]teacher everyday assign cents > month limit! total: ["+totalDayCount+"]");
      return null;
     }
   }
   cacheManager.set(dayKey,totalDayCount.toString(),DateUtil.getSecsToEndOfCurrentDay());

}
//對月限制key進(jìn)行積分累加
//每月1號凌晨1點(diǎn)啟動腳本刪除，同時設(shè)置了保存到月底緩存時間雙重保障
cacheManager.set(monthKey, totalMonCount.toString(), DateUtil.getSecsToEndOfCurrentDay());
logger.info("==monthkey:"+monthKey+"---value:"+totalMonCount);
 }
              ...
}catch(Exception e){
          logger.error("===cache redis fail!");
          e.printStackTrace();

      }finally {

          if (cacheManager != null){
              cacheManager.close();
          }
      }

//工廠類獲取redis鏈接
public class CacheManagerFactory {
  private static ICacheManager cacheManager;
  private CacheManagerFactory(){
  };

  public static ICacheManager getCacheManager(){
    if(cacheManager == null){
      synchronized (CacheManagerFactory.class) {
        if(cacheManager == null){
          JedisPooler jedisPooler = RedisPoolerFactory.getJedisPooler();
          cacheManager = new RedisCacheManager(jedisPooler);
        }
      }
    }
    return cacheManager;
 }
}

//redis鏈接池工廠類獲取鏈接
public class RedisPoolerFactory {
  private static JedisPooler jedisPooler; 
  private RedisPoolerFactory(){
  };

  public static JedisPooler getJedisPooler(){
    if(jedisPooler == null){
      synchronized (RedisPoolerFactory.class) {
        if(jedisPooler == null){
          jedisPooler = new JedisPooler();
        }
      }
    }
    return jedisPooler;
 }
}


/**
 * 
 * Redis 連接池實(shí)例
 * 
 * @author Ethan.Lam
 * @createTime 2011-12-3
 * 
 */
public class JedisPooler {

  private JedisPool pool;
  private String REDIS_HOST;
  private String REDIS_PSW;
  private int REDIS_PORT;
  private int REDIS_MaxActive;
  private int REDIS_MaxIdle;
  private int REDIS_MaxWait;

  public JedisPooler(String config) {
    __init(config);
  }

  public JedisPooler() {
    __init("/jedisPool.properties");
  }

  private void __init(String conf) {
    // 完成初始化工作
    Properties prop = new Properties();
    try {
      InputStream _file = loadConfig(conf);
      prop.load(_file);
      REDIS_HOST = prop.getProperty("REDIS.HOST");
      REDIS_PSW = prop.getProperty("REDIS.PSW");
      REDIS_PORT = Integer.parseInt(prop.getProperty("REDIS.PORT").trim());
      REDIS_MaxActive = Integer.parseInt(prop.getProperty("REDIS.MaxActive").trim());
      REDIS_MaxIdle = Integer.parseInt(prop.getProperty("REDIS.MaxIdle").trim());
      REDIS_MaxWait = Integer.parseInt(prop.getProperty("REDIS.MaxWait").trim());
    } catch (Exception e) {
      e.printStackTrace();
      REDIS_HOST = "localhost";
      throw new NullPointerException(conf + " is not found !");
    }
    JedisPoolConfig config = new JedisPoolConfig();
    config.setMaxActive(REDIS_MaxActive);
    config.setMaxIdle(REDIS_MaxIdle);
    config.setMaxWait(REDIS_MaxWait);
    config.setTestOnBorrow(true);
    System.out.println("REDIS Cache服務(wù)信息: 當(dāng)前連接的服務(wù)IP為：" + REDIS_HOST + ":" + REDIS_PORT);
    if (null == REDIS_PSW || "".equals(REDIS_PSW.trim())){
      pool = new JedisPool(config, REDIS_HOST, REDIS_PORT, 5000);
    }
    else{
      pool = new JedisPool(config, REDIS_HOST, REDIS_PORT, 5000, REDIS_PSW);
    }
  }

  public Jedis getJedis() {
    return pool.getResource();
  }

  public void returnResource(Jedis jedis) {
    pool.returnResource(jedis);
  }

  public JedisPool getPool() {
    return pool;
  }

  InputStream loadConfig(String configPath) throws Exception {
    InputStream _file = null;
    try {
      String file = JedisPooler.class.getResource(configPath).getFile();
      file = URLDecoder.decode(file);
      _file = new FileInputStream(file);
    } catch (Exception e) {
      System.out.println("讀取jar中的配置文件....");
      String currentJarPath = URLDecoder.decode(JedisPooler.class.getProtectionDomain()
          .getCodeSource().getLocation().getFile(), "UTF-8"); // 獲取當(dāng)前Jar文件名
      System.out.println("currentJarPath：" + currentJarPath);
      java.util.jar.JarFile currentJar = new java.util.jar.JarFile(currentJarPath);
      java.util.jar.JarEntry dbEntry = currentJar.getJarEntry("jedisPool.properties");
      InputStream in = currentJar.getInputStream(dbEntry);
      _file = in;
    }
    return _file;
  }
}

cacheManager.set(monthKey, totalMonCount.toString(), DateUtil.getSecsToEndOfCurrentDay());
public class DateUtil {
  /**
   *獲取每月最后一天時間
   * @param sDate1
   * @return
   */
  public static Date getLastDayOfMonth(Date sDate1)  {
    Calendar cDay1 = Calendar.getInstance();
    cDay1.setTime(sDate1);
    final int lastDay = cDay1.getActualMaximum(Calendar.DAY_OF_MONTH);
    Date lastDate = cDay1.getTime();
    lastDate.setDate(lastDay);
    return lastDate;
  }

  /*
  獲取下一個月第一天凌晨1點(diǎn)
   */
  public static Date nextMonthFirstDate() {
    Calendar calendar = Calendar.getInstance();
    calendar.set(Calendar.HOUR_OF_DAY, 1);  //設(shè)置為每月凌晨1點(diǎn)
    calendar.set(Calendar.DAY_OF_MONTH, 1);  //設(shè)置為每月1號
    calendar.add(Calendar.MONTH, 1);  // 月份加一，得到下個月的一號
//    calendar.add(Calendar.DATE, -1);   下一個月減一為本月最后一天
    return calendar.getTime();
  }

  /**
   * 獲取第二天凌晨0點(diǎn)毫秒數(shù)
   * @return
   */
  public static Date nextDayFirstDate() throws ParseException {
    Calendar cal = Calendar.getInstance();
    cal.setTime(new Date());
    cal.add(Calendar.DAY_OF_YEAR, 1);
    cal.set(Calendar.HOUR_OF_DAY, 00);
    cal.set(Calendar.MINUTE, 0);
    cal.set(Calendar.SECOND, 0);
    return cal.getTime();
  }

  //*********

  /**
   * 獲取當(dāng)前時間到下個月凌晨1點(diǎn)相差秒數(shù)
   * @return
   */
  public static Long getSecsToEndOfCurrentMonth(){

    Long secsOfNextMonth = nextMonthFirstDate().getTime();
    //將當(dāng)前時間轉(zhuǎn)為毫秒數(shù)
    Long secsOfCurrentTime = new Date().getTime();
    //將時間轉(zhuǎn)為秒數(shù)
    Long distance = (secsOfNextMonth - secsOfCurrentTime)/1000;
    if (distance > 0 && distance != null){
      return distance;
    }
    return new Long(0);
  }

  /**
   * 獲取當(dāng)前時間到明天凌晨0點(diǎn)相差秒數(shù)
   * @return
   */
  public static Long getSecsToEndOfCurrentDay() throws ParseException {

    Long secsOfNextDay = nextDayFirstDate().getTime();
    //將當(dāng)前時間轉(zhuǎn)為毫秒數(shù)
    Long secsOfCurrentTime = new Date().getTime();
    //將時間轉(zhuǎn)為秒數(shù)
    Long distance = (secsOfNextDay - secsOfCurrentTime)/1000;
    if (distance > 0 && distance != null){
      return distance;
    }
    return new Long(0);
  }
}

  <!--定時任務(wù)1-->
  <!-- 每天12點(diǎn)將當(dāng)天用戶積分行為緩存清掉 -->
  <bean id="deleteRedisCacheDayUsersJob" class="cn.qtone.xxt.cent.quartz.delRedisCacheCentUsers" />
  <bean id="deleteRedisCacheDayUsersTask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    <property name="targetObject" ref="deleteRedisCacheDayUsersJob" />
    <property name="targetMethod" value="delCurrentDayCacheUsersByDay" /><!-- 定時執(zhí)行 doItem 方法 -->
    <property name="concurrent" value="false" />
  </bean>
  <bean id="deleteRedisCacheDayUsersTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">
    <property name="jobDetail" ref="deleteRedisCacheDayUsersTask" />
    <property name="cronExpression" value="59 59 23 * * ?" /><!-- 每天凌晨23:59:59 點(diǎn)執(zhí)行 -->
    <!--<property name="cronExpression" value="0 */1 * * * ?" />&lt;!&ndash; 每隔1min執(zhí)行一次 &ndash;&gt;-->
  </bean>
  <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
    <property name="triggers">
      <list>
         <ref bean="deleteRedisCacheDayUsersTrigger" />
        <ref bean="deleteRedisCacheMonthUsersTrigger" />
        <!--暫時不用-->
         <!--<ref bean="centUpdateByMonthTrigger" />-->
      </list>
    </property>
  </bean>