C D E G M P S T
C
- channel() - 接口 中的方法cn.jdevelops.delay.core.execute.DelayExecute
-
获取频道
- cn.jdevelops.delay.core.entity - 程序包 cn.jdevelops.delay.core.entity
-
- cn.jdevelops.delay.core.execute - 程序包 cn.jdevelops.delay.core.execute
-
- cn.jdevelops.delay.core.factory - 程序包 cn.jdevelops.delay.core.factory
-
- cn.jdevelops.delay.core.scan - 程序包 cn.jdevelops.delay.core.scan
-
- cn.jdevelops.delay.core.service - 程序包 cn.jdevelops.delay.core.service
-
- cn.jdevelops.delay.core.util - 程序包 cn.jdevelops.delay.core.util
-
- consumeDelay() - 接口 中的方法cn.jdevelops.delay.core.service.DelayService
-
消费延迟队列数据
D
- DelayExecute<T extends DelayQueueMessage> - cn.jdevelops.delay.core.execute中的接口
-
延迟来了之后要执行的方法接口,具体使用是构建实现
- delayExecute(T) - 接口 中的方法cn.jdevelops.delay.core.execute.DelayExecute
-
策略执行方法
- delayExecute(T) - 类 中的方法cn.jdevelops.delay.core.factory.DelayFactory
-
执行 DelayExecute的 实现,根据 channel 查询该走哪一个实现
- DelayFactory<T extends DelayQueueMessage> - cn.jdevelops.delay.core.factory中的类
-
延时执行方法的工厂类
- DelayFactory() - 类 的构造器cn.jdevelops.delay.core.factory.DelayFactory
-
- delayFactory() - 类 中的方法cn.jdevelops.delay.core.scan.EnableAutoScanDelayCore
-
延迟方法的调用工厂
- DelayQueueMessage - cn.jdevelops.delay.core.entity中的类
-
延时消息
- DelayQueueMessage() - 类 的构造器cn.jdevelops.delay.core.entity.DelayQueueMessage
-
- DelayQueueMessage(String, String, Long, String, String) - 类 的构造器cn.jdevelops.delay.core.entity.DelayQueueMessage
-
添加延迟队列数据
- DelayService<T extends DelayQueueMessage> - cn.jdevelops.delay.core.service中的接口
-
jdk延时队列 没有默认实现
优点: 效率高,低延迟
缺点: 宕机丢失(可以存数据库),不利于集群扩展
E
- EnableAutoScanDelayCore - cn.jdevelops.delay.core.scan中的类
-
自动扫描
- EnableAutoScanDelayCore() - 类 的构造器cn.jdevelops.delay.core.scan.EnableAutoScanDelayCore
-
G
- getBody() - 类 中的方法cn.jdevelops.delay.core.entity.DelayQueueMessage
-
- getChannel() - 类 中的方法cn.jdevelops.delay.core.entity.DelayQueueMessage
-
- getDelayTime() - 类 中的方法cn.jdevelops.delay.core.entity.DelayQueueMessage
-
- getDelayTimeStr() - 类 中的方法cn.jdevelops.delay.core.entity.DelayQueueMessage
-
- getDesc() - 类 中的方法cn.jdevelops.delay.core.entity.DelayQueueMessage
-
- getId() - 类 中的方法cn.jdevelops.delay.core.entity.DelayQueueMessage
-
- getSha256StrJava(String) - 类 中的静态方法cn.jdevelops.delay.core.util.Md5Util
-
利用java原生的摘要实现SHA256加密
M
- Md5Util - cn.jdevelops.delay.core.util中的类
-
MD5
- Md5Util() - 类 的构造器cn.jdevelops.delay.core.util.Md5Util
-
P
- produce(T) - 接口 中的方法cn.jdevelops.delay.core.service.DelayService
-
生产延迟队列消息
- produce(List<T>) - 接口 中的方法cn.jdevelops.delay.core.service.DelayService
-
生产延迟队列消息
S
- setBody(String) - 类 中的方法cn.jdevelops.delay.core.entity.DelayQueueMessage
-
- setChannel(String) - 类 中的方法cn.jdevelops.delay.core.entity.DelayQueueMessage
-
- setDelayTime(Long) - 类 中的方法cn.jdevelops.delay.core.entity.DelayQueueMessage
-
- setDelayTimeStr(String) - 类 中的方法cn.jdevelops.delay.core.entity.DelayQueueMessage
-
- setDesc(String) - 类 中的方法cn.jdevelops.delay.core.entity.DelayQueueMessage
-
- setId(String) - 类 中的方法cn.jdevelops.delay.core.entity.DelayQueueMessage
-
T
- toString() - 类 中的方法cn.jdevelops.delay.core.entity.DelayQueueMessage
-
C D E G M P S T
Copyright © 2024 tan. All rights reserved.