> 在common 模塊下 新建 behavior 文件夾 ,創建 AutoGrabOrder.php （示例） ``` <?php namespace app\common\behavior; use think\Db; use think\Queue; class AutoGrabOrder { public function run($param){ // 當輪到該任務時，系統將生成一個該類的實例，并調用其 fire 方法 $jobHandlerClassName = 'app\common\job\AutoGrabOrder'; // 2.當前任務歸屬的隊列名稱，如果為新隊列，會自動創建 $jobQueueName = "AutoGrabOrder"; // 3.當前任務所需的業務數據 . 不能為 resource 類型，其他類型最終將轉化為json形式的字符串 $jobData = [ 'id' => $param['id'], 'bizId' => uniqid()] ; // 4.將該任務推送到消息隊列，延遲1小時 $isPushed = Queue::later($param['time'],$jobHandlerClassName , $jobData , $jobQueueName ); // database 驅動時，返回值為 1|false ; redis 驅動時，返回值為 隨機字符串|false if( $isPushed !== false ){ //已加入隊列 Db::name("job_begin_record")->insert([ 'data'=>json_encode($param), 'date'=>date("Y-m-d H:i:s",time()) ]); }else{ //任務開始失敗 writeLog($param,"listen/job_begin_failed"); } } } ``` > 在common 模塊下 新建 job 文件夾 ,創建 AutoGrabOrder.php （示例） ``` <?php namespace app\common\job; use think\Db; use think\Exception; use think\queue\Job; /** * Class AutoGrabOrder * @package app\common\job * 到時間自動解凍 凍結金額 */ class AutoGrabOrder { public function fire(Job $job, $data) { try { //你的處理邏輯 //處理完 刪除隊列 $job->delete(); } catch (Exception $exception) { // 隊列執行異常 writeLog('queue-' . get_class() . '-AutoGrabOrder' . '：執行異常，錯誤信息：' . $exception->getMessage(), "listen/AutoGrabOrder"); } } /** * @param $data * 隊列執行失敗 */ public function failed($data) { Db::name("listen_failed")->insert([ "name" => "AutoGrabOrder", "data" => json_encode($data), "createtime" => time(), "updatetime" => time() ]); } } ``` > 調用 hook 隊列 ，在 index 模塊下 的 tags.php 添加監聽 ``` // 'AutoGrabOrder'=>[ 'app\\common\\behavior\\AutoGrabOrder' ] ``` > 控制器里調用 ``` $da=["id"=>$id,"time"=>3600]; Hook::listen("AutoGrabOrder",$da); ``` > 寶塔安裝 ， Supervisor管理器 2.2 > 添加 守護進程 > 名稱 填 AutoGrabOrder > 啟動用戶 選擇 root > 運行目錄選擇 項目目錄 > 啟動命令 `php think queue:listen --queue AutoGrabOrder` > 進程數量 1 ***** > 如果啟動失敗 ，則 刪除 php 的一些 禁用函數 ， exec ,putenv, popen 等等