package cn.lili.trigger.util;
|
|
import cn.lili.trigger.enums.DelayTypeEnums;
|
|
/**
|
* 延时任务工具类
|
*
|
* @author paulG
|
* @since 2021/5/7
|
**/
|
public class DelayQueueTools {
|
|
/**
|
* 前缀
|
*/
|
private static final String PREFIX = "{rocketmq_trigger}_";
|
|
/**
|
* 组装延时任务唯一键
|
*
|
* @param type 延时任务类型
|
* @param id id
|
* @return 唯一键
|
*/
|
public static String wrapperUniqueKey(DelayTypeEnums type, String id) {
|
return "{TIME_TRIGGER_" + type.name() + "}_" + id;
|
}
|
|
|
/**
|
* 生成延时任务标识key
|
*
|
* @param executorName 执行器beanId
|
* @param triggerTime 执行时间
|
* @param uniqueKey 自定义表示
|
* @return 延时任务标识key
|
*/
|
public static String generateKey(String executorName, Long triggerTime, String uniqueKey) {
|
return PREFIX + (executorName + triggerTime + uniqueKey).hashCode();
|
}
|
|
}
|
