feat: upgrade 2.0

Author: liutao

composer.json

@@ -12,7 +12,7 @@
         }
     ],
     "require": {
-        "workerman/workerman": ">=4",
+        "workerman/workerman": ">=5.1",
         "workerman/psr7": "*"
     }
 }

src/ConfigProvider.php

@@ -0,0 +1,21 @@
+<?php
+declare(strict_types=1);
+
+namespace MicroPHP\Workerman;
+
+use MicroPHP\Framework\Config\ConfigProviderInterface;
+
+class ConfigProvider implements ConfigProviderInterface
+{
+    public function config(): array
+    {
+        return [
+            'publish' => [
+                'workerman' => [
+                    'from' => __DIR__ . '/config.php',
+                    'to' => base_path('config/workerman.php'),
+                ],
+            ],
+        ];
+    }
+}

src/WorkermanHttpServer.php

@@ -11,7 +11,9 @@
 use MicroPHP\Framework\Http\ServerConfig;
 use MicroPHP\Framework\Http\Traits\HttpServerTrait;
 use MicroPHP\Framework\Router\Router;
+use Symfony\Component\Console\Output\OutputInterface;
 use Workerman\Connection\TcpConnection;
+use Workerman\Events\Fiber;
 use Workerman\Protocols\Http\Request;
 use Workerman\Psr7\Response;
 use Workerman\Psr7\ServerRequest;
@@ -21,7 +23,7 @@ class WorkermanHttpServer implements HttpServerInterface
 {
     use HttpServerTrait;
 
-    public function run(Router $router): void
+    public function run(Router $router, OutputInterface $output): void
     {
         $this->setRuntime();
         $strategy = new ApplicationStrategy();
@@ -30,16 +32,9 @@ public function run(Router $router): void
         $serverConfig = new ServerConfig();
 
         $httpWorker = new Worker($serverConfig->getUri(true));
-
+        $config = Config::get('workerman', []);
         $httpWorker->count = $serverConfig->getWorkers();
-
-        $httpWorker->onMessage = function (TcpConnection $connection, Request $request) use ($router) {
-            $psr7Request = new ServerRequest($request->rawBuffer());
-
-            $response = $this->routeDispatch($router, \MicroPHP\Framework\Http\ServerRequest::fromPsr7($psr7Request));
-            $connection->send(new Response($response->getStatusCode(), $response->getHeaders(), $response->getBody(), $response->getProtocolVersion(), $response->getReasonPhrase()));
-        };
-
+        $config['callback']($httpWorker, $router, $output);
         Worker::runAll();
     }
 

src/config.php

@@ -0,0 +1,22 @@
+<?php
+declare(strict_types=1);
+
+use MicroPHP\Framework\Router\Router;
+use Symfony\Component\Console\Output\OutputInterface;
+use Workerman\Connection\TcpConnection;
+use Workerman\Protocols\Http\Request;
+use Workerman\Psr7\Response;
+use Workerman\Psr7\ServerRequest;
+use Workerman\Worker;
+
+return [
+    'callback' => function(Worker $httpWorker,  Router $router, OutputInterface $output) {
+        $httpWorker->eventLoop = \Workerman\Events\Fiber::class;
+        $httpWorker->onMessage = function (TcpConnection $connection, Request $request) use ($router, $output) {
+            $psr7Request = new ServerRequest($request->rawBuffer());
+
+            $response = $this->routeDispatch($router, \MicroPHP\Framework\Http\ServerRequest::fromPsr7($psr7Request));
+            $connection->send(new Response($response->getStatusCode(), $response->getHeaders(), $response->getBody(), $response->getProtocolVersion(), $response->getReasonPhrase()));
+        };
+    }
+];