五月天激情丁香,国产精品2019,国产成人精品亚洲2020,国产精品免费视频一区二区三区,开心久久婷婷综合中文字幕,天堂视频在线观看免费完整版

定時(shí)任務(wù)

開發(fā)者執(zhí)行定時(shí)任務(wù)會(huì)通過 Linux 的 Crontab 去實(shí)現(xiàn),不方便去管理。EasySwoole 提供了根據(jù) LinuxCrontab 規(guī)則的定時(shí)任務(wù),最小粒度為1分鐘。

注意:舊版本(3.5.x 之前版本)的定時(shí)任務(wù)的使用請(qǐng)查看 舊版本(3.5.x之前)定時(shí)任務(wù)

創(chuàng)建一個(gè)定時(shí)任務(wù)

需要定義一個(gè)定時(shí)任務(wù)類實(shí)現(xiàn) \EasySwoole\Crontab\JobInterface 接口。

定義執(zhí)行規(guī)則

public function crontabRule(): string
{
    // 定義執(zhí)行規(guī)則 根據(jù)Crontab來定義
    return '*/1 * * * *';
}

定義 Crontab 名稱

public function jobName(): string
{
    // 定時(shí)任務(wù)的名稱
    return 'CustomCrontab';
}

定義執(zhí)行邏輯

public function run()
{
    // 定時(shí)任務(wù)的執(zhí)行邏輯

    // 開發(fā)者可投遞給task異步處理
    TaskManager::getInstance()->async(function (){
        // todo some thing
    });
}

定義異常捕獲

public function onException(\Throwable $throwable)
{
    // 捕獲run方法內(nèi)所拋出的異常
}

注冊(cè) Crontab

EasySwoole 框架全局的 mainServerCreate 事件(即項(xiàng)目根目錄的 EasySwooleEvent.php 文件的 mainServerCreate 方法中)中進(jìn)行定時(shí)任務(wù)注冊(cè)。

public static function mainServerCreate(EventRegister $register)
{
    // 配置定時(shí)任務(wù)
    $crontabConfig = new \EasySwoole\Crontab\Config();

    // 1.設(shè)置執(zhí)行定時(shí)任務(wù)的 socket 服務(wù)的 socket 文件存放的位置,默認(rèn)值為 當(dāng)前文件所在目錄
    // 這里設(shè)置為框架的 Temp 目錄
    $crontabConfig->setTempDir(EASYSWOOLE_TEMP_DIR);

    // 2.設(shè)置執(zhí)行定時(shí)任務(wù)的 socket 服務(wù)的名稱,默認(rèn)值為 'EasySwoole'
    $crontabConfig->setServerName('EasySwoole');

    // 3.設(shè)置用來執(zhí)行定時(shí)任務(wù)的 worker 進(jìn)程數(shù),默認(rèn)值為 3
    $crontabConfig->setWorkerNum(3);

    // 4.設(shè)置定時(shí)任務(wù)執(zhí)行出現(xiàn)異常的異常捕獲回調(diào)
    $crontabConfig->setOnException(function (\Throwable $throwable) {
        // 定時(shí)任務(wù)執(zhí)行發(fā)生異常時(shí)觸發(fā)(如果未在定時(shí)任務(wù)類的 onException 中進(jìn)行捕獲異常則會(huì)觸發(fā)此異常回調(diào))
    });

    // 創(chuàng)建定時(shí)任務(wù)實(shí)例
    $crontab = \EasySwoole\EasySwoole\Crontab\Crontab::getInstance($crontabConfig);

    // 注冊(cè)定時(shí)任務(wù)
    $crontab->register(new \App\Crontab\CustomCrontab());
}

完整使用示例代碼

在 EasySwoole 中使用

1.定義定時(shí)任務(wù)類,新增 \App\Crontab\CustomCrontab 文件,文件內(nèi)容如下:

<?php

namespace App\Crontab;

use EasySwoole\Crontab\JobInterface;

class CustomCrontab implements JobInterface
{
    public function jobName(): string
    {
        // 定時(shí)任務(wù)的名稱
        return 'CustomCrontab';
    }

    public function crontabRule(): string
    {
        // 定義執(zhí)行規(guī)則 根據(jù) Crontab 來定義
        // 這里是每分鐘執(zhí)行 1 次
        return '*/1 * * * *';
    }

    public function run()
    {
        // 定時(shí)任務(wù)的執(zhí)行邏輯

        // 相當(dāng)于每分鐘打印1次時(shí)間戳,這里只是參考示例。
        echo time();
    }

    public function onException(\Throwable $throwable)
    {
        // 捕獲 run 方法內(nèi)所拋出的異常
    }
}

2.注冊(cè)定時(shí)任務(wù),在 EasySwoole 框架全局的 mainServerCreate 事件(即項(xiàng)目根目錄的 EasySwooleEvent.php 文件的 mainServerCreate 方法中)中進(jìn)行定時(shí)任務(wù)注冊(cè),如下所示:

<?php

namespace EasySwoole\EasySwoole;

use App\Crontab\CustomCrontab;
use EasySwoole\EasySwoole\AbstractInterface\Event;
use EasySwoole\EasySwoole\Swoole\EventRegister;
use EasySwoole\EasySwoole\Crontab\Crontab;

