任务调度

    过去,你可能需要在服务器上为每一个调度任务去创建 Cron 入口。但是这种方式很快就会变得不友好,因为这些任务调度不在源代码中,并且你每次都需要通过 SSH 链接登录到服务器中才能增加 Cron 入口。

    Laravel 命令行调度器允许你在 Laravel 中对命令调度进行清晰流畅的定义。且使用这个任务调度器时,你只需要在你的服务器上创建单个 Cron 入口接口。你的任务调度在 的 schedule 方法中进行定义。为了帮助你更好的入门,这个方法中有个简单的例子。

    当使用这个调度器时,你只需要把下面的 Cron 入口添加到你的服务器中即可。如果你不知道怎么在服务器中添加 Cron 入口,可以考虑使用一些服务来管理 Cron 入口,比如 :

    这个 Cron 为每分钟执行一次 Laravel 的命令行调度器。当 schedule:run 命令被执行的时候,Laravel 会根据你的调度执行预定的程序。

    你可以在 App\Console\Kernel 类的 schedule 方法中定义所有的调度任务。在开始之前,让我们来看一个例子。在这个例子中,我们计划每天午夜调用一个闭包。在闭包中,我们执行一个数据库查询来清空一张表:

    1. <?php
    2. namespace App\Console;
    3. use Illuminate\Support\Facades\DB;
    4. use Illuminate\Console\Scheduling\Schedule;
    5. use Illuminate\Foundation\Console\Kernel as ConsoleKernel;
    6. class Kernel extends ConsoleKernel
    7. {
    8. /**
    9. * 应用里的自定义 Artisan 命令
    10. *
    11. */
    12. protected $commands = [
    13. //
    14. ];
    15. /**
    16. * 定义计划任务
    17. *
    18. * @param \Illuminate\Console\Scheduling\Schedule $schedule
    19. * @return void
    20. */
    21. protected function schedule(Schedule $schedule)
    22. {
    23. $schedule->call(function () {
    24. DB::table('recent_users')->delete();
    25. })->daily();
    26. }
    27. }

    除了使用闭包来定义任务调度外,你也可以用 。

    1. $schedule->call(new DeleteRecentUsers)->daily();

    Artisan 命令调度

    除了使用调用闭包这种方式来调度外,你还可以调用 Artisan 命令 和操作系统命令。比如,你可以给 command 方法传递命令名称或者类来调度一个 Artisan 命令。

    1. $schedule->command('emails:send --force')->daily();
    2. $schedule->command(EmailsCommand::class, ['--force'])->daily();

    队列任务调度

    job 方法可以用来调度 。此方法提供了一种快捷的方式来调度任务,而无需使用 call 方法创建闭包来调度任务。

    1. $schedule->job(new Heartbeat)->everyFiveMinutes();
    2. // 分发任务到「heartbeats」队列...
    3. $schedule->job(new Heartbeat, 'heartbeats')->everyFiveMinutes();

    exec 方法可用于向操作系统发送命令:

    1. $schedule->exec('node /home/forge/script.js')->daily();

    调度频率设置

    当然了,你可以给你的任务分配多种调度计划:

    结合其他一些特定条件,我们可以生成在一周中特定时间运行的任务。举个例子,在每周一执行命令:

    1. // 每周一 13:00 执行...
    2. $schedule->call(function () {
    3. //
    4. })->weekly()->mondays()->at('13:00');
    5. // 工作日(周一至周五) 8点 至 17 点每小时执行一次...
    6. $schedule->command('foo')
    7. ->weekdays()
    8. ->hourly()
    9. ->timezone('America/Chicago')
    10. ->between('8:00', '17:00');
    方法描述
    ->weekdays();限制任务在工作日执行
    ->weekends();限制任务在周末执行
    ->sundays();限制任务在周日执行
    ->mondays();限制任务在周一执行
    ->tuesdays();限制任务在周二执行
    ->wednesdays();限制任务在周三执行
    ->thursdays();限制任务在周四执行
    ->fridays();限制任务在周五执行
    ->saturdays();限制任务在周六执行
    ->between($start, $end);限制任务在 $start$end 之间执行
    ->when(Closure);当闭包返回为真时执行
    ->environments($env);限制任务在特定环境中执行

    时间范围限制

    使用 between 来限制任务在一天中的某个时间段来执行:

    1. $schedule->command('reminders:send')
    2. ->hourly()
    3. ->between('7:00', '22:00');

    或者使用 unlessBetween 方法来为任务排除一个时间段:

    闭包测试限制

    使用 when 方法来根据测试结果来执行任务。也就是说,如果给定的闭包返回结果为 true,只要没有其他约束条件阻止任务运行,任务就会一直执行下去:

    1. $schedule->command('emails:send')->daily()->when(function () {
    2. return true;
    3. });

    skip 方法可以看做是 when 方法的逆过程。如果 skip 方法返回 true,任务就不会执行:

    1. return true;
    2. });

    使用链式调用 when 方法时,只有所有的 when 都返回 true 时,任务才会执行。

    环境约束

    environments 方法可用于仅在给定环境中执行任务:

    1. $schedule->command('emails:send')
    2. ->daily()
    3. ->environments(['staging', 'production']);

    时区

    使用 timezone 方法,你可以指定任务在给定的时区内执行:

    1. $schedule->command('report:generate')
    2. ->timezone('America/New_York')
    3. ->at('02:00')

    如果要为所有计划任务分配相同的时区,则可能希望在 app/Console/Kernel.php 文件中定义 方法。 此方法应返回应分配给所有计划任务的默认时区:

    1. /**
    2. * 获取默认情况下应为预定事件使用的时区。
    3. *
    4. * @return \DateTimeZone|string|null
    5. */
    6. protected function scheduleTimezone()
    7. {
    8. return 'America/Chicago';
    9. }

    默认情况下,即使之前的任务还在执行,调度内任务也会执行。你可以使用 withoutOverlapping 方法来避免这种情况:

    1. $schedule->command('emails:send')->withoutOverlapping();

    在这个例子中,如果 emails:send 没有正在运行,它将会每分钟执行一次。如果你的任务执行时间不确定,且你又不能准确预估出任务的执行时间,那么 withoutOverlapping 方法会显得特别有用。

    如果有需要,你可以指定「without overlapping」锁指定的时间范围。默认情况下,锁将在 24 小时后过期。

    1. $schedule->command('emails:send')->withoutOverlapping(10);

    任务只运行在一台服务器上

    为了说明任务应该在单个服务器上运行,在定义调度任务时使用 onOneServer 方法。第一个获取到任务的服务器会生成一个原子锁,用来防止其他服务器在同一时刻执行相同任务。

    后台任务

    默认情况下,同时调度的多个命令将按顺序执行。如果你有长时间运行的命令,这可能会导致后续命令的启动时间比预期的要晚。因此,你想在后台同时运行命令,可以使用 runInBackground 方法:

    1. $schedule->command('analytics:report')
    2. ->daily()
    3. ->runInBackground();

    Laravel 的队列任务在 下不会运行。因为我们不想你的调度任务干扰到你服务器上可能还未完成的项目。不过,如果你确实是想在维护模式下强制调度任务执行,你可以使用 evenInMaintenanceMode 方法:

    1. $schedule->command('emails:send')->evenInMaintenanceMode();

    Laravel 调度器提供了一些方便的方法来处理调度任务输出。首先,你可以使用 sendOutputTo 方法来输出到文件以便于后续检查:

    1. $schedule->command('emails:send')
    2. ->daily()
    3. ->sendOutputTo($filePath);

    如果希望将输出 附加 到给定文件,可以使用 appendOutputTo 方法

    1. $schedule->command('emails:send')
    2. ->daily()
    3. ->appendOutputTo($filePath);

    使用 emailOutputTo 方法,你可以将输出发送到指定邮箱。在使用邮件发送之前,你需要配置 Laravel 的 :

    1. $schedule->command('foo')
    2. ->daily()
    3. ->sendOutputTo($filePath)
    4. ->emailOutputTo('foo@example.com');

    使用 beforeafter 方法,你可以在调度任务执行前或者执行后来执行特定代码:

    1. $schedule->command('emails:send')
    2. ->daily()
    3. ->before(function () {
    4. // Task is about to start...
    5. })
    6. ->after(function () {
    7. // Task is complete...
    8. });

    Ping 网址

    使用 pingBeforethenPing 方法,你可以在任务执行前或者执行后来 ping 指定的 URL。这个方法在通知外部服务(比如 Laravel Envoyer)时将会特别有用:

    1. $schedule->command('emails:send')
    2. ->daily()
    3. ->pingBefore($url)

    只有在给定条件为 true 时,才能使用 pingBeforeIf 和 方法 ping 指定的 URL:

    所有 ping 方法都需要 Guzzle HTTP 库。你可以使用 Composer 来添加 Guzzle 到你的项目中:

    1. composer require guzzlehttp/guzzle

    本文章首发在 网站上。