From 717ab758372ad2b0dbcb5df501cb8b4ad19def6c Mon Sep 17 00:00:00 2001
From: hongawen <83944980@qq.com>
Date: Fri, 18 Aug 2023 11:26:14 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=BC=82=E5=B8=B8=E6=97=A5?=
 =?UTF-8?q?=E5=BF=97=E8=AE=B0=E5=BD=95=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../rocket/constant/EnhanceMessageConstant.java   |  6 ++++++
 .../handler/EnhanceConsumerMessageHandler.java    | 15 ++++++++++++---
 2 files changed, 18 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/njcn/middle/rocket/constant/EnhanceMessageConstant.java b/src/main/java/com/njcn/middle/rocket/constant/EnhanceMessageConstant.java
index e9fb00a..3e5faca 100644
--- a/src/main/java/com/njcn/middle/rocket/constant/EnhanceMessageConstant.java
+++ b/src/main/java/com/njcn/middle/rocket/constant/EnhanceMessageConstant.java
@@ -32,5 +32,11 @@ public class EnhanceMessageConstant {
 
     public final String RETRY_PREFIX = "RETRY_";
 
+    //单次异常失败
+    public final String IDENTITY_SINGLE = "IDENTITY_SINGLE";
+
+    //多次重试后，异常记录
+    public final String IDENTITY_RETRY = "IDENTITY_RETRY";
+
 
 }
diff --git a/src/main/java/com/njcn/middle/rocket/handler/EnhanceConsumerMessageHandler.java b/src/main/java/com/njcn/middle/rocket/handler/EnhanceConsumerMessageHandler.java
index 69bb006..b3bbc38 100644
--- a/src/main/java/com/njcn/middle/rocket/handler/EnhanceConsumerMessageHandler.java
+++ b/src/main/java/com/njcn/middle/rocket/handler/EnhanceConsumerMessageHandler.java
@@ -52,8 +52,9 @@ public abstract class EnhanceConsumerMessageHandler<T extends BaseMessage> {
      *
      * @param message 待处理消息
      */
-    protected abstract void handleMaxRetriesExceeded(T message);
-
+    protected void handleMaxRetriesExceeded(T message) {
+        saveExceptionMsgLog(message,EnhanceMessageConstant.IDENTITY_RETRY);
+    }
 
     /**
      * 是否需要根据业务规则过滤消息，去重逻辑可以在此处处理
@@ -97,6 +98,14 @@ public abstract class EnhanceConsumerMessageHandler<T extends BaseMessage> {
         return DELAY_LEVEL;
     }
 
+
+    /**
+     * 发生异常时，进行错误信息入库保存
+     * 默认没有实现类，子类可以实现该方法，调用feign接口进行入库保存
+     */
+    protected void saveExceptionMsgLog(T message, String identity) {
+    }
+
     /**
      * 使用模板模式构建消息消费框架，可自由扩展或删减
      */
@@ -118,7 +127,7 @@ public abstract class EnhanceConsumerMessageHandler<T extends BaseMessage> {
             long costTime = System.currentTimeMillis() - now;
             log.info("消息{}消费成功，耗时[{}ms]", message.getKey(), costTime);
         } catch (Exception e) {
-            log.error("消息{}消费异常", message.getKey(), e);
+            saveExceptionMsgLog(message,EnhanceMessageConstant.IDENTITY_SINGLE);
             // 是捕获异常还是抛出，由子类决定
             if (throwException()) {
                 //抛出异常，由DefaultMessageListenerConcurrently类处理