任务调度SpringTask

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p" xmlns:context="http://www.springframework.org/schema/context" xmlns:task="http://www.springframework.org/schema/task" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-4.2.xsd"> <context:component-scan base-package="com.pinyougou.task"/> <task:annotation-driven/> </beans>

@Component public class SeckillTask { /** * 刷新秒杀商品 */ @Scheduled(cron="* * * * * ?") public void refreshSeckillGoods(){ System.out.println("执行了任务调度" new Date()); } }

/** * 刷新秒杀商品 */ @Scheduled(cron="0 * * * * ?") public void refreshSeckillGoods(){ System.out.println("执行了任务调度" new Date()); //查询所有的秒杀商品键集合 List ids = new ArrayList( redisTemplate.boundHashOps("seckillGoods").keys()); //查询正在秒杀的商品列表 TbSeckillGoodsExample example=new TbSeckillGoodsExample(); Criteria criteria = example.createCriteria(); criteria.andStatusEqualTo("1");//审核通过 criteria.andStockCountGreaterThan(0);//剩余库存大于0 criteria.andStartTimeLessThanOrEqualTo(new Date());//开始时间小于等于当前时间 criteria.andEndTimeGreaterThan(new Date());//结束时间大于当前时间 criteria.andIdNotIn(ids);//排除缓存中已经有的商品 List<TbSeckillGoods> seckillGoodsList= seckillGoodsMapper.selectByExample(example); //装入缓存 for( TbSeckillGoods seckill:seckillGoodsList ){ redisTemplate.boundHashOps("seckillGoods").put(seckill.getId(), seckill); } System.out.println("将" seckillGoodsList.size() "条商品装入缓存"); }

/** * 移除秒杀商品 */ @Scheduled(cron="* * * * * ?") public void removeSeckillGoods(){ System.out.println("移除秒杀商品任务在执行"); //扫描缓存中秒杀商品列表，发现过期的移除 List<TbSeckillGoods> seckillGoodsList = redisTemplate.boundHashOps("seckillGoods").values(); for( TbSeckillGoods seckill:seckillGoodsList ){ if(seckill.getEndTime().getTime()<new Date().getTime() ){//如果结束日期小于当前日期，则表示过期 seckillGoodsMapper.updateByPrimaryKey(seckill);//向数据库保存记录 redisTemplate.boundHashOps("seckillGoods").delete(seckill.getId());//移除缓存数据 System.out.println("移除秒杀商品" seckill.getId()); } } System.out.println("移除秒杀商品任务结束"); }