Merge branch 'master' into 3.1-merge

# Conflicts: # docs/zh-cn/changelog.md # docs/zh-hk/changelog.md # docs/zh-tw/changelog.md # src/redis/composer.json
hyperf · Oct 13, 2023 · e8bc063 · e8bc063
2 parents 84a3202 + ae9abcc
commit e8bc063
Show file tree

Hide file tree

Showing 15 changed files with 169 additions and 14 deletions.
diff --git a/publish/opentracing.php b/publish/opentracing.php
@@ -16,8 +16,11 @@
 return [
     'default' => env('TRACER_DRIVER', 'zipkin'),
     'enable' => [
+        'coroutine' => env('TRACER_ENABLE_COROUTINE', false),
         'db' => env('TRACER_ENABLE_DB', false),
+        'elasticserach' => env('TRACER_ENABLE_ELASTICSERACH', false),
         'exception' => env('TRACER_ENABLE_EXCEPTION', false),
+        'grpc' => env('TRACER_ENABLE_GRPC', false),
         'guzzle' => env('TRACER_ENABLE_GUZZLE', false),
         'method' => env('TRACER_ENABLE_METHOD', false),
         'redis' => env('TRACER_ENABLE_REDIS', false),

diff --git a/src/Aspect/CoroutineAspect.php b/src/Aspect/CoroutineAspect.php
@@ -14,6 +14,7 @@
 use Hyperf\Di\Aop\AbstractAspect;
 use Hyperf\Di\Aop\ProceedingJoinPoint;
 use Hyperf\Engine\Coroutine as Co;
+use Hyperf\Tracer\SpanTagManager;
 use Hyperf\Tracer\SwitchManager;
 use Hyperf\Tracer\TracerContext;
 use OpenTracing\Span;
@@ -25,12 +26,16 @@ class CoroutineAspect extends AbstractAspect
         'Hyperf\Coroutine\Coroutine::create',
     ];
 
-    public function __construct(private SwitchManager $switchManager)
+    public function __construct(protected SwitchManager $switchManager, protected SpanTagManager $spanTagManager)
     {
     }
 
     public function process(ProceedingJoinPoint $proceedingJoinPoint)
     {
+        if (! $this->switchManager->isEnable('coroutine')) {
+            return $proceedingJoinPoint->process();
+        }
+
         $callable = $proceedingJoinPoint->arguments['keys']['callable'];
         $root = TracerContext::getRoot();
 
@@ -41,7 +46,9 @@ public function process(ProceedingJoinPoint $proceedingJoinPoint)
                     $child = $tracer->startSpan('coroutine', [
                         'child_of' => $root->getContext(),
                     ]);
-                    $child->setTag('coroutine.id', Co::id());
+                    if ($this->spanTagManager->has('coroutine', 'id')) {
+                        $child->setTag($this->spanTagManager->get('coroutine', 'id'), Co::id());
+                    }
                     TracerContext::setRoot($child);
                     Co::defer(function () use ($child, $tracer) {
                         $child->finish();
@@ -51,7 +58,7 @@ public function process(ProceedingJoinPoint $proceedingJoinPoint)
 
                 $callable();
             } catch (Throwable $e) {
-                if (isset($child) && $this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($e::class)) {
+                if (isset($child) && $this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($e)) {
                     $child->setTag('error', true);
                     $child->log(['message', $e->getMessage(), 'code' => $e->getCode(), 'stacktrace' => $e->getTraceAsString()]);
                 }

diff --git a/src/Aspect/DbAspect.php b/src/Aspect/DbAspect.php
@@ -46,7 +46,7 @@ public function process(ProceedingJoinPoint $proceedingJoinPoint)
         try {
             $result = $proceedingJoinPoint->process();
         } catch (Throwable $e) {
-            if ($this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($e::class)) {
+            if ($this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($e)) {
                 $span->setTag('error', true);
                 $span->log(['message', $e->getMessage(), 'code' => $e->getCode(), 'stacktrace' => $e->getTraceAsString()]);
             }

diff --git a/src/Aspect/ElasticserachAspect.php b/src/Aspect/ElasticserachAspect.php
@@ -48,12 +48,16 @@ public function __construct(private SwitchManager $switchManager, private SpanTa
      */
     public function process(ProceedingJoinPoint $proceedingJoinPoint)
     {
+        if ($this->switchManager->isEnable('elasticserach') === false) {
+            return $proceedingJoinPoint->process();
+        }
+
         $key = $proceedingJoinPoint->className . '::' . $proceedingJoinPoint->methodName;
         $span = $this->startSpan($key);
         try {
             $result = $proceedingJoinPoint->process();
         } catch (Throwable $e) {
-            if ($this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($e::class)) {
+            if ($this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($e)) {
                 $span->setTag('error', true);
                 $span->log(['message', $e->getMessage(), 'code' => $e->getCode(), 'stacktrace' => $e->getTraceAsString()]);
             }

diff --git a/src/Aspect/GrpcAspect.php b/src/Aspect/GrpcAspect.php
@@ -0,0 +1,130 @@
+<?php
+
+declare(strict_types=1);
+/**
+ * This file is part of Hyperf.
+ *
+ * @link     https://www.hyperf.io
+ * @document https://hyperf.wiki
+ * @contact  [email protected]
+ * @license  https://github.com/hyperf/hyperf/blob/master/LICENSE
+ */
+namespace Hyperf\Tracer\Aspect;
+
+use Hyperf\Context\Context as CT;
+use Hyperf\Di\Aop\AbstractAspect;
+use Hyperf\Di\Aop\ProceedingJoinPoint;
+use Hyperf\GrpcClient\GrpcClient;
+use Hyperf\GrpcClient\Request;
+use Hyperf\Rpc\Context;
+use Hyperf\Tracer\SpanStarter;
+use Hyperf\Tracer\SpanTagManager;
+use Hyperf\Tracer\SwitchManager;
+use Hyperf\Tracer\TracerContext;
+use OpenTracing\Span;
+use Psr\Container\ContainerInterface;
+use Swoole\Http2\Response;
+use Throwable;
+
+use const OpenTracing\Formats\TEXT_MAP;
+
+class GrpcAspect extends AbstractAspect
+{
+    use SpanStarter;
+
+    public array $classes = [
+        GrpcClient::class . '::send',
+        GrpcClient::class . '::recv',
+    ];
+
+    private SwitchManager $switchManager;
+
+    private SpanTagManager $spanTagManager;
+
+    private Context $context;
+
+    public function __construct(private ContainerInterface $container)
+    {
+        $this->switchManager = $container->get(SwitchManager::class);
+        $this->spanTagManager = $container->get(SpanTagManager::class);
+        $this->context = $container->get(Context::class);
+    }
+
+    public function process(ProceedingJoinPoint $proceedingJoinPoint)
+    {
+        if (! $this->switchManager->isEnable('grpc')) {
+            return $proceedingJoinPoint->process();
+        }
+
+        return match ($proceedingJoinPoint->methodName) {
+            'send' => $this->processSend($proceedingJoinPoint),
+            'recv' => $this->processRecv($proceedingJoinPoint),
+            default => $proceedingJoinPoint->process(),
+        };
+    }
+
+    private function processSend(ProceedingJoinPoint $proceedingJoinPoint)
+    {
+        $arguments = $proceedingJoinPoint->getArguments();
+        /** @var Request $request */
+        $request = $arguments[0];
+        $key = "GRPC send [{$request->path}]";
+        $span = $this->startSpan($key);
+        $carrier = [];
+        // Injects the context into the wire
+        TracerContext::getTracer()->inject(
+            $span->getContext(),
+            TEXT_MAP,
+            $carrier
+        );
+
+        // Merge tracer info
+        $request->headers = array_merge($request->headers, $carrier);
+        if ($this->spanTagManager->has('grpc', 'request.header')) {
+            foreach ($request->headers as $key => $value) {
+                $span->setTag($this->spanTagManager->get('grpc', 'request.header') . '.' . $key, $value);
+            }
+        }
+
+        $this->context->set('tracer.carrier', $carrier);
+        CT::set('tracer.span.' . static::class, $span);
+
+        try {
+            return $proceedingJoinPoint->process();
+        } catch (Throwable $e) {
+            if ($this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($e)) {
+                $span->setTag('error', true);
+                $span->log(['message', $e->getMessage(), 'code' => $e->getCode(), 'stacktrace' => $e->getTraceAsString()]);
+            }
+            throw $e;
+        }
+    }
+
+    private function processRecv(ProceedingJoinPoint $proceedingJoinPoint)
+    {
+        /** @var null|Span $span */
+        $span = CT::get('tracer.span.' . static::class);
+
+        try {
+            /** @var bool|Response $result */
+            $result = $proceedingJoinPoint->process();
+            if ($result instanceof Response) {
+                if ($this->spanTagManager->has('grpc', 'response.header')) {
+                    foreach ($result->headers as $key => $value) {
+                        $span?->setTag($this->spanTagManager->get('grpc', 'response.header') . '.' . $key, $value);
+                    }
+                }
+            }
+        } catch (Throwable $e) {
+            if ($this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($e::class)) {
+                $span?->setTag('error', true);
+                $span?->log(['message', $e->getMessage(), 'code' => $e->getCode(), 'stacktrace' => $e->getTraceAsString()]);
+            }
+            throw $e;
+        } finally {
+            $span?->finish();
+        }
+
+        return $result;
+    }
+}
diff --git a/src/Aspect/HttpClientAspect.php b/src/Aspect/HttpClientAspect.php
@@ -80,7 +80,7 @@ public function process(ProceedingJoinPoint $proceedingJoinPoint)
                 $span->setTag($this->spanTagManager->get('http_client', 'http.status_code'), $result->getStatusCode());
             }
         } catch (Throwable $e) {
-            if ($this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($e::class)) {
+            if ($this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($e)) {
                 $span->setTag('error', true);
                 $span->log(['message', $e->getMessage(), 'code' => $e->getCode(), 'stacktrace' => $e->getTraceAsString()]);
             }

diff --git a/src/Aspect/MethodAspect.php b/src/Aspect/MethodAspect.php
@@ -43,7 +43,7 @@ public function process(ProceedingJoinPoint $proceedingJoinPoint)
         try {
             $result = $proceedingJoinPoint->process();
         } catch (Throwable $e) {
-            if ($this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($e::class)) {
+            if ($this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($e)) {
                 $span->setTag('error', true);
                 $span->log(['message', $e->getMessage(), 'code' => $e->getCode(), 'stacktrace' => $e->getTraceAsString()]);
             }

diff --git a/src/Aspect/RedisAspect.php b/src/Aspect/RedisAspect.php
@@ -47,7 +47,7 @@ public function process(ProceedingJoinPoint $proceedingJoinPoint)
             $result = $proceedingJoinPoint->process();
             $span->setTag($this->spanTagManager->get('redis', 'result'), json_encode($result));
         } catch (Throwable $e) {
-            if ($this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($e::class)) {
+            if ($this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($e)) {
                 $span->setTag('error', true);
                 $span->log(['message', $e->getMessage(), 'code' => $e->getCode(), 'stacktrace' => $e->getTraceAsString()]);
             }

diff --git a/src/Aspect/RpcAspect.php b/src/Aspect/RpcAspect.php
@@ -78,7 +78,7 @@ public function process(ProceedingJoinPoint $proceedingJoinPoint)
             try {
                 $result = $proceedingJoinPoint->process();
             } catch (Throwable $e) {
-                if (($span = CT::get('tracer.span.' . static::class)) && $this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($e::class)) {
+                if (($span = CT::get('tracer.span.' . static::class)) && $this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($e)) {
                     $span->setTag('error', true);
                     $span->log(['message', $e->getMessage(), 'code' => $e->getCode(), 'stacktrace' => $e->getTraceAsString()]);
                     CT::set('tracer.span.' . static::class, $span);

diff --git a/src/Aspect/TraceAnnotationAspect.php b/src/Aspect/TraceAnnotationAspect.php
@@ -50,7 +50,7 @@ public function process(ProceedingJoinPoint $proceedingJoinPoint)
         try {
             $result = $proceedingJoinPoint->process();
         } catch (Throwable $e) {
-            if ($this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($e::class)) {
+            if ($this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($e)) {
                 $span->setTag('error', true);
                 $span->log(['message', $e->getMessage(), 'code' => $e->getCode(), 'stacktrace' => $e->getTraceAsString()]);
             }

diff --git a/src/ConfigProvider.php b/src/ConfigProvider.php
@@ -12,7 +12,10 @@
 namespace Hyperf\Tracer;
 
 use GuzzleHttp\Client;
+use Hyperf\Tracer\Aspect\CoroutineAspect;
 use Hyperf\Tracer\Aspect\CreateTraceContextAspect;
+use Hyperf\Tracer\Aspect\ElasticserachAspect;
+use Hyperf\Tracer\Aspect\GrpcAspect;
 use Hyperf\Tracer\Aspect\HttpClientAspect;
 use Hyperf\Tracer\Aspect\RedisAspect;
 use Hyperf\Tracer\Aspect\RpcAspect;
@@ -47,7 +50,10 @@ public function __invoke(): array
                 ],
             ],
             'aspects' => [
+                CoroutineAspect::class,
                 CreateTraceContextAspect::class,
+                ElasticserachAspect::class,
+                GrpcAspect::class,
                 HttpClientAspect::class,
                 RedisAspect::class,
                 RpcAspect::class,

diff --git a/src/Listener/RequestTraceListener.php b/src/Listener/RequestTraceListener.php
@@ -77,7 +77,7 @@ protected function handleRequestTerminated(RequestTerminated $event): void
         $span = TracerContext::getRoot();
         $span->setTag($this->spanTagManager->get('response', 'status_code'), $response->getStatusCode());
 
-        if ($event->exception && $this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($event->exception::class)) {
+        if ($event->exception && $this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($event->exception)) {
             $this->appendExceptionToSpan($span, $exception = $event->exception);
 
             if ($exception instanceof HttpException) {

diff --git a/src/Middleware/TraceMiddleware.php b/src/Middleware/TraceMiddleware.php
@@ -58,7 +58,7 @@ public function process(ServerRequestInterface $request, RequestHandlerInterface
             }
             $span->setTag($this->spanTagManager->get('response', 'status_code'), $response->getStatusCode());
         } catch (Throwable $exception) {
-            if ($this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($exception::class)) {
+            if ($this->switchManager->isEnable('exception') && ! $this->switchManager->isIgnoreException($exception)) {
                 $this->appendExceptionToSpan($span, $exception);
             }
             if ($exception instanceof HttpException) {

diff --git a/src/SpanTagManager.php b/src/SpanTagManager.php
@@ -19,6 +19,10 @@ class SpanTagManager
             'http.method' => 'http.method',
             'http.status_code' => 'http.status_code',
         ],
+        'grpc' => [
+            'request.header' => 'grpc.request.header',
+            'response.header' => 'grpc.response.header',
+        ],
         'redis' => [
             'arguments' => 'redis.arguments',
             'result' => 'redis.result',

diff --git a/src/SwitchManager.php b/src/SwitchManager.php
@@ -13,6 +13,7 @@
 
 use Hyperf\Context\Context;
 use OpenTracing\Span;
+use Throwable;
 
 class SwitchManager
 {
@@ -50,11 +51,11 @@ public function isEnable(string $identifier): bool
         return $this->config[$identifier] && Context::get('tracer.root') instanceof Span;
     }
 
-    public function isIgnoreException(string $className): bool
+    public function isIgnoreException(Throwable|string $exception): bool
     {
         $ignoreExceptions = $this->config['ignore_exceptions'] ?? [];
         foreach ($ignoreExceptions as $ignoreException) {
-            if (is_a($className, $ignoreException, true)) {
+            if (is_a($exception, $ignoreException, true)) {
                 return true;
             }
         }