队列测试

application/api/controller/User.php

@@ -6,6 +6,7 @@ use app\common\controller\Api;
 use app\common\library\Ems;
 use app\common\library\Sms;
 use fast\Random;
+use think\Queue;
 use think\Validate;
 
 /**
@@ -153,6 +154,15 @@ class User extends Api
         print_r("创建失败");
     }
 
+    public function testJob()
+    {
+        $jobHandlerClassName = "app\job\FlowLog";
+        $jobData = ['test'=>123];
+        $jobQueueName = "test";
+        $ret = Queue::push($jobHandlerClassName, $jobData, $jobQueueName);
+        var_dump($ret);
+    }
+
     /**
      * 注销登录
      */

application/extra/queue.php

@@ -10,14 +10,14 @@
 // +----------------------------------------------------------------------
 
 return [
-//    'connector' => 'Sync',
-    'connector'     =>  'Redis',
-    'expire'        =>  null,
-    'default'       =>  'default',
-    'host'          =>  '127.0.0.1',
-    'port'          =>  6379,
-    'password'      =>  'Z159357p',
-    'select'        =>  10,
-    'timeout'       =>  0,
-    'persistent'    =>  false
+    'connector' => 'Sync',
+//    'connector'     =>  'Redis',
+//    'expire'        =>  null,
+//    'default'       =>  'default',
+//    'host'          =>  '127.0.0.1',
+//    'port'          =>  6379,
+//    'password'      =>  'Z159357p',
+//    'select'        =>  10,
+//    'timeout'       =>  0,
+//    'persistent'    =>  false
 ];

application/job/FlowLog.php

@@ -0,0 +1,17 @@
+<?php
+
+
+namespace app\job;
+use think\queue\job;
+
+
+class FlowLog
+{
+    public function fire(Job $job, $data) {
+
+        var_dump($data);
+        file_put_contents('test.job', '111111111111111111111111111111');
+        echo date("Y-m-d H:i:s"). "\n";
+        $job->delete();
+    }
+}