Added QueueHandleListener which can record running logs for async-queue. (#2671)

* Added QueueHandleListener for async-queue

* Update Client.php

* update

Author: limingxinleo

composer.json

@@ -32,6 +32,7 @@
     "suggest": {
         "hyperf/di": "Required to use annotations.",
         "hyperf/event": "Required to dispatch a event.",
+        "hyperf/logger": "Required to use QueueHandleListener.",
         "hyperf/process": "Auto register the consumer process for server."
     },
     "autoload": {

src/Listener/QueueHandleListener.php

@@ -0,0 +1,74 @@
+<?php
+
+declare(strict_types=1);
+/**
+ * This file is part of Hyperf.
+ *
+ * @link     https://www.hyperf.io
+ * @document https://hyperf.wiki
+ * @contact  group@hyperf.io
+ * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
+ */
+namespace Hyperf\AsyncQueue\Listener;
+
+use Hyperf\AsyncQueue\AnnotationJob;
+use Hyperf\AsyncQueue\Event\AfterHandle;
+use Hyperf\AsyncQueue\Event\BeforeHandle;
+use Hyperf\AsyncQueue\Event\Event;
+use Hyperf\AsyncQueue\Event\FailedHandle;
+use Hyperf\AsyncQueue\Event\RetryHandle;
+use Hyperf\Event\Contract\ListenerInterface;
+use Hyperf\Logger\LoggerFactory;
+use Psr\Container\ContainerInterface;
+use Psr\Log\LoggerInterface;
+
+class QueueHandleListener implements ListenerInterface
+{
+    /**
+     * @var LoggerInterface
+     */
+    protected $logger;
+
+    public function __construct(ContainerInterface $container)
+    {
+        $this->logger = $container->get(LoggerFactory::class)->get('queue');
+    }
+
+    public function listen(): array
+    {
+        return [
+            AfterHandle::class,
+            BeforeHandle::class,
+            FailedHandle::class,
+            RetryHandle::class,
+        ];
+    }
+
+    public function process(object $event)
+    {
+        if ($event instanceof Event && $event->message->job()) {
+            $job = $event->message->job();
+            $jobClass = get_class($job);
+            if ($job instanceof AnnotationJob) {
+                $jobClass = sprintf('Job[%s@%s]', $job->class, $job->method);
+            }
+            $date = date('Y-m-d H:i:s');
+
+            switch (true) {
+                case $event instanceof BeforeHandle:
+                    $this->logger->info(sprintf('[%s] Processing %s.', $date, $jobClass));
+                    break;
+                case $event instanceof AfterHandle:
+                    $this->logger->info(sprintf('[%s] Processed %s.', $date, $jobClass));
+                    break;
+                case $event instanceof FailedHandle:
+                    $this->logger->error(sprintf('[%s] Failed %s.', $date, $jobClass));
+                    $this->logger->error((string) $event->getThrowable());
+                    break;
+                case $event instanceof RetryHandle:
+                    $this->logger->warning(sprintf('[%s] Retried %s.', $date, $jobClass));
+                    break;
+            }
+        }
+    }
+}