class EasySwooleEvent implements Event
{
    public static function initialize()
    {
        date_default_timezone_set('Asia/Shanghai');
    }

    public static function mainServerCreate(EventRegister $register)
    {
        ###### 注冊(cè)一個(gè)定時(shí)任務(wù) ######
        // 配置定時(shí)任務(wù)
        $crontabConfig = new \EasySwoole\Crontab\Config();

        // 1.設(shè)置執(zhí)行定時(shí)任務(wù)的 socket 服務(wù)的 socket 文件存放的位置,默認(rèn)值為 當(dāng)前文件所在目錄
        // 這里設(shè)置為框架的 Temp 目錄
        $crontabConfig->setTempDir(EASYSWOOLE_TEMP_DIR);

        // 2.設(shè)置執(zhí)行定時(shí)任務(wù)的 socket 服務(wù)的名稱,默認(rèn)值為 'EasySwoole'
        $crontabConfig->setServerName('EasySwoole');

        // 3.設(shè)置用來執(zhí)行定時(shí)任務(wù)的 worker 進(jìn)程數(shù),默認(rèn)值為 3
        $crontabConfig->setWorkerNum(3);

        // 4.設(shè)置定時(shí)任務(wù)執(zhí)行出現(xiàn)異常的異常捕獲回調(diào)
        $crontabConfig->setOnException(function (\Throwable $throwable) {
            // 定時(shí)任務(wù)執(zhí)行發(fā)生異常時(shí)觸發(fā)(如果未在定時(shí)任務(wù)類的 onException 中進(jìn)行捕獲異常則會(huì)觸發(fā)此異常回調(diào))
        });

        // 創(chuàng)建定時(shí)任務(wù)實(shí)例
        $crontab = \EasySwoole\EasySwoole\Crontab\Crontab::getInstance($crontabConfig);

        // 注冊(cè)定時(shí)任務(wù)
        $crontab->register(new CustomCrontab());
    }
}

在 Swoole 中使用

<?php
use EasySwoole\Crontab\JobInterface;

require_once __DIR__ . '/vendor/autoload.php';

$http = new Swoole\Http\Server('0.0.0.0', 9501);

class JobPerMin implements JobInterface
{
    public function jobName(): string
    {
        return 'JobPerMin';
    }

    public function crontabRule(): string
    {
        return '*/1 * * * *';
    }

    public function run()
    {
        var_dump(time());
        return time();
    }

    public function onException(\Throwable $throwable)
    {
        throw $throwable;
    }
}

// 配置及注冊(cè)定時(shí)任務(wù)
$crontab = \EasySwoole\EasySwoole\Crontab\Crontab::getInstance();
$crontab->register(new JobPerMin());
$crontab->attachToServer($http);

$http->on('request', function ($request, $response) use ($crontab) {

    // 在 http 服務(wù)中直接觸發(fā)執(zhí)行定時(shí)任務(wù)
    $ret = $crontab->rightNow('JobPerMin');

    $response->header('Content-Type', 'text/plain');
    $response->end('Hello World ' . $ret);
});

$http->start();

Crontab 表達(dá)式

通用表達(dá)式:

    *    *    *    *    *
    -    -    -    -    -
    |    |    |    |    |
    |    |    |    |    |
    |    |    |    |    +----- day of week (0 - 7) (Sunday=0 or 7)
    |    |    |    +---------- month (1 - 12)
    |    |    +--------------- day of month (1 - 31)
    |    +-------------------- hour (0 - 23)
    +------------------------- min (0 - 59)

特殊表達(dá)式:

@yearly                    每年一次 等同于(0 0 1 1 *) 
@annually                  每年一次 等同于(0 0 1 1 *)
@monthly                   每月一次 等同于(0 0 1 * *) 
@weekly                    每周一次 等同于(0 0 * * 0) 
@daily                     每日一次 等同于(0 0 * * *) 
@hourly                    每小時(shí)一次 等同于(0 * * * *)
主站蜘蛛池模板: 成人精品区| 伊人第一页 | 深爱五月开心网亚洲综合 | 福利免费在线观看 | 久久久久琪琪精品色 | 四虎永久在线观看免费网站网址 | 日本免费专区 | 欧美国产精品va在线观看 | 欧美色啪 | 天天爽天天狼久久久综合 | 久久精品爱国产免费久久 | 999在线观看精品免费 | 老女人另类重囗味 | 日本不卡一区二区三区四区 | 视色影院| 国产电影午夜成年免费视频 | 久久这里只有精品久久 | 久久99网| 婷婷开心激情 | 久久男人网 | 国产高清视频在线 | 一级毛片免费观看视频 | 日美欧韩一区二去三区 | 国产欧美一区二区成人影院 | 久久精品视频3 | 四虎亚洲精品 | 成人欧美一区二区三区黑人 | 亚洲欧美精品成人久久91 | 成人xxxxx| 玖玖在线国产精品 | 色婷婷激情综合 | 啦啦啦啦高清视频免费观看 | 国产成人青青热久免费精品 | 天使萌一区二区三区免费观看 | 四虎影院精品 | 六月丁香啪啪六月激情 | 偷拍第一页 | 中文一级国产特级毛片视频 | 国产精品久久久久久久久久久不卡 | 国产精品亚洲专区在线播放 | 男人的天堂日本 |