add multi-thread support

Author: kpicaza

composer.json

@@ -17,13 +17,14 @@
   "require": {
     "php": "^7.4|^8.0",
     "ext-json": "*",
-    "antidot-fw/react-framework": "^1.0.3",
-    "antidot-fw/fast-router-adapter": "^0.1.0",
+    "antidot-fw/react-framework": "^1.1.0",
+    "antidot-fw/antidot-react-psr15": "^0.0.1",
+    "antidot-fw/fast-router-adapter": "^0.2.0",
     "antidot-fw/cli": "^1.1.0",
     "antidot-fw/container": "^0.1.0",
     "antidot-fw/dev-tools": "^0.1.2",
     "antidot-fw/event-dispatcher": "^2.0.3",
-    "antidot-fw/framework": "^0.1.1",
+    "antidot-fw/framework": "^0.2.0",
     "antidot-fw/logger": "^1.1.0",
     "antidot-fw/symfony-config-translator": "^1.1.0",
     "antidot-fw/yaml-config-provider": "^0.1.0",
@@ -66,7 +67,7 @@
     "sort-packages": true
   },
   "extra": {
-    "zf": {
+    "laminas": {
       "component-whitelist": [
         "antidot-fw/framework",
         "antidot-fw/logger",

config/config.php

@@ -15,6 +15,7 @@
 ];
 
 $aggregator = new ConfigAggregator([
+    \Antidot\React\PSR15\Container\Config\ConfigProvider::class,
     \WShafer\PSR11MonoLog\ConfigProvider::class,
     \Antidot\Event\Container\Config\ConfigProvider::class,
     \Antidot\Logger\Container\Config\ConfigProvider::class,

config/services/dependencies.prod.yaml

@@ -27,5 +27,6 @@ parameters:
           stream: 'var/log/%date%-default.log'
           level: 400
   server:
-    max_concurrency: 2048
-    workers: 16
+    max_concurrency: 512
+    buffer_size: 2097152
+    workers: 4

public/index.php

@@ -17,20 +17,27 @@
     $application = $container->get(Application::class);
     (require 'router/middleware.php')($application, $container);
     (require 'router/routes.php')($application, $container);
+    $globalConfig = $container->get('config');
+    $serverConfig = $globalConfig['server'];
 
     $loop = $container->get(LoopInterface::class);
-    Child::fork(
-        shell_exec('nproc') ? (int)shell_exec('nproc') : 16,
-        static function () use ($container) {
-            $server = $container->get(Server::class);
-            $server->on('error', static function ($err) use ($container) {
-                $logger = $container->get(LoggerInterface::class);
-                $logger->critical($err);
-            });
-
-            $socket = $container->get(Socket::class);
-            $server->listen($socket);
+    $serverInstance = static function () use ($container) {
+        $server = $container->get(Server::class);
+        $server->on('error', static function ($err) use ($container) {
+            $logger = $container->get(LoggerInterface::class);
+            $logger->critical($err);
         });
 
+        $socket = $container->get(Socket::class);
+        $server->listen($socket);
+    };
+
+    if (1 < $serverConfig['workers']) {
+        Child::fork($serverConfig['workers'], $serverInstance);
+    } else {
+        $serverInstance();
+    }
+
+
     $loop->run();
 });

router/middleware.php

@@ -11,8 +11,8 @@
 
 return static function (Application $app): void {
     $app->pipe(ErrorMiddleware::class);
-//    $app->pipe(ExceptionLoggerMiddleware::class);
-//    $app->pipe(RequestLoggerMiddleware::class);
+    $app->pipe(ExceptionLoggerMiddleware::class);
+    $app->pipe(RequestLoggerMiddleware::class);
     $app->pipe(RouteDispatcherMiddleware::class);
     $app->pipe(RouteNotFoundMiddleware::class);
 };