From e311206b84b9520112c1fd2d14af097cdf0dc014 Mon Sep 17 00:00:00 2001
From: weiwei_unique <248430449@qq.com>
Date: Tue, 1 Aug 2023 20:52:36 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=EF=BC=9A=E7=BA=BF=E7=A8=8B?=
 =?UTF-8?q?=E5=85=A8=E5=B1=80=E5=BC=82=E5=B8=B8=E5=A4=84=E7=90=86=E5=99=A8?=
 =?UTF-8?q?=E6=94=B9=E4=B8=BA=E5=8D=95=E4=BE=8B=E6=A8=A1=E5=BC=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mallchat/common/common/factory/MyThreadFactory.java   | 2 +-
 .../common/handler/GlobalUncaughtExceptionHandler.java    | 8 ++++++++
 .../mallchat/common/user/service/impl/IpServiceImpl.java  | 2 +-
 .../chat/service/impl/WeChatMsgOperationServiceImpl.java  | 2 +-
 4 files changed, 11 insertions(+), 3 deletions(-)

diff --git a/mallchat-common/src/main/java/com/abin/mallchat/common/common/factory/MyThreadFactory.java b/mallchat-common/src/main/java/com/abin/mallchat/common/common/factory/MyThreadFactory.java
index db07ee6..29a44eb 100644
--- a/mallchat-common/src/main/java/com/abin/mallchat/common/common/factory/MyThreadFactory.java
+++ b/mallchat-common/src/main/java/com/abin/mallchat/common/common/factory/MyThreadFactory.java
@@ -15,7 +15,7 @@ public class MyThreadFactory  implements ThreadFactory {
     @Override
     public Thread newThread(Runnable r) {
         Thread thread =factory.newThread(r);
-        thread.setUncaughtExceptionHandler(new GlobalUncaughtExceptionHandler());
+        thread.setUncaughtExceptionHandler(GlobalUncaughtExceptionHandler.getInstance());
         return thread;
     }
 }
diff --git a/mallchat-common/src/main/java/com/abin/mallchat/common/common/handler/GlobalUncaughtExceptionHandler.java b/mallchat-common/src/main/java/com/abin/mallchat/common/common/handler/GlobalUncaughtExceptionHandler.java
index 4dc9775..6a65030 100644
--- a/mallchat-common/src/main/java/com/abin/mallchat/common/common/handler/GlobalUncaughtExceptionHandler.java
+++ b/mallchat-common/src/main/java/com/abin/mallchat/common/common/handler/GlobalUncaughtExceptionHandler.java
@@ -5,10 +5,18 @@ import lombok.extern.slf4j.Slf4j;
 @Slf4j
 public class GlobalUncaughtExceptionHandler  implements Thread.UncaughtExceptionHandler {
 
+    private static final  GlobalUncaughtExceptionHandler instance = new GlobalUncaughtExceptionHandler();
+
+    private GlobalUncaughtExceptionHandler() {
+    }
 
     @Override
     public void uncaughtException(Thread t, Throwable e) {
         log.error("Exception in thread {} ", t.getName(), e);
     }
 
+    public static GlobalUncaughtExceptionHandler getInstance() {
+        return instance;
+    }
+
 }
diff --git a/mallchat-common/src/main/java/com/abin/mallchat/common/user/service/impl/IpServiceImpl.java b/mallchat-common/src/main/java/com/abin/mallchat/common/user/service/impl/IpServiceImpl.java
index 208c16c..c142975 100644
--- a/mallchat-common/src/main/java/com/abin/mallchat/common/user/service/impl/IpServiceImpl.java
+++ b/mallchat-common/src/main/java/com/abin/mallchat/common/user/service/impl/IpServiceImpl.java
@@ -37,7 +37,7 @@ public class IpServiceImpl implements IpService, DisposableBean {
             0L, TimeUnit.MILLISECONDS,
             new LinkedBlockingQueue<>(500),
             new NamedThreadFactory("refresh-ipDetail", null, false,
-                    new GlobalUncaughtExceptionHandler()));
+                    GlobalUncaughtExceptionHandler.getInstance()));
 
     @Autowired
     private UserDao userDao;
diff --git a/mallchat-custom-server/src/main/java/com/abin/mallchat/custom/chat/service/impl/WeChatMsgOperationServiceImpl.java b/mallchat-custom-server/src/main/java/com/abin/mallchat/custom/chat/service/impl/WeChatMsgOperationServiceImpl.java
index 429068c..0866b41 100644
--- a/mallchat-custom-server/src/main/java/com/abin/mallchat/custom/chat/service/impl/WeChatMsgOperationServiceImpl.java
+++ b/mallchat-custom-server/src/main/java/com/abin/mallchat/custom/chat/service/impl/WeChatMsgOperationServiceImpl.java
@@ -31,7 +31,7 @@ public class WeChatMsgOperationServiceImpl implements WeChatMsgOperationService
             TimeUnit.MILLISECONDS,
             new LinkedBlockingQueue<Runnable>(20),
             new NamedThreadFactory("wechat-operation-thread", null, false,
-                    new GlobalUncaughtExceptionHandler()));
+                    GlobalUncaughtExceptionHandler.getInstance()));
 
     // at消息的微信推送模板id
     private final String atMsgPublishTemplateId = "Xd7sWPZsuWa0UmpvLaZPvaJVjNj1KjEa0zLOm5_Z7IU";