Added package to delegate the execution of event listeners to a swoole task worker

composer.json

@@ -30,6 +30,7 @@
         "mikehaertl/phpwkhtmltopdf": "^2.2",
         "monolog/monolog": "^1.21",
         "phly/phly-event-dispatcher": "^1.0",
+        "phly/phly-swoole-taskworker": "^1.1",
         "shlinkio/shlink-installer": "^1.1",
         "symfony/console": "^4.2",
         "symfony/filesystem": "^4.2",

config/autoload/swoole.global.php

@@ -9,6 +9,11 @@ return [
         'swoole-http-server' => [
             'host' => '0.0.0.0',
             'process-name' => 'shlink',
+
+            'options' => [
+                'worker_num' => 16,
+                'task_worker_num' => 16,
+            ],
         ],
     ],
 

config/config.php

@@ -5,6 +5,7 @@ namespace Shlinkio\Shlink;
 
 use Acelaya\ExpressiveErrorHandler;
 use Phly\EventDispatcher;
+use Phly\Swoole\TaskWorker;
 use Zend\ConfigAggregator;
 use Zend\Expressive;
 
@@ -18,6 +19,7 @@ return (new ConfigAggregator\ConfigAggregator([
     Expressive\Swoole\ConfigProvider::class,
     ExpressiveErrorHandler\ConfigProvider::class,
     EventDispatcher\ConfigProvider::class,
+    TaskWorker\ConfigProvider::class,
     Common\ConfigProvider::class,
     Core\ConfigProvider::class,
     CLI\ConfigProvider::class,

module/Core/config/event_dispatcher.config.php

@@ -3,6 +3,7 @@ declare(strict_types=1);
 
 namespace Shlinkio\Shlink\Core;
 
+use Phly\Swoole\TaskWorker\DeferredListenerDelegator;
 use Shlinkio\Shlink\Common\IpGeolocation\IpLocationResolverInterface;
 use Zend\ServiceManager\AbstractFactory\ConfigAbstractFactory;
 
@@ -18,6 +19,11 @@ return [
         'factories' => [
             EventDispatcher\LocateShortUrlVisit::class => ConfigAbstractFactory::class,
         ],
+        'delegators' => [
+            EventDispatcher\LocateShortUrlVisit::class => [
+                DeferredListenerDelegator::class,
+            ],
+        ],
     ],
 
     ConfigAbstractFactory::class => [

module/Core/src/EventDispatcher/ShortUrlVisited.php

@@ -3,7 +3,9 @@ declare(strict_types=1);
 
 namespace Shlinkio\Shlink\Core\EventDispatcher;
 
-final class ShortUrlVisited
+use JsonSerializable;
+
+final class ShortUrlVisited implements JsonSerializable
 {
     /** @var string */
     private $visitId;
@@ -17,4 +19,9 @@ final class ShortUrlVisited
     {
         return $this->visitId;
     }
+
+    public function jsonSerialize(): array
+    {
+        return ['visitId' => $this->visitId];
+    }
 }

module/Core/src/Visit/Model/UnknownVisitLocation.php

@@ -25,14 +25,7 @@ final class UnknownVisitLocation implements VisitLocationInterface
         return 'Unknown';
     }
 
-    /**
+    public function jsonSerialize(): array
-     * Specify data which should be serialized to JSON
-     * @link https://php.net/manual/en/jsonserializable.jsonserialize.php
-     * @return mixed data which can be serialized by <b>json_encode</b>,
-     * which is a value of any type other than a resource.
-     * @since 5.4.0
-     */
-    public function jsonSerialize()
     {
         return [
             'countryCode' => 'Unknown',