1
<!--添加redis依赖-->
2
        <dependency>
3
            <groupId>org.springframework.boot</groupId>
4
            <artifactId>spring-boot-starter-data-redis</artifactId>
5
        </dependency>

1
spring:
2
  redis:
3
    host: 192.168.66.227
4
    port: 6379
5
    password:

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

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

3
import cn.tedu.mall.seckill.mapper.SeckillSpuMapper;
4
import cn.tedu.mall.seckill.utils.RedisBloomUtils;
5
import cn.tedu.mall.seckill.utils.SeckillCacheUtils;
6
import org.quartz.Job;
7
import org.quartz.JobExecutionContext;
8
import org.quartz.JobExecutionException;
9
import org.springframework.beans.factory.annotation.Autowired;
10

11
import java.time.LocalDate;
12

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

1
//定义Trigger
2
    @Bean
3
    public Trigger initSeckillTrigger(){
4
        log.info("预热触发器运行");
5
        CronScheduleBuilder cronScheduleBuilder =
6
                CronScheduleBuilder.cronSchedule("0 0/1 * * * ?");
7
        return TriggerBuilder.newTrigger()
8
                .forJob(initJobDetail())
9
                .withIdentity("initialTrigger")
10
                .withSchedule(cronScheduleBuilder)
11
                .build();
12
    }
13

14
    //布隆过滤器
15
    @Bean
16
    public JobDetail seckillBloomJobDetail(){
17
        log.info("加载布隆过滤器");
18
        return JobBuilder.newJob(SeckillBloomInitialJob.class)
19
                .withIdentity("SeckillBloom")
20
                .storeDurably()
21
                .build();
22
    }
23
    @Bean
24
    public Trigger seckillBloomTrigger(){
25
        log.info("布隆过滤器触发器运行");
26
        //方便看效果，每分钟执行一次
27
        //实际开发中根据秒杀批次定义布隆过滤器的运行时间
28
        CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule("0 0/1 * * * ?");
29
        return TriggerBuilder.newTrigger()
30
                .forJob(seckillBloomJobDetail())
31
                .withIdentity("SeckillBloomTrigger")
32
                .withSchedule(cronScheduleBuilder)
33
                .build();
34
    }

1
https://gitee.com/mingxuchn/csmall-mobile-repo.git