From abf2dc974d3ccedfcfcf98f6913ea83cd76d0842 Mon Sep 17 00:00:00 2001 From: Bryant Date: Wed, 16 Mar 2022 10:17:39 +0800 Subject: [PATCH] =?UTF-8?q?REPORT-67131=20=E4=B9=8B=E5=89=8D=E6=9A=82?= =?UTF-8?q?=E5=AD=98=E5=9F=8B=E7=82=B9=E7=9A=84=E9=80=BB=E8=BE=91=E6=B2=A1?= =?UTF-8?q?=E4=BA=BA=E7=94=A8=E4=BA=86=EF=BC=8C=E5=8E=BB=E6=8E=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../record/analyzer/advice/MonitorAdvice.java | 15 ++++----------- 1 file changed, 4 insertions(+), 11 deletions(-) diff --git a/designer-base/src/main/java/com/fr/design/record/analyzer/advice/MonitorAdvice.java b/designer-base/src/main/java/com/fr/design/record/analyzer/advice/MonitorAdvice.java index 607c80619..a459d0841 100644 --- a/designer-base/src/main/java/com/fr/design/record/analyzer/advice/MonitorAdvice.java +++ b/designer-base/src/main/java/com/fr/design/record/analyzer/advice/MonitorAdvice.java @@ -9,6 +9,7 @@ import com.fr.intelli.record.Measurable; import com.fr.intelli.record.MeasureObject; import com.fr.intelli.record.MeasureUnit; import com.fr.intelli.record.MetricRegistry; +import com.fr.log.FineLoggerFactory; import com.fr.measure.DBMeterFactory; import com.fr.stable.ArrayUtils; import com.fr.stable.StringUtils; @@ -79,25 +80,17 @@ public class MonitorAdvice implements DesignerAnalyzerAdvice { List newArgs = new ArrayList<>(Arrays.asList(args)); newArgs.add(id); recordSQLDetail(id); - String sessionID = null; - SessionProvider provider = SessionLocalManager.getSession(); - if (provider != null) { - sessionID = provider.getSessionID(); - } if (measurable instanceof Estimator) { measurable.asyncDurable(measureObject, newArgs.toArray()); } else { - Object message; + Object message = null; try { message = measurable.durableEntity(measureObject, newArgs.toArray()); } catch (Throwable throwable) { - //埋点生成失败，降级逻辑 - message = measurable.fallBackEntity(); + FineLoggerFactory.getLogger().error(throwable.getMessage(), throwable); } - if (StringUtils.isEmpty(sessionID)) { + if (message != null) { MetricRegistry.getMetric().submit(message); - } else { - MetricRegistry.getMetric().submitAccumulativeData(sessionID, message); } } }