Commit 94b31584 authored by Liu lu's avatar Liu lu

异步协程日志加入异常

parent a119a36d
...@@ -31,6 +31,7 @@ class AsyncCoroutineAspect extends AbstractAspect ...@@ -31,6 +31,7 @@ class AsyncCoroutineAspect extends AbstractAspect
// 在调用前进行某些处理 // 在调用前进行某些处理
return Coroutine::create(function ()use($proceedingJoinPoint){ return Coroutine::create(function ()use($proceedingJoinPoint){
try {
LogTraceHandler::recordProcess( LogTraceHandler::recordProcess(
'投递到子协程任务,id:'.Coroutine::id() '投递到子协程任务,id:'.Coroutine::id()
.' ,类:'.$proceedingJoinPoint->className .' ,类:'.$proceedingJoinPoint->className
...@@ -44,6 +45,9 @@ class AsyncCoroutineAspect extends AbstractAspect ...@@ -44,6 +45,9 @@ class AsyncCoroutineAspect extends AbstractAspect
'子协程任务id:'.Coroutine::id().'已完成,执行结果:'. '子协程任务id:'.Coroutine::id().'已完成,执行结果:'.
json_encode($result),true json_encode($result),true
); );
}catch (\Throwable $exception){
LogTraceHandler::recordProcess($exception,true);
}
}); });
......
...@@ -26,6 +26,7 @@ class LogTraceAspect extends AbstractAspect ...@@ -26,6 +26,7 @@ class LogTraceAspect extends AbstractAspect
public function process(ProceedingJoinPoint $proceedingJoinPoint) public function process(ProceedingJoinPoint $proceedingJoinPoint)
{ {
try {
$originParams = [ $originParams = [
'called_params'=>$proceedingJoinPoint->getArguments(), 'called_params'=>$proceedingJoinPoint->getArguments(),
'http_params'=>make(RequestInterface::class)->all() 'http_params'=>make(RequestInterface::class)->all()
...@@ -38,5 +39,10 @@ class LogTraceAspect extends AbstractAspect ...@@ -38,5 +39,10 @@ class LogTraceAspect extends AbstractAspect
LogTraceHandler::recordProcess('返回结果:'.json_encode($result)); LogTraceHandler::recordProcess('返回结果:'.json_encode($result));
return $result; return $result;
}catch (\Throwable $exception){
LogTraceHandler::recordProcess($exception);
throw $exception;
}
} }
} }
\ No newline at end of file
...@@ -76,7 +76,6 @@ class LogTraceHandler ...@@ -76,7 +76,6 @@ class LogTraceHandler
/** /**
* 程序执行完成标记结束 * 程序执行完成标记结束
* @throws \Exception
*/ */
public static function markComplete() public static function markComplete()
{ {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment