redisDelayHandler

介绍

实现redis延迟（延时）任务处理器（设计中）。针对delayMessage项目中的Redis延迟任务实现方案，简化其延迟任务处理的逻辑复杂度，增强部分其他功能

优势

相比于RabbitMQ，该项目的优势在于可以在同一个key中处理多个不同逻辑、不同延迟时间的任务。 RabbitMQ受限于队列的先进先出策略，同一个队列中后进的消息就算延迟时间更短，也不能出队列到死信队列中执行延迟任务。

软件架构

3.1 任务轮询模式

支持任务轮询的三种模型

public模型：公共轮询线程，key等于delay.task.public
customize模型：自定义轮询线程，获取数据后，根据任务类型分别执行处理器Handler
exclusive模型（默认）：独立轮询线程，获取数据后，调用各类型的处理器Handler执行任务

3.2 任务失败策略

任务处理失败，默认重试3次，重试间隔时间0毫秒
@DelayListener(retry=-1)时，将一直重试，直到成功为止

使用说明

第一步：添加redisDelayHandler与spring-boot-starter-data-redis依赖

<dependency>
    <groupId>com.five</groupId>
    <artifactId>redisDelayHandler</artifactId>
    <version>0.0.1-SNAPSHOT</version>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
    <optional>true</optional>
</dependency>

第二步：设置redis与redisDelayHandler的基本参数

# 若工程中已有自己的redisTemplate，不需要额外配置
spring:
  redis:
    host: 127.0.0.1
    password:
    jedis:
      pool:
        max-active: 10
        max-wait: 10
        max-idle: 10
        min-idle: 1
delay:
  handler:
    initialDelay: 1000  # 毫秒，项目初始化时，启动轮询任务的延迟时间，默认1000毫秒
    period: 1000        # 毫秒，轮询任务时间间隔，默认1000毫秒
    corePoolSize: 10    # 轮询任务核心线程数配置，默认10个
    batchSize: 10       # 每次轮询任务从redis中取出数据条数，默认10条
    threadPrefix: sync-five.delayHandler-pool  # 轮询任务线程名称前缀
    delayRate:          # 根据key配置自定义轮询频率
      public: 600        # public模型key等于"public"或key值（如果DelayListener注解中配置了key）
      xxx: 210           # customize模型key等于DelayListener注解name或key的值
      OID1: 200           # exclusive模型key等于DelayListener注解name的值

第三步：添加消息：调用DelayMessageService.sendMessage()方法

@Autowired
private DelayMessageService delayMessageService;

delayMessageService.sendMessage(new DelayMessage<String>("OID1", "value10001", 10));
delayMessageService.sendMessage(new DelayMessage<Order>("OID2", new Order(), 10));

第四步：延迟任务处理：在方法上使用@DelayListener注解

@Component
public class TestDelayHandler {

    @DelayListener(name ="OID1", mode = DelayPollModeConf.MODE_PUBLIC)
    public void process1(String value){
        System.out.println(DateUtil.format(new Date(), "yyyy-MM-dd HH:mm:ss")+"-------->任务处理成功！ com.five.delay.temp.TestDelayHandler.process1   ==== " + value);
    }

    @DelayListener(name ="OID2", mode = DelayPollModeConf.MODE_CUSTOMIZE, task = "task.name")
    public void process2(Order order){
        System.out.println(DateUtil.format(new Date(), "yyyy-MM-dd HH:mm:ss")+"-------->任务处理成功！ com.five.delay.temp.TestDelayHandler.process2   ==== " + order);
    }

    @DelayListener(name ="OID3")
    public void process3(String value){
        System.out.println(DateUtil.format(new Date(), "yyyy-MM-dd HH:mm:ss")+"-------->任务处理成功！ com.five.delay.temp.TestDelayHandler.process3   ==== " + value);
    }
    
    @DelayListener(name ="OID4", mode = DelayPollModeConf.MODE_CUSTOMIZE, task = "task.name", retry = 1, retryDelay = 1000)
    public void process4(Order order){
        System.out.println(DateUtil.format(new Date(), "yyyy-MM-dd HH:mm:ss")+"-------->任务处理成功！ com.five.delay.temp.TestDelayHandler.process4   ==== " + order);
        // process4() 方法抛出异常，则认为任务处理失败，1秒中后，继续重试
    }
}

TODO LIST

支持三种任务轮询模式
支持消息类型多样化
任务失败处理机制
当前没有任务时，降低轮询的频率
轮询性能优化(优化中)
后台管理webAdmin

smallFive55/redisDelayHandler