江苏龙网

  1. 首页 > 人文 > >

Java|Java通过DelayQueue实现的延迟任务队列调度服务

Java|Java通过DelayQueue实现的延迟任务队列调度服务

文章图片

Java|Java通过DelayQueue实现的延迟任务队列调度服务

文章图片

Java|Java通过DelayQueue实现的延迟任务队列调度服务

文章图片


背景在我们的系统中 ， 有些时候需要用到一些延迟任务 ， 比如我们的系统A依赖于另外一个系统B ， 只有这两个系统建立连接后 ， 才能进行业务操作 。系统A把一些策略运行所需的参数、环境、指标数据发给B ，B进行策略服务运行 ， 获取结果后通知系统A 。系统A在与系统B建立连接后首先发送一些基础的系统参数 ， 然后才可以发送正常的业务数据 。所以要求我们在两个系统建立连接成功后 ， 稍微延迟一点时间发送系统参数 。其中原因是：系统建立成功后 ， 系统A立即发送参数 ， 系统B有时候会收不到 ， 因为系统连接基于tcp建立连接后进行一些认证、初始化环境操作 ， 所以tcp连接成功后 ， 业务系统的环境还没有准备好 。因此我们需要引入一个延迟任务调度服务 ， 在监听到连接成功后 ，创建一个延迟任务 ， 放入队列里面 ， 然后进行调度运行 。

因为对延迟任务调度队列要求很简单 ， 不需要做故障恢复、数据持久等安全性保障 ， 所以就引入了单机版的任务调度服务实现 。我们第一版本基于java提供的DelayQueue实现 ， 后续有第二版本支持任务持久化、故障恢复、分布式等操作 。本文先介绍基于DelayQueue怎么实现一个延迟任务调度服务 。
实现首先定义一个抽象延迟任务类AbstractDelayedTask ，具体要实现的延迟任务通过继承该类就可以被调度 。

延迟调度服务实现类DelayScheduleService ，该类通过DelayQueue实现延迟任务的调度运行 。

用例在springMvc里面直接声明一个bean对象 ， 如下：


特别需要注意的是：配置该bean的3个属性 ， 如下：
init-method=\"init\"
destroy-method=\"shutdown\"
scope=\"singleton\"
声明一个延迟任务实现类
该任务类继承AbstractDelayedTask ， 实现其抽象方法process()

在需要的地方 ， 把该延迟任务放入到队列里面去 ， 如下：
【Java|Java通过DelayQueue实现的延迟任务队列调度服务】logger.info(\"=======>scenarioDiscoveryStatus==== 已连接交易系统\");
//加入延迟任务 ， 默认10s ， 具体可以在实现类里面定制 ， 也可以通过构造函数指定
delayScheduleService.put(new DelaySendControlRuleTask(controlRuleConfigService));
这样就完成了一个延迟任务调度服务了 ， 使用非常简单 。
缺点第一版本实现的比较简陋 ，时间精度不细致、不支持故障恢复、 不支持数据持久化、不支持分布式 ， 适用于系统对延迟要求比较低 ， 任务延迟精度低的场景下使用 。其他场景须慎用 。


    推荐阅读


    上一篇：北方国际视野|中国防空系统有多强大？美媒终于说出实话：会让美隐身战机毫无用处

    下一篇：商务西服定制的颜色该怎么选择？