从 Linux 上的 Web 环境安排作业

Question

我正在 Linux/Apache 上用 PHP 开发一个应用程序。我希望能够在应用程序内安排 PHP 作业（脚本）在将来的某个特定时间执行。

我知道很多人会推荐 cron 和 at，但首先我不需要重复（cron），其次也是最重要的是，我需要能够扩展的解决方案。 At 的设计并未考虑竞争条件，如果两个用户尝试同时添加一项作业，其中一个或两个可能会失败。

同样重要的是，作业在指定时间执行，而不仅仅是每分钟左右“轮询”一次。

有人可以建议这项任务的解决方案吗？谢谢。

Answer 1

编写一个 php 脚本作为守护进程
该脚本在后台运行，每隔几微秒唤醒一次，检查要执行的任务。如果它有一些任务要执行，它可以分叉自己并启动任务。

如果您不喜欢脚本每隔几微秒唤醒一次，您还可以计算下一个任务的睡眠时间，然后分叉来启动它。当添加或删除任务时，只需向程序发送信号，程序就会醒来并重新计算现在需要休眠多长时间。

超链接：

http://en.wikipedia.org/wiki/Daemon_%28computer_software%29

http://php.net/manual/en/function.pcntl-fork .php

http://www.php.net/manual /en/function.pcntl-signal.php

Answer 2

你可以尝试 gearman

Answer 3

您可以（我会）这样做：

• 使用 Google 的应用引擎任务队列。它有大量的免费配额（而且定价平面也不错），它可以扩展，使用网络钩子。我认为这是最容易实施的解决方案。
• beanstalkd。

Answer 4

在 POSIX 系统上，应该有 at-daemon 它基本上是一个一次性版本cron：

$ at 13:20 executeVeryImportantScript.php withPositionalParameters taken

可以通过 php 的 exec 调用（或者任何用于通过 php 执行 shell 命令的东西）。

重新实现现有的解决方案是非常糟糕的做法™：

1. 您需要实现它，这不符合成本效益
2. 您需要测试代码
3. 您需要维护代码

Answer 5

这是使用 MySQL 的 Yii2 解决方案。如果将查询/状态更新放在事务中，则可以在不同的机器上有多个工作人员。

cron table

Field         | Type        
--------------+-------------
id            | int(11)     
execute_after | timestamp   
executed_at   | timestamp   
status        | int(11)     
progress      | int(11)     
action        | varchar(255)
parameter     | varchar(255)
result        | varchar(255)

Cron class

  /** This command waits for jobs to work on by polling the DB every 10s. TODO put this into Redis.
   * 
   */
  public function actionIndex()
  {
    do {
      $job = Cron::find()->where('execute_after < :now AND status = 0 ORDER BY id ASC', [':now'=>date(DATE_ATOM)])->one();
      if($job && method_exists($this, $job->action)){
        $job->status = 1;
        $job->save() or Yii::error($job->getErrors());
        $result = $this->{$job->action}($job, $job->parameter);
        $job->status = 2;
        $job->progress = 100;
        $job->executed_at = date(DATE_ATOM);
        $job->save() or Yii::error($job->getErrors());
      }
      sleep(10);
    } while (true);
  }

然后，您可以在班级中执行任务，例如

function toggleStatus($job, $id) {

完成工作并在工作完成时更新工作进度。