~~~
<?php
<?php
/**
* Created by PhpStorm.
* User: Mikkle
* QQ:776329498
* Date: 2017/9/19
* Time: 10:10
*/
namespace app\task\library\Base;
use think\Exception;
use think\Log;
abstract class TimeWorkerBase extends WorkerBase
{
protected $listName;
protected $listData;
protected $listNum;
protected $lockName;
public function _initialize($options = [])
{
$this->listData = "{$this->listName}_data";
$this->listNum = "{$this->listName}_num";
}
/**
* 當命令行未運行 直接執行
* description add
* @param $data 傳入 runHandle中的數據
* @param $runTime 時間戳 可以是多少秒后的int,也可以是指定時間的時間戳
* @param array $options
* @param string $handleName 可以自己重寫的方法名
* @return bool
*/
static public function add($data, $runTime = 0, $handleName = "run", $options = [])
{
try {
$data = json_encode($data);
$instance = static::instance($options);
switch (true) {
case (self::checkCommandRun()):
$time = $instance->getRunTime($runTime);
$num = $instance->redis()->incre($instance->listNum);
Log::notice("添加了 $num 號定時任務");
$instance->redis()->zAdd($instance->listName, [$time => $num]);
$instance->redis()->hSet($instance->listData, $num, $data);
Log::notice("Timing Command service start work!!");
$instance->runWorker($handleName);
break;
default:
Log::notice("Timing Command service No away!!");
$instance->runHandle($data);
}
return true;
} catch (Exception $e) {
Log::error($e->getMessage());
return false;
}
}
/**
* 命令行執行的方法
*/
static public function run()
{
try {
$i = 0;
$instance = static::instance();
//讀取并刪除定時任務
$workList = $instance->redis()->zRangByScore($instance->listName, 0, time());
//刪除
$instance->redis()->ZRemRangeByScore($instance->listName, 0,time());
//剩余任務數
$re = $instance->redis()->zCard($instance->listName);
if ( $workList ){
foreach ($workList as $num) {
try {
$redisData = $instance->redis()->hGet($instance->listData, $num);
if ($redisData) {
$data = json_decode($redisData, true);
$result = $instance->runHandle($data);
Log::notice("執行{$num}編號任務");
if ($instance->saveLog) {
$instance->saveRunLog($result, $data);
}
$instance->redis()->hDel($instance->listData, $num);
}
} catch (Exception $e) {
Log::error($e->getMessage());
$instance->redis()->zAdd($instance->listData, [(time() + 300) => $num]);
}
$i++;
sleep(1);
}
}
if ( $re == 0) {
$instance->clearWorker();
}
echo "執行了{$i}次任務,剩余未執行任務[{$re}]項" . PHP_EOL;
Log::notice("執行了{$i}次任務,剩余未執行任務[{$re}]項");
} catch (Exception $e) {
//Log::error($e);
Log::error($e->getMessage());
echo($e->getMessage());
}
}
//判斷執行時間
protected function getRunTime($time = 0)
{
$now = time();
switch (true) {
case ($time == 0):
return $now;
break;
case (is_int($time) && 30 * 3600 * 24 > $time):
return $now + $time;
break;
case (is_int($time) && $now < $time):
return $time;
break;
default:
return $now + (int)$time;
}
}
}
~~~
- PHP7新特性
- 優雅的寫代碼
- 常見的代碼優化
- 常用的工具類
- PHP原生生成EXCEL
- PHP地理位置計算
- PHP獲取服務器狀態
- 駝峰轉下劃線
- 百度地圖兩點坐標距離計算
- 判斷是否是url
- PHP常見header頭
- 郵件發送類
- 阿拉伯數字轉化為大寫
- 獲取漢字首個拼音
- 根據身份證號獲取星座
- 生成驗證碼類
- 生成唯一ID
- 身份證驗證類
- PHP中文轉拼音
- Nginx配置文件
- curl獲取網頁內容
- 快遞查詢api
- 上傳圖片類
- 股票類
- 找回密碼類
- 字符串助手函數
- 校驗數據規則
- PHP獲取收集相關信息
- 字符串截取助手函數
- 網頁中提取關鍵字
- 檢測瀏覽器語言
- 微信相關類
- 微信獲取access_token
- 獲取用戶基本信息
- 代碼規范
- 編程規范(psr-1,2)
- 編程規范(原作者的建議)
- 經驗
- 常用函數地址
- 函數集合
- 一些常識
- MYSQL相關知識
- 常用sql
- mysql事務隔離級別
- Read uncommitted
- Read committed
- Repeatable read
- Serializable
- 高性能MYSQL讀書筆記
- 第一章MYSQL的架構
- mysql邏輯架構
- redis相關知識
- 1.安裝redis
- 3.php操作redis
- 隊列
- 悲觀鎖
- 樂觀鎖
- 發布
- 訂閱
- redis實戰-文章投票
- 設計模式
- 創建模型實例
- 單例模式
- 工廠模式
- AnimalInterface.php
- Chicken.php
- Factory.php
- Farm.php
- Pig
- SampleFactory.php
- Zoo
- 抽象工廠模式
- AnimalFactory
- Factory
- FarmInterface
- Income
- PandaZoo
- PeonyZoo
- PigFarm
- PlantFactory
- RiceFarm
- ZooInterface
- 原型模式
- 建造者模式
- 結構型模式實例
- 橋接模式
- 享元模式
- 外觀模式
- 適配器模式
- 裝飾器模式
- 組合模式
- 代理模式哦
- 過濾器模式
- 行為型模式實例
- 模板模式
- 策略模式
- 狀態模式
- 觀察者模式
- 責任鏈模式
- 訪問者模式
- 解釋器模式
- 空對象模式
- 中介者模式
- 迭代器模式
- 命令模式
- 備忘錄模式
- 網絡知識
- 互聯網協議概述
- nginx簡易交互過程
- HTTP知識
- LINUX相關知識
- swoole學習
- 1.初識swoole
- 2.WebSocket PHP 即時通訊開發
- 3.異步多進程的 CURL
- 4.異步非阻塞多進程的 Http 服務器
- 5.TCP 服務器
- 5.1同步 TCP 客戶端
- 5.2異步 TCP 客戶端
- 6.UDP 服務器
- 7.異步多任務處理
- 8.毫秒定時器
- 9.高并發投票
- ThinkPHP5學習
- 命令行操作
- 所有命令行中用到的基類
- 1.base
- 2.WorkerBase
- 3.TimeWorkerBase
- 4.CycleWorkerBase
- 5.WorkerCommandBase
- 6.WorkerHookBase
- 1.基礎命令實現
- 2.建立Linux上的守護源碼
- 3.發送模板消息
- 4.基于命令行實現自己的隊列模式
- 5.發送定時短信
- thinkphp5使用sentry
- sentry通知,記錄日志
- 高級查詢
- Kafka相關
- 1.安裝
- 2.為php打擴展
- 3.kafka實現
- 一些工具搭建
- sentry日志收集系統搭建
- walle搭建
- php實現定時任務
- 檢測文件變化