open-source/MallChat
1
0
Fork 0
mirror of https://github.com/zongzibinbin/MallChat.git synced 2026-03-16 07:43:42 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #118 from vv-248430449/main

Browse Source 
优化：线程全局异常处理器改为单例模式
This commit is contained in:
zongzibinbin
2023-08-19 15:38:39 +08:00
committed by GitHub
parent 7c21b4127e e311206b84
commit 56abebc96d
4 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
mallchat-common/src/main/java/com/abin/mallchat/common/common/factory/MyThreadFactory.java
View File

@@ -15,7 +15,7 @@ public class MyThreadFactory implements ThreadFactory {
@Override @Override
public Thread newThread(Runnable r) { public Thread newThread(Runnable r) {
Thread thread =factory.newThread(r); Thread thread =factory.newThread(r);
thread.setUncaughtExceptionHandler(new GlobalUncaughtExceptionHandler()); thread.setUncaughtExceptionHandler(GlobalUncaughtExceptionHandler.getInstance());
return thread; return thread;
} }
} }

8
mallchat-common/src/main/java/com/abin/mallchat/common/common/handler/GlobalUncaughtExceptionHandler.java
View File

@@ -5,10 +5,18 @@ import lombok.extern.slf4j.Slf4j;
@Slf4j @Slf4j
public class GlobalUncaughtExceptionHandler implements Thread.UncaughtExceptionHandler { public class GlobalUncaughtExceptionHandler implements Thread.UncaughtExceptionHandler {
private static final GlobalUncaughtExceptionHandler instance = new GlobalUncaughtExceptionHandler();
private GlobalUncaughtExceptionHandler() {
}
@Override @Override
public void uncaughtException(Thread t, Throwable e) { public void uncaughtException(Thread t, Throwable e) {
log.error("Exception in thread {} ", t.getName(), e); log.error("Exception in thread {} ", t.getName(), e);
} }
public static GlobalUncaughtExceptionHandler getInstance() {
return instance;
}
} }

2
mallchat-common/src/main/java/com/abin/mallchat/common/user/service/impl/IpServiceImpl.java
View File

@@ -37,7 +37,7 @@ public class IpServiceImpl implements IpService, DisposableBean {
0L, TimeUnit.MILLISECONDS, 0L, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<>(500), new LinkedBlockingQueue<>(500),
new NamedThreadFactory("refresh-ipDetail", null, false, new NamedThreadFactory("refresh-ipDetail", null, false,
new GlobalUncaughtExceptionHandler())); GlobalUncaughtExceptionHandler.getInstance()));
@Autowired @Autowired
private UserDao userDao; private UserDao userDao;

2
mallchat-custom-server/src/main/java/com/abin/mallchat/custom/chat/service/impl/WeChatMsgOperationServiceImpl.java
View File

@@ -31,7 +31,7 @@ public class WeChatMsgOperationServiceImpl implements WeChatMsgOperationService
TimeUnit.MILLISECONDS, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>(20), new LinkedBlockingQueue<Runnable>(20),
new NamedThreadFactory("wechat-operation-thread", null, false, new NamedThreadFactory("wechat-operation-thread", null, false,
new GlobalUncaughtExceptionHandler())); GlobalUncaughtExceptionHandler.getInstance()));
// at消息的微信推送模板id // at消息的微信推送模板id
private final String atMsgPublishTemplateId = "Xd7sWPZsuWa0UmpvLaZPvaJVjNj1KjEa0zLOm5_Z7IU"; private final String atMsgPublishTemplateId = "Xd7sWPZsuWa0UmpvLaZPvaJVjNj1KjEa0zLOm5_Z7IU";