feat(Process): Add custom Process Support

CHANGELOG.md

@@ -19,6 +19,7 @@
 - **system:** can get more system info via class SystemInfoHelper
 
 ### Fix
+- **Anonymous:** Fix Auth Page 500 after commit `2cd1a499`
 - **Cookies:** Fix session sep from `%` to `_`
 - **Database:** Fix table `links` miss
 - **Env:** Exit when parse env file failed

apps/config/httpd.php

@@ -43,6 +43,16 @@
 
     ],
 
+    // 用户自定义进程 （用于常驻的任务清理，将会使用Server->addProcess添加到Server上
+    'process' => [
+        //'tracker' => [
+        //    'class' => \apps\process\EchoProcess::class,
+        //    'title' => 'Test',
+        //    'components' => ['log','pdo','redis','config','site'],
+        //    'sleep' => 5,
+        //]
+    ],
+
     // 类库配置
     'libraries'        => [
 

apps/process/EchoProcess.php

@@ -0,0 +1,21 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Rhilip
+ * Date: 7/28/2019
+ * Time: 10:22 PM
+ */
+
+namespace apps\process;
+
+
+use Rid\Base\Process;
+
+class EchoProcess extends Process
+{
+    public function start()
+    {
+        println(time() . config('base.site_name'));
+        sleep(5);
+    }
+}

framework/Base/Process.php

@@ -0,0 +1,31 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Rhilip
+ * Date: 7/28/2019
+ * Time: 10:09 PM
+ */
+
+namespace Rid\Base;
+
+
+class Process implements StaticInstanceInterface
+{
+
+    use StaticInstanceTrait;
+
+    protected $_config;
+
+    public function start() {
+
+    }
+
+    final public function run($config) {
+        $this->_config = $config;
+
+        while (true) {
+            $this->start();
+            sleep($this->_config['sleep']);
+        }
+    }
+}

framework/Http/Application.php

@@ -156,9 +156,10 @@ public function __get($name)
     }
 
     // 装载全部组件
-    public function loadAllComponents()
+    public function loadAllComponents($components = null)
     {
-        foreach (array_keys($this->components) as $name) {
+        $components = $components ?? $this->components;
+        foreach (array_keys($components) as $name) {
             $this->loadComponent($name);
         }
     }

framework/Http/HttpServer.php

@@ -4,6 +4,7 @@
 
 use Rid\Base\BaseObject;
 
+use Rid\Base\Process;
 use Rid\Base\Timer;
 use Rid\Helpers\ProcessHelper;
 
@@ -71,6 +72,9 @@ public function start()
         $this->_server->on('workerExit', [$this, 'onWorkerExit']);
         $this->_server->on('request', [$this, 'onRequest']);
 
+        // 增加自定义进程
+        $this->addCustomProcess();
+
         // 欢迎信息
         $this->welcome();
 
@@ -136,7 +140,7 @@ public function onWorkerStart(\Swoole\Http\Server $server, int $workerId)
 
         // 进程命名
         if ($workerId < $server->setting['worker_num']) {
-            ProcessHelper::setTitle("rid-httpd: worker #{$workerId}");
+            ProcessHelper::setTitle("rid-httpd: http worker #{$workerId}");
         } else {
             ProcessHelper::setTitle("rid-httpd: task #{$workerId}");
         }
@@ -210,6 +214,31 @@ public function onRequest(\Swoole\Http\Request $request, \Swoole\Http\Response $
         }
     }
 
+    private function addCustomProcess()
+    {
+        foreach (app()->env('process') as $process_name => $process_config) {
+            $process_class = $process_config['class'];
+            $custom_process = new $process_class();
+            if ($custom_process instanceof Process) {
+                $process = new \Swoole\Process(function ($process) use ($process_name, $process_config, $custom_process) {
+
+                    if ($process_config['title']) ProcessHelper::setTitle($process_config['title']);
+
+                    // 实例化App
+                    $config = require $this->virtualHost['configFile'];
+
+                    $app = new Application($config);
+                    $app->setServ($this->_server);
+                    $app->loadAllComponents(array_flip($process_config['components']));
+
+                    $custom_process->run($process_config);
+                });
+
+                $this->_server->addProcess($process);
+            }
+        }
+    }
+
     // 欢迎信息
     protected function welcome()
     {