ThinkPHP6을 사용하여 예약된 작업 작업을 수행하는 방법은 무엇입니까?-ThinkPHP-php.cn

ThinkPHP6을 사용하여 예약된 작업 작업을 수행하는 방법은 무엇입니까?

PHPz

풀어 주다： 2023-06-12 10:26:46

원래의

4381명이 탐색했습니다.

ThinkPHP6은 효율적인 웹 애플리케이션을 개발하는 데 도움이 되는 다양한 편리한 기능을 제공하는 인기 있는 PHP 프레임워크입니다. 그 중 하나가 예약된 작업입니다. 이번 글에서는 데이터 백업, 이메일 전송 등 정기적으로 수행해야 하는 일부 작업을 ThinkPHP6의 예약 작업 기능을 사용하여 수행하는 방법을 소개하겠습니다.

Installation

ThinkPHP6은 Swoole의 코루틴 타이머를 사용하여 효율적인 예약 작업 기능을 달성합니다. 예약된 작업을 사용하기 전에 Swoole 확장을 설치했는지 확인해야 합니다.

Composer에서는 다음 명령을 통해 Swoole을 설치할 수 있습니다.

composer require swoole/swoole

로그인 후 복사

설치 후 config/app.php 파일에서 Swoole 확장 기능을 활성화해야 합니다. providers 배열을 찾아 thinkworkerProvider::class를 추가하세요: config/app.php 文件中启用 Swoole 扩展。找到 providers 数组并加入 thinkworkerProvider::class：

'providers' => [
    //…
    thinkworkerProvider::class,
],

로그인 후 복사

定义任务

在 ThinkPHP6 中，你可以使用两种方式来定义定时任务。一种是通过创建名为 appcommand 的命令类，另一种是通过扩展 thinkworkerServer 类。这里我们采用后者。

在你的项目中，你需要创建一个继承自 thinkworkerServer 的类，如下所示：

<?php
namespace appsocket;

use SwooleCoroutine;
use thinkworkerServer;

class Socket extends Server
{
    protected $socket;

    public function onWorkerStart()
    {
        // 此处可以定义在 Worker 进程启动时需要执行的操作
    }

    public function onConnect($server, $fd)
    {
        // 此处定义客户端连接时执行的操作
    }

    public function onReceive($server, $fd, $reactor_id, $data)
    {
        // 此处定义客户端发送数据时的操作
    }

    public function onClose($server, $fd)
    {
        // 此处定义客户端断开连接时的操作
    }

    public function onTask($server, $task_id, $src_worker_id, $data)
    {
        // 自定义任务处理方法
    }

    public function onFinish($server, $task_id, $data)
    {
        // 任务结束时的操作
    }

    public function onPipeMessage($server, $from_worker_id, $message)
    {
        // 此处定义进程间通讯的逻辑
    }
}

로그인 후 복사

在上面的示例中，我们定义了 onWorkerStart()、onConnect()、onReceive()、onClose()、onTask()、onFinish()、onPipeMessage() 等方法。这些方法将在对应的事件触发时自动执行。

执行任务

当我们想在后台任务中执行某个方法时，我们可以在 onWorkerStart() 中使用 Swoole 的 tick() 方法来设定定时任务的执行频率。例如，我们以下面的代码为例：

public function onWorkerStart()
{
    // 每五秒执行一次 backup() 方法
    SwooleTimer::tick(5000, function () {
        (new Backup())->backup();
    });
}

로그인 후 복사

在上面的代码中，我们设定了每5秒执行一次 backup() 方法。通过这种方式，我们可以实现定期备份数据、发送邮件等任务。

自定义任务

如果你想要执行一些更加复杂的任务，并且需要在任务过程中使用到一些长时间运行的操作，你可以使用 onTask() 和 onFinish() 方法来处理这些任务。例如，

public function onTask($server, $task_id, $src_worker_id, $data)
{
    // 此处可以定义需要在任务中执行的操作
    $result = (new Task())->execute($data);
    return $result;
}

public function onFinish($server, $task_id, $data)
{
    // 任务执行结束后的操作
    echo "Task #$task_id finished with result: $data
";
}

로그인 후 복사

在上面的代码中，我们定义了 onTask() 和 onFinish() 方法。 onTask() 方法定义了在任务中需要执行的操作，而 onFinish() 方法则定义了任务结束后的操作。如果需要在任务中执行一些长时间运行的操作，你可以在 onTask()rrreee

ThinkPHP6에서는 두 가지 방법을 사용하여 다음을 수행할 수 있습니다. 예약된 작업을 정의합니다. 하나는 appcommand라는 명령 클래스를 생성하는 것이고, 다른 하나는 thinkworkerServer 클래스를 확장하는 것입니다. 여기서는 후자를 채택합니다.

프로젝트에서 아래와 같이 thinkworkerServer에서 상속되는 클래스를 생성해야 합니다.

onWorkerStart()

onConnect()

onReceive()

onClose()

onTask()

onFinish() code>, <code>onPipeMessage()

tick( )

backup()

onTask( )

onFinish()

onTask()