feat(Timer): Add Timer Example

apps/config/http_base.php

@@ -209,6 +209,16 @@
         ],
     ],
 
+    // 定时器配置
+    'timer'            => [
+        'crontab' => [
+            'class' => \apps\task\CronTabTimer::class,
+            'type' => \Rid\Base\Timer::TICK,
+            'msec' => 1 * 1000,    // 单位为毫秒
+            'callback' => 'init'
+        ]
+    ],
+
     // 类库配置
     'libraries'           => [
         'swiftmailer' => [

apps/task/CronTabTimer.php

@@ -0,0 +1,19 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Rhilip
+ * Date: 2019/3/17
+ * Time: 22:19
+ */
+
+namespace apps\task;
+
+use Rid\Base\Timer;
+
+class CronTabTimer extends Timer
+{
+    public function init()
+    {
+
+    }
+}

framework/Base/Timer.php

@@ -16,6 +16,10 @@
 class Timer implements StaticInstanceInterface
 {
     use StaticInstanceTrait;
+
+    const AFTER = 'after';
+    const TICK = 'tick';
+
     /**
      * 定时器ID
      * @var int
@@ -84,4 +88,14 @@ public function clear()
         }
         return false;
     }
+
+    public function run($config)
+    {
+        $type = $config['type'];
+        $msec = $config['msec'];
+        $callback = $config['callback'];
+
+        println('New Timer '. self::class .' added. (Type: ' . $type . ', msec: ' . $msec . ', callback function: ' . $callback . ')');
+        $this->{$type}($msec, [$this, $callback]);
+    }
 }

framework/Http/HttpServer.php

@@ -5,6 +5,7 @@
 use Rid\Base\BaseObject;
 
 use Rid\Base\TaskInterface;
+use Rid\Base\Timer;
 use Rid\Exceptions\TaskException;
 use Rid\Helpers\ProcessHelper;
 
@@ -108,6 +109,16 @@ protected function onWorkerStart()
             $app->setServ($this->_server);
             $app->setWorker($workerId);
             $app->loadAllComponents();
+
+            if ($workerId == 0) {  // 将系统设置中的 Timer 添加到 worker #0 中
+                foreach (app()->env('timer') as $timer_name => $timer_config) {
+                    $timer_class = $timer_config['class'];
+                    $timer = new $timer_class();
+                    if ($timer instanceof \Rid\Base\TimerInterface) {
+                        $timer->run($timer_config);
+                    }
+                }
+            }
         });
     }
 

framework/Rid.php

@@ -7,7 +7,7 @@ class Rid
 {
 
     // 版本号
-    const VERSION = 'v0.1.2-alpha';
+    const VERSION = 'v0.1.3-alpha';
 
     // App实例
     protected static $_app;