创建生成队列

application/api/controller/Index.php

@@ -4,6 +4,7 @@ namespace app\api\controller;
 
 use app\common\controller\Api;
 use fast\Random;
+use think\Queue;
 
 /**
  * 首页接口
@@ -57,20 +58,21 @@ class Index extends Api
         }
     }
 
-    // 流量上报
+    /**
+     * 功能: 流量上报, 生成队列, 后台进程处理流量数据
+     * @return bool|void
+     */
     public function traffic()
     {
-        $result = $this->request->request();
-        $user = \app\common\model\User::where('mobile', $result['username'])->find();
-        if(!$user){
-            return $this->err();
-        }
-        $find = \app\common\model\User::where('id',$user->id)->setInc('traffic',$result['bytes']);
-    	file_put_contents('./log.txt',time()."_".$result['bytes']."\n",8);
-        if($find){
-            return 'true';
+        $jobData = $this->request->request();
+        $jobHandlerClassName = "app\job\FlowLog";
+        $jobName = "FlowLog";
+        $jobData['time'] = time();
+        $ret = Queue::push($jobHandlerClassName, $jobData, $jobName);
+        if ($ret) {
+            return header('HTTP/1.0 204 Success');
         }
-        return $this->err();
+        return false;
     }
 
 

application/api/controller/User.php

@@ -141,9 +141,9 @@ class User extends Api
             break;
         }
 
-        $password = Random::alnum(6);
+        $password = Random::numeric(8);
         $email = "test@qq.com";
-        $mobile = "18888888888";
+        $mobile = "188".Random::numeric(8);
 
         if ($ret = $this->auth->register($username, $password, $email, $mobile, [])) {
             var_dump($username);
@@ -154,15 +154,6 @@ 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/common/model/FlowLogs.php

@@ -0,0 +1,12 @@
+<?php
+
+
+namespace app\common\model;
+
+
+use think\Model;
+
+class FlowLogs extends Model
+{
+
+}

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

@@ -2,6 +2,7 @@
 
 
 namespace app\job;
+use app\common\model\FlowLogs;
 use think\queue\job;
 
 
@@ -9,9 +10,13 @@ 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();
+        list($ip, $port) = explode(':', $data['client_addr']);
+
+        FlowLogs::create([
+            'username'  =>  $data['username'],
+            'ip'        =>  $ip,
+            'bytes'     =>  $data['bytes'],
+            'created_at'    => $data['time']
+        ]);
     }
 }