异步协程日志加入异常

src/Aspect/AsyncCoroutineAspect.php

@@ -30,21 +30,23 @@ class AsyncCoroutineAspect extends AbstractAspect
         // $proceedingJoinPoint 为连接点，通过该类的 process() 方法调用原方法并获得结果
         // 在调用前进行某些处理
         return Coroutine::create(function ()use($proceedingJoinPoint){
-
-            LogTraceHandler::recordProcess(
-                '投递到子协程任务,id:'.Coroutine::id()
-                .' ,类:'.$proceedingJoinPoint->className
-                .' ,方法:'.$proceedingJoinPoint->methodName
-                .' ,参数:'.json_encode($proceedingJoinPoint->getArguments())
-                ,
-                true
-            );
-            $result = $proceedingJoinPoint->process();
-            LogTraceHandler::recordProcess(
-                '子协程任务id:'.Coroutine::id().'已完成,执行结果:'.
-                json_encode($result),true
-            );
-
+            try {
+                LogTraceHandler::recordProcess(
+                    '投递到子协程任务,id:'.Coroutine::id()
+                    .' ,类:'.$proceedingJoinPoint->className
+                    .' ,方法:'.$proceedingJoinPoint->methodName
+                    .' ,参数:'.json_encode($proceedingJoinPoint->getArguments())
+                    ,
+                    true
+                );
+                $result = $proceedingJoinPoint->process();
+                LogTraceHandler::recordProcess(
+                    '子协程任务id:'.Coroutine::id().'已完成,执行结果:'.
+                    json_encode($result),true
+                );
+            }catch (\Throwable $exception){
+                LogTraceHandler::recordProcess($exception,true);
+            }
         });
 
 

src/Aspect/LogTraceAspect.php

@@ -26,18 +26,23 @@ class LogTraceAspect extends AbstractAspect
 
     public function process(ProceedingJoinPoint $proceedingJoinPoint)
     {
+        try {
+            $originParams = [
+                'called_params'=>$proceedingJoinPoint->getArguments(),
+                'http_params'=>make(RequestInterface::class)->all()
+            ];
+            LogTraceHandler::createLogTrace(
+                $proceedingJoinPoint->className.'@'.$proceedingJoinPoint->methodName,
+                $originParams
+            );
+            $result =  $proceedingJoinPoint->process();
+            LogTraceHandler::recordProcess('返回结果：'.json_encode($result));
 
-        $originParams = [
-            'called_params'=>$proceedingJoinPoint->getArguments(),
-            'http_params'=>make(RequestInterface::class)->all()
-        ];
-        LogTraceHandler::createLogTrace(
-            $proceedingJoinPoint->className.'@'.$proceedingJoinPoint->methodName,
-            $originParams
-        );
-        $result =  $proceedingJoinPoint->process();
-        LogTraceHandler::recordProcess('返回结果：'.json_encode($result));
+            return $result;
+        }catch (\Throwable $exception){
+            LogTraceHandler::recordProcess($exception);
+            throw $exception ; //保持异常抛出
+        }
 
-        return $result;
     }
 }
\ No newline at end of file

src/Handler/LogTrace/LogTraceHandler.php

@@ -76,7 +76,6 @@ class LogTraceHandler
 
     /**
      * 程序执行完成标记结束
-     * @throws \Exception
      */
     public static function markComplete()
     {