> 定時器任務功能類似于Linux下的crontab;因為使用了開源的[cron-expression](https://github.com/dragonmantank/cron-expression)來解析運行周期,所以zcswoole目前最小粒度只支持到分鐘;swoole可以實現毫秒級別的定時器,所以如果你需要更小粒度的定時器需求,那么需要自己實現解析運行周期的方法;
#### 原理:
zcswoole的定時器為1秒輪詢所有任務,將到期的任務丟到task進程處理,task進程不會影響工作進程,所以理論上誤差不會很大
#### 創建任務表:
```sql
DROP TABLE IF EXISTS contrab;
CREATE TABLE contrab (
`id` INT(11) NOT NULL AUTO_INCREMENT,
`timer` VARCHAR(255)
CHARACTER SET utf8
COLLATE utf8_general_ci NOT NULL
COMMENT '定時周期',
`command` VARCHAR(255)
CHARACTER SET utf8
COLLATE utf8_general_ci NOT NULL
COMMENT '命令',
`remark` TEXT CHARACTER SET utf8
COLLATE utf8_general_ci NOT NULL
COMMENT '備注',
`create_time` DATETIME DEFAULT NULL,
`status` TINYINT(2) NOT NULL DEFAULT '0'
COMMENT '0開啟,1關閉',
PRIMARY KEY (`id`)
)
ENGINE = InnoDB
CHARSET = utf8
COLLATE utf8_general_ci
COMMENT = '定時器';
```
#### 代碼:
zcswoole在http服務已內置定時器功能,在http服務啟動時,會在第一個進程設置一個定時器,每秒輪詢所有任務
```php
/**
* http服務,繼承zcswoole的httpServer服務后,覆蓋父類方法可以擴展自己功能
* Class HttpCommand
* @package command
*/
class HttpCommand extends HttpServerCommand
{
// demo,為http服務添加一個定時器功能,重寫父類onEvent方法
public function onEvent()
{
parent::onEvent();
$this->server->on('receive', [$this, 'receive']);
$this->server->on('task', [$this, 'task']);
$this->server->on('finish', [$this, 'finish']);
}
/**
* 開始進程,重寫父類workerStart方法
* @param $server
* @param $workerID
*/
public function workerStart($server, $workerID)
{
// 為第一個進程安裝定時器
if (!$this->server->taskworker && $workerID == 0) {
Console::msg('crontab task start......');
swoole_timer_tick(1000, function(){
$records = MysqliDB::instance()->where('status', 0)->get('crontab');
foreach ($records as $record) {
$nextTime = CronExpression::factory($record['timer'])->getNextRunDate()->getTimestamp() - 1;
if (time() == $nextTime) {
$this->server->task($record['command']);
} /*else {
Console::msg("no run; next time is ".$nextTime.", now time is ". time());
}*/
}
});
}
}
/**
* 處理任務
* @param Server $server
* @param $taskID
* @param $workerID
* @param $data
* @return string
*/
public function task(Server $server, $taskID, $workerID, $data)
{
exec($data);
return $data . 'success';
}
/**
* 結束任務回調
* @param Server $server
* @param $taskID
* @param $data
*/
public function finish(Server $server, $taskID, $data)
{
Console::success('has run ' . $data);
}
}
```
#### 效果:
- 任務管理頁面:
- 后臺執行:
