Merge remote-tracking branch 'origin/develop' into develop

Author: lisgroup

laravel/app/Events/TestEvent.php

@@ -0,0 +1,28 @@
+<?php
+/**
+ * 创建事件类--异步事件
+ * 此特性依赖Swoole的AsyncTask，必须先设置config/laravels.php的swoole.task_worker_num。
+ * 异步事件的处理能力受Task进程数影响，需合理设置task_worker_num。
+ * User: lisgroup
+ * Date: 19-4-13
+ * Time: 下午10:23
+ */
+
+namespace App\Events;
+
+use Hhxsv5\LaravelS\Swoole\Task\Event;
+
+class TestEvent extends Event
+{
+    private $data;
+
+    public function __construct($data)
+    {
+        $this->data = $data;
+    }
+
+    public function getData()
+    {
+        return $this->data;
+    }
+}

laravel/app/Http/Controllers/AuthController.php

@@ -7,6 +7,7 @@
 
 use App\Events\LoginEvent;
 use App\Http\Repository\UserRepository;
+use Hhxsv5\LaravelS\Swoole\Task\Event;
 use Jenssegers\Agent\Agent;
 
 class AuthController extends Controller
@@ -52,6 +53,7 @@ public function login()
 
         // 登录成功，触发事件
         event(new LoginEvent(auth('api')->user(), new Agent(), \Request::getClientIp(), time()));
+        // Event::fire(new LoginEvent(auth('api')->user(), new Agent(), \Request::getClientIp(), time()));
 
         $data = [
             'access_token' => $token,

laravel/app/Listeners/LoginListener.php

@@ -3,12 +3,19 @@
 namespace App\Listeners;
 
 use App\Events\LoginEvent;
+use Hhxsv5\LaravelS\Swoole\Task\Event;
+use Hhxsv5\LaravelS\Swoole\Task\Listener;
 use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Support\Facades\DB;
 use Zhuzhichao\IpLocationZh\Ip;
 
 class LoginListener implements ShouldQueue
 {
+    // 声明没有参数的构造函数
+    public function __construct()
+    {
+    }
+
     /**
      * 失败重试次数
      *
@@ -21,7 +28,7 @@ class LoginListener implements ShouldQueue
      *
      * @param LoginEvent $event
      */
-    public function handle(LoginEvent $event)
+    public function handle(Event $event)
     {
         //获取事件中保存的信息
         $user = $event->getUser();

laravel/app/Listeners/TestListener.php

@@ -0,0 +1,36 @@
+<?php
+
+/**
+ * 创建监听器类
+ * User: lisgroup
+ * Date: 19-4-13
+ * Time: 下午10:28
+ */
+
+namespace App\Listeners;
+
+use App\Tasks\TestTask;
+use Hhxsv5\LaravelS\Swoole\Task\Task;
+use Hhxsv5\LaravelS\Swoole\Task\Event;
+use Hhxsv5\LaravelS\Swoole\Task\Listener;
+
+class TestListener extends Listener
+{
+    // 声明没有参数的构造函数
+    public function __construct()
+    {
+    }
+
+    public function handle(Event $event)
+    {
+        \Log::info(__CLASS__.':handle start', [$event->getData()]);
+        sleep(2);// 模拟一些慢速的事件处理
+        // 监听器中也可以投递Task，但不支持Task的finish()回调。
+        // 注意：
+        // 1.参数2需传true
+        // 2.config/laravels.php中修改配置 task_ipc_mode 为1或2，参考 https://wiki.swoole.com/wiki/page/296.html
+        // $ret = Task::deliver(new TaskEvent('task data'), true);
+        // var_dump($ret);
+        // throw new \Exception('an exception');// handle时抛出的异常上层会忽略，并记录到Swoole日志，需要开发者try/catch捕获处理
+    }
+}

laravel/app/Tasks/TestTask.php

@@ -0,0 +1,38 @@
+<?php
+/**
+ * 创建异步任务类
+ * User: lisgroup
+ * Date: 19-4-13
+ * Time: 下午10:23
+ */
+
+namespace App\Tasks;
+
+use Hhxsv5\LaravelS\Swoole\Task\Task;
+
+class TestTask extends Task
+{
+    private $data;
+    private $result;
+
+    public function __construct($data)
+    {
+        $this->data = $data;
+    }
+
+    // 处理任务的逻辑，运行在Task进程中，不能投递任务
+    public function handle()
+    {
+        \Log::info(__CLASS__.':handle start', [$this->data]);
+        sleep(2);// 模拟一些慢速的事件处理
+        // throw new \Exception('an exception');// handle时抛出的异常上层会忽略，并记录到Swoole日志，需要开发者try/catch捕获处理
+        $this->result = 'the result of '.$this->data;
+    }
+
+    // 可选的，完成事件，任务处理完后的逻辑，运行在Worker进程中，可以投递任务
+    public function finish()
+    {
+        \Log::info(__CLASS__.':finish start', [$this->result]);
+        // Task::deliver(new TestTask2('task2')); // 投递其他任务
+    }
+}

laravel/config/laravels.php

@@ -29,16 +29,29 @@
     'processes'                => [
     ],
     'timer'                    => [
-        'enable' => false,
+        'enable' => false, // 开启定时任务类
         'jobs'   => [
+            // 启用LaravelScheduleJob来执行`php artisan schedule:run`，每分钟一次，替代Linux Crontab
+            // \Hhxsv5\LaravelS\Illuminate\LaravelScheduleJob::class,
+            // 两种配置参数的方式：
+            // [\App\Jobs\Timer\TestCronJob::class, [1000, true]], // 注册时传入参数
+            \App\Jobs\Timer\TestCronJob::class, // 重载对应的方法来返回参数
             // Enable LaravelScheduleJob to run `php artisan schedule:run` every 1 minute, replace Linux Crontab
             //\Hhxsv5\LaravelS\Illuminate\LaravelScheduleJob::class,
             // Two ways to configure parameters:
             // [\App\Jobs\XxxCronJob::class, [1000, true]], // Pass in parameters when registering
             // \App\Jobs\XxxCronJob::class, // Override the corresponding method to return the configuration
         ],
+        'max_wait_time' => 5, // Reload 时最大等待时间
     ],
-    'events'                   => [
+    // 绑定事件与监听器，一个事件可以有多个监听器，多个监听器按顺序执行
+    'events' => [
+        \App\Events\TestEvent::class => [
+            \App\Listeners\TestListener::class,
+        ],
+        // App\Events\LoginEvent::class => [
+        //     App\Listeners\LoginListener::class,
+        // ],
     ],
     'swoole_tables'            => [
     ],
@@ -56,7 +69,7 @@
         'dispatch_mode'      => 2,
         'reactor_num'        => function_exists('\swoole_cpu_num') ? \swoole_cpu_num() * 2 : 4,
         'worker_num'         => function_exists('\swoole_cpu_num') ? \swoole_cpu_num() * 2 : 8,
-        //'task_worker_num'    => function_exists('\swoole_cpu_num') ? \swoole_cpu_num() * 2 : 8,
+        'task_worker_num'    => function_exists('\swoole_cpu_num') ? \swoole_cpu_num() * 2 : 8,
         'task_ipc_mode'      => 1,
         'task_max_request'   => 5000,
         'task_tmpdir'        => @is_writable('/dev/shm/') ? '/dev/shm' : '/tmp',