当前位置：文江博客话题详情

在java中执行依赖任务

发布于 2024-10-06 00:31:43 字数 296 浏览 6 评论 0原文

我需要找到一种方法来执行相互依赖的任务。

第一个任务必须从远程服务器下载 zip 文件。
第二个任务的目标是解压缩第一个任务下载的文件。
第三个任务必须处理从 zip 中提取的文件。

因此，第三个任务依赖于第二个任务，第二个任务依赖于第一个任务。当然，如果其中一项任务失败，则不应执行其他任务。由于第一个任务从远程服务器下载文件，因此应该有一种在服务器不可用时重新启动任务的机制。任务必须每天执行。

有什么建议、模式或java API吗？

问候！

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

情未る 2024-10-13 00:31:44

这在一定程度上取决于外部要求。有用户参与吗？监控？警报？...

最简单的显然只是检查前一个是否已完成其应做的事情的方法。

download() 将文件下载到指定位置。
如果下载的文件就位，unzip() 将文件解压到指定位置。
process() 处理已提取的数据。

一种更“正式”的方法是使用工作流引擎。根据需求，您可以获得从精美的 UI 到遵循工作流的正式标准化 .XML 定义的一些功能 - 以及介于两者之间的任何功能。

http://java-source.net/open-source/workflow-engines

回复收藏 0 原文

风铃鹿 2024-10-13 00:31:44

创建一个公共方法来执行任务的完整链和私有方法：

public void doIt() {
  if (download() == false) {
     // download failed
  } else if (unzip() == false) {
     // unzip failed;
  } else (process() == false)
     // processing failed
  }
}

private boolean download() {/* ... */}
private boolean unzip() {/* ... */}
private boolean process() {/* ... */}

因此，您有一个 API 可以保证所有步骤都按正确的顺序执行，并且仅在满足某些条件时才执行步骤（上面的示例仅说明了这个图案）

Create one public method to execute the full chain and private methods for the tasks:

public void doIt() {
  if (download() == false) {
     // download failed
  } else if (unzip() == false) {
     // unzip failed;
  } else (process() == false)
     // processing failed
  }
}

private boolean download() {/* ... */}
private boolean unzip() {/* ... */}
private boolean process() {/* ... */}

So you have an API that gurantees that all steps are executed in the correct sequence and that a step is only executed if certain conditions are met (the above example just illustrates this pattern)

回复收藏 0 原文

寄居人 2024-10-13 00:31:44

对于日常执行，您可以使用 Quartz 框架。

由于任务相互依赖，我建议评估任务返回的错误代码或异常。如果之前的任务成功，则继续。

回复收藏 0 原文

秋凉 2024-10-13 00:31:44

执行这些任务的正常方法是：按顺序调用每个任务，并在出现阻止执行以下任务的失败时抛出异常。像这样的东西

try {
  download();
  unzip();
  process();
} catch(Exception failed) {
  failed.printStackTrace();
}

The normal way to perform these tasks is to; call each task in order, and throw an exception when you have a failure which prevents the following tasks being performed. Something like

try {
  download();
  unzip();
  process();
} catch(Exception failed) {
  failed.printStackTrace();
}

回复收藏 0 原文

可是我不能没有你 2024-10-13 00:31:44

我认为您感兴趣的是某种事务定义。
即
- 定义TaskA（例如下载）
- 定义TaskB（例如解压缩）
- 定义TaskC（例如进程）
假设您的目的是让任务也独立工作，例如仅下载文件（不执行TaskB，TaskC），您应该定义由TaskA，TaskB，TaskCTransaction1 > 或仅由 TaskA 组成的 Transaction2。
例如，关于 Transaction1 的语义，即 TaskA、TaskB 和 TaskC 应按顺序执行，并且可以在事务定义中捕获所有或没有捕获。
定义可以在 xml 配置文件中，您可以使用 Quartz 等框架进行调度。
更高的构造应检查事务并按定义执行它们。

回复收藏 0 原文

小梨窩很甜 2024-10-13 00:31:44

使用 Dexecutor 可以轻松执行依赖任务

免责声明：我是该库的所有者

基本上你需要以下模式

使用 Dexecutor.addDependency 方法

 DefaultDexecutor<Integer, Integer> executor = newTaskExecutor();
//Building
executor.addDependency(1, 2);
executor.addDependency(2, 3);
executor.addDependency(3, 4);
executor.addDependency(4, 5);
//Execution
executor.execute(ExecutionConfig.TERMINATING);

Dependent tasks execution made easy with Dexecutor

Disclaimer : I am the owner of the library

Basically you need the following pattern

Use Dexecutor.addDependency method

 DefaultDexecutor<Integer, Integer> executor = newTaskExecutor();
//Building
executor.addDependency(1, 2);
executor.addDependency(2, 3);
executor.addDependency(3, 4);
executor.addDependency(4, 5);
//Execution
executor.execute(ExecutionConfig.TERMINATING);

回复收藏 0 原文