@Autowired
    private RedisBloomUtils redisBloomUtils;
    @Override
    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        //具体要执行的任务--输出当前时间
//        System.out.println("=============="+LocalDateTime.now()+"==============");
//        StockReduceCountDTO stockReduceCountDTO = new StockReduceCountDTO();
//        stockReduceCountDTO.setCommodityCode("PU201");
//        stockReduceCountDTO.setReduceCount(-1);
//        stockService.reduceCommodityCount(stockReduceCountDTO);
        //先简单发送一个字符串
        //convertAndSend([交换机名称],[路由key的名称],[要发送的消息])
//        rabbitTemplate.convertAndSend(
//                RabbitMQConfig.STOCK_EX,RabbitMQConfig.STOCK_ROUT,"消息：执行减少库存的操作");
        // 先定义向布隆过滤器中保存的元素
        String[] colors={"red","green","yellow","pink","blue"};
        //向布隆过滤器中保存这些元素
        redisBloomUtils.bfmadd("colorBloom",colors);
        //定义一个要判断的字符
        String element="black";
        //输出判断结果
        System.out.println("判断"+ element +"是否在布隆过滤器中："+
                redisBloomUtils.bfexists("colorBloom",element));
    }

package cn.tedu.mall.seckill.timer.job;

import cn.tedu.mall.seckill.mapper.SeckillSpuMapper;
import cn.tedu.mall.seckill.utils.RedisBloomUtils;
import cn.tedu.mall.seckill.utils.SeckillCacheUtils;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.beans.factory.annotation.Autowired;

import java.time.LocalDate;

//将spuId保存到布隆过滤器中
public class SeckillBloomInitialJob implements Job {
    @Autowired
    private RedisBloomUtils redisBloomUtils;
    @Autowired
    private SeckillSpuMapper seckillSpuMapper;
    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        //首先确定保存布隆过滤器的批次的key
        //我们这里设计添加两个秒杀批次的布隆过滤器
        //避免两个批次之间瞬间的空档期
        //而且也允许让用户看到下一个批次的商品
        //key可能是这样：“spu:bloom:filter:2023-03-06”
        String bloomTodayKey = SeckillCacheUtils.getBloomFilterKey(LocalDate.now());
        String bloomTomorrowKey = SeckillCacheUtils.getBloomFilterKey(LocalDate.now().plusDays(1));
        //到数据库中根据秒杀时间查询对应的SpuId集合
        Long[] spuIds = seckillSpuMapper.findAllSeckillSpuIds();
        //布隆过滤器支持String[]数组类型的参数，将数据保存到redis中
        String[] spuIdStrs =  new String[spuIds.length];
        //将spuIds中的数据转为String类型，赋值到spuIdStrs
        for (int i = 0; i < spuIds.length; i++) {
            spuIdStrs[i]=spuIds[i]+"";
        }
        //spuIdStrs保存到布隆过滤器中
        //实际开发中，每个批次的spuId是不一样的，这里是学习阶段使用了相同的spuId
        redisBloomUtils.bfmadd(bloomTodayKey,spuIdStrs);
        redisBloomUtils.bfmadd(bloomTomorrowKey,spuIdStrs);
        System.out.println("将两个批次的布隆过滤器加载完成");
    }
}

//定义Trigger
    @Bean
    public Trigger initSeckillTrigger(){
        log.info("预热触发器运行");
        CronScheduleBuilder cronScheduleBuilder =
                CronScheduleBuilder.cronSchedule("0 0/1 * * * ?");
        return TriggerBuilder.newTrigger()
                .forJob(initJobDetail())
                .withIdentity("initialTrigger")
                .withSchedule(cronScheduleBuilder)
                .build();
    }

    //布隆过滤器
    @Bean
    public JobDetail seckillBloomJobDetail(){
        log.info("加载布隆过滤器");
        return JobBuilder.newJob(SeckillBloomInitialJob.class)
                .withIdentity("SeckillBloom")
                .storeDurably()
                .build();
    }
    @Bean
    public Trigger seckillBloomTrigger(){
        log.info("布隆过滤器触发器运行");
        //方便看效果，每分钟执行一次
        //实际开发中根据秒杀批次定义布隆过滤器的运行时间
        CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule("0 0/1 * * * ?");
        return TriggerBuilder.newTrigger()
                .forJob(seckillBloomJobDetail())
                .withIdentity("SeckillBloomTrigger")
                .withSchedule(cronScheduleBuilder)
                .build();
    }

@Autowired
private RedisBloomUtils redisBloomUtils; 
 //根据spuId查询spu详情
 @Override
 public SeckillSpuVO getSeckillSpu(Long spuId) {
     //先判断当前spuId是否在布隆过滤器中
     String bloomTodayFilter = SeckillCacheUtils.getBloomFilterKey(LocalDate.now());
     log.info("当前批次的布隆过滤器key为：{}",bloomTodayFilter);
     //如果不存在。直接抛出异常
     if(!redisBloomUtils.bfexists(bloomTodayFilter,spuId+"")){
         //进入这里表示布隆过滤器没有这个spuId，防止缓存穿透，抛出异常
         throw new CoolSharkServiceException(ResponseCode.NOT_FOUND,"您访问的商品不存在(测试：布隆过滤器)");
     }
     //声明返回值类型对象
     SeckillSpuVO seckillSpuVO = new SeckillSpuVO();
  ......   
 }