任务调度

[[toc]]

介绍

过去，你可能需要在服务器上为每一个调度任务去创建 Cron 条目。因为这些任务的调度不是通过代码控制的，你要查看或新增任务调度都需要通过 SSH 远程登录到服务器上去操作，所以这种方式很快会让人变得痛苦不堪。

Goravel 的命令行调度器允许你在 Goravel 中清晰明了地定义命令调度。在使用这个任务调度器时，你只需要在你的服务器上创建单个 Cron 入口。

定义调度

你可以在 app\console\kernel.go 的 Schedule 方法中定义所有的调度任务。在开始之前，我们来看一个例子：我们计划每天午夜执行一个 闭包，这个 闭包 会执行一次数据库语句去清空一张表：

package console
import (
  "github.com/goravel/framework/contracts/console"
  "github.com/goravel/framework/schedule/support"
  "github.com/goravel/framework/facades"
  "goravel/app/models"
)
type Kernel struct {
}
func (kernel Kernel) Schedule() []*support.Event {
  return []*support.Event{
    facades.Schedule.Call(func() {
      facades.Orm.Query().Where("1 = 1").Delete(&models.User{})
    }).Daily(),
  }
}

Artisan 命令调度

调度方式不仅有闭包调用，还可以使用 Artisan commands。例如，你可以给 command 方法传递命令名称或类来调度一个 Artisan 命令：

package console
import (
  "github.com/goravel/framework/contracts/console"
  "github.com/goravel/framework/schedule/support"
  "github.com/goravel/framework/facades"
)
type Kernel struct {
}
func (kernel *Kernel) Schedule() []*support.Event {
  return []*support.Event{
    facades.Schedule.Command("send:emails name").Daily(),
  }
}

调度频率选项

我们已经看到了几个如何设置任务在指定时间间隔运行的例子。不仅如此，你还有更多的任务调度频率可选：

避免任务重复

默认情况下，即使之前的任务实例还在执行，调度内的任务也会执行。为避免这种情况的发生，你可以使用 SkipIfStillRunning 或 DelayIfStillRunning 方法：

facades.Schedule.Command("send:emails name").EveryMinute().SkipIfStillRunning()
facades.Schedule.Command("send:emails name").EveryMinute().DelayIfStillRunning()

运行调度程序

现在，我们已经学会了如何定义计划任务，接下来让我们讨论如何真正在服务器上运行它们。

在根目录 main.go 文件中增加 go facades.Schedule.Run()。

package main
import (
  "github.com/goravel/framework/facades"
  "goravel/bootstrap"
)
func main() {
  //This bootstraps the framework and gets it ready for use.
  bootstrap.Boot()
  //Start schedule by facades.Schedule
  go facades.Schedule.Run()
  select {}
}