捕获异常，日志打印线程

book-push/src/main/java/com/book/push/service/push/impl/IntellectPushServiceImpl.java

@@ -141,6 +141,7 @@ public class IntellectPushServiceImpl implements IntellectPushService {
 
     @Override
     public void pushBySubscribe(Integer platformId, String appid, Long userId) {
+        try {
         Integer second = afterNow();
         if (second > 0) {
             redisService.set(redisService.getKeyListener().getKeyMpSubscribe(platformId, appid, userId), userId + "", second);
@@ -151,17 +152,18 @@ public class IntellectPushServiceImpl implements IntellectPushService {
 
         WxOpenService wxOpenService = wxThirdPartService.getWxOpenServiceByPlatFormId(platformId);
         WxOpenMpService wxMpService = wxOpenService.getWxOpenComponentService().getWxMpServiceByAppid(appid);
-        try {
+
             wxMpService.getKefuService().sendKefuMessage(signMessage);
         } catch (WxErrorException e) {
             e.printStackTrace();
-            log.error("签到智能推送失败");
+            log.error("签到智能推送失败",e);
         }
 
     }
 
     @Override
     public void pushBySign(Integer platformId, String appid, Long userId) {
+        try {
         Integer second = afterNow();
         if (second > 0) {
             redisService.set(redisService.getKeyListener().getKeyMpSign(platformId, appid, userId), userId + "", second);
@@ -172,11 +174,11 @@ public class IntellectPushServiceImpl implements IntellectPushService {
 
         WxOpenService wxOpenService = wxThirdPartService.getWxOpenServiceByPlatFormId(platformId);
         WxOpenMpService wxMpService = wxOpenService.getWxOpenComponentService().getWxMpServiceByAppid(appid);
-        try {
+
             wxMpService.getKefuService().sendKefuMessage(signMessage);
         } catch (WxErrorException e) {
             e.printStackTrace();
-            log.error("签到智能推送失败");
+            log.error("签到智能推送失败",e);
         }
 
 
@@ -185,6 +187,7 @@ public class IntellectPushServiceImpl implements IntellectPushService {
 
     @Override
     public void pushByContinueRead(Integer platformId, String appid, Integer id) {
+        try {
         Integer second = afterNow();
         if (second > 0) {
             redisService.set(redisService.getKeyListener().getKeyPrefixBookContinueRead(platformId, appid, id), id + "", second);
@@ -195,31 +198,33 @@ public class IntellectPushServiceImpl implements IntellectPushService {
 
         WxOpenService wxOpenService = wxThirdPartService.getWxOpenServiceByPlatFormId(platformId);
         WxOpenMpService wxMpService = wxOpenService.getWxOpenComponentService().getWxMpServiceByAppid(appid);
-        try {
+
             wxMpService.getKefuService().sendKefuMessage(signMessage);
         } catch (WxErrorException e) {
             e.printStackTrace();
-            log.error("继续阅读智能推送失败");
+            log.error("继续阅读智能推送失败",e);
         }
 
     }
 
     @Override
     public void pushByNopay(Integer platformId, String appid, Integer id) {
+        try {
         WxMpKefuMessage signMessage = createNopayMessage(platformId, appid, id);
 
         WxOpenService wxOpenService = wxThirdPartService.getWxOpenServiceByPlatFormId(platformId);
         WxOpenMpService wxMpService = wxOpenService.getWxOpenComponentService().getWxMpServiceByAppid(appid);
-        try {
+
             wxMpService.getKefuService().sendKefuMessage(signMessage);
         } catch (WxErrorException e) {
             e.printStackTrace();
-            log.error("未支付提醒智能推送失败");
+            log.error("未支付提醒智能推送失败",e);
         }
     }
 
     @Override
     public void pushByNoSign(Integer platformId, String appid, Long userId) {
+        try {
         Integer second = afterNow();
         if (second > 0) {
             redisService.set(redisService.getKeyListener().getKeyMpNosign(platformId, appid, userId), userId + "", second);
@@ -229,11 +234,11 @@ public class IntellectPushServiceImpl implements IntellectPushService {
 
         WxOpenService wxOpenService = wxThirdPartService.getWxOpenServiceByPlatFormId(platformId);
         WxOpenMpService wxMpService = wxOpenService.getWxOpenComponentService().getWxMpServiceByAppid(appid);
-        try {
+
             wxMpService.getKefuService().sendKefuMessage(signMessage);
         } catch (WxErrorException e) {
             e.printStackTrace();
-            log.error("未签到提醒智能推送失败");
+            log.error("未签到提醒智能推送失败",e);
         }
     }
 

book-push/src/main/resources/log4j2.xml

@@ -11,7 +11,7 @@
         <!--这个输出控制台的配置-->
         <console name="Console" target="SYSTEM_OUT">
             <!--输出日志的格式-->
-            <PatternLayout pattern="[%d{HH:mm:ss:SSS}] [%p] - %l - %m%n"/>
+            <PatternLayout pattern="[%d{HH:mm:ss:SSS}] [%p] [%t] - %l - %m%n"/>
         </console>
         <!--文件会打印出所有信息，这个log每次运行程序会自动清空，由append属性决定，这个也挺有用的，适合临时测试用-->
         <File name="log" fileName="${logDir}/test.log" append="false">
@@ -23,7 +23,7 @@
                                  immediateFlush="false">
             <!--控制台只输出level及以上级别的信息（onMatch），其他的直接拒绝（onMismatch）-->
             <ThresholdFilter level="info" onMatch="ACCEPT" onMismatch="DENY"/>
-            <PatternLayout pattern="[%d{HH:mm:ss:SSS}] [%p] - %l - %m%n"/>
+            <PatternLayout pattern="[%d{HH:mm:ss:SSS}] [%-5p] [%t] - %l - %m%n"/>
             <Policies>
                 <TimeBasedTriggeringPolicy/>
                 <SizeBasedTriggeringPolicy size="500 MB"/>
@@ -33,7 +33,7 @@
                                  filePattern="${logDir}/$${date:yyyy-MM}/warn-%d{yyyy-MM-dd}-%i.log"
                                  immediateFlush="false">
             <ThresholdFilter level="warn" onMatch="ACCEPT" onMismatch="DENY"/>
-            <PatternLayout pattern="[%d{HH:mm:ss:SSS}] [%p] - %l - %m%n"/>
+            <PatternLayout pattern="[%d{HH:mm:ss:SSS}] [%-5p] [%t] - %l - %m%n"/>
             <Policies>
                 <TimeBasedTriggeringPolicy/>
                 <SizeBasedTriggeringPolicy size="500 MB"/>
@@ -45,7 +45,7 @@
                                  filePattern="${logDir}/$${date:yyyy-MM}/error-%d{yyyy-MM-dd}-%i.log"
                                  immediateFlush="false">
             <ThresholdFilter level="error" onMatch="ACCEPT" onMismatch="DENY"/>
-            <PatternLayout pattern="[%d{HH:mm:ss:SSS}] [%p] - %l - %m%n"/>
+            <PatternLayout pattern="[%d{HH:mm:ss:SSS}] [%-5p] [%t] - %l - %m%n"/>
             <Policies>
                 <TimeBasedTriggeringPolicy/>
                 <SizeBasedTriggeringPolicy size="500 MB"/>