异常打印

serverlogic/src/main/java/com/ljsd/jieling/core/HandlerLogicThread.java

@@ -113,7 +113,7 @@ public class HandlerLogicThread extends Thread{
         try {
             AyyncWorker ayyncWorker =null;
             while ( (ayyncWorker = ayyncWorkerConcurrentLinkedQueue.poll())!=null){
-                ayyncWorker.exec();
+                ayyncWorker.work(ayyncWorker.getUser());
             }
             PacketNetData packetNetData = handlerLinkedQueue.poll();
             if(packetNetData == null){
@@ -177,6 +177,7 @@ public class HandlerLogicThread extends Thread{
                             LOGGER.error(ErrorUtil.getExceptionStackTraceFileLineAndMethod(e));
                         }else {
                             LOGGER.info(e.toString());
+                            LOGGER.debug(ErrorUtil.getExceptionStackTraceFileLineAndMethod(e));
                         }
                         MessageUtil.sendErrorResponse(session, errCode, session.getLastMsgId() + 1,(ErrorCodeException)e);
                         return;

serverlogic/src/main/java/com/ljsd/jieling/exception/ErrorUtil.java

@@ -67,8 +67,6 @@ public class ErrorUtil {
                 StackTraceElement[] stackTraceElements = t.getStackTrace();
                 if (stackTraceElements != null && stackTraceElements.length > 0) {
                     builder.append(System.getProperty("line.separator"));
-                    int var5 = stackTraceElements.length;
-
                     for (StackTraceElement stackTraceElement : stackTraceElements) {
                         builder.append("    at ").append(stackTraceElement).append(System.getProperty("line.separator"));
                     }

serverlogic/src/main/java/com/ljsd/jieling/handler/BaseHandler.java

@@ -48,7 +48,7 @@ public abstract class BaseHandler<T extends GeneratedMessage> {
             throw new LogicException("解析协议失败",var5);
         }catch (Exception var4) {
             if(null !=proto){
-                LOGGER.error("processWithProtoException\r\nprotoID:"+netData.getMsgId()+"\r\n"+proto.toString());
+                LOGGER.error("processWithProtoException\r\nprotoID:"+netData.getMsgId()+"\r\nuid"+netData.getUserId()+"\r\n"+proto.toString());
             }
             throw var4;
         }

serverlogic/src/main/java/com/ljsd/jieling/handler/TakeActivityRewardHandler.java

@@ -16,16 +16,14 @@ import com.ljsd.jieling.util.MessageUtil;
 import org.springframework.stereotype.Component;
 
 @Component
-public class TakeActivityRewardHandler extends BaseHandler {
+public class TakeActivityRewardHandler extends BaseHandler<PlayerInfoProto.TakeActivityRewardRequest> {
     @Override
     public MessageTypeProto.MessageType getMessageCode() {
         return MessageTypeProto.MessageType.TAKE_ACTIVITY_REWARD_REQUEST;
     }
 
     @Override
-    public void process(ISession iSession, PacketNetData netData) throws Exception {
-        byte[] bytes = netData.parseClientProtoNetData();
-        PlayerInfoProto.TakeActivityRewardRequest takeActivityRewardRequest = PlayerInfoProto.TakeActivityRewardRequest.parseFrom(bytes);
+    public void processWithProto(ISession iSession, PlayerInfoProto.TakeActivityRewardRequest takeActivityRewardRequest) throws Exception {
         int missionId = takeActivityRewardRequest.getMissionId();
         int activityId = takeActivityRewardRequest.getActivityId();
         AbstractActivity abstractActivity = ActivityTypeEnum.getActicityType(activityId);
@@ -37,6 +35,6 @@ public class TakeActivityRewardHandler extends BaseHandler {
             User user = UserManager.getUser(iSession.getUid());
             user.getUserMissionManager().onGameEvent(user,GameEvent.TAKE_ACTIVITY_REWARD,activityId);
         }
-
     }
+
 }

serverlogic/src/main/java/com/ljsd/jieling/util/AyyncWorker.java

@@ -3,9 +3,9 @@ package com.ljsd.jieling.util;
 import com.ljsd.jieling.logic.dao.root.User;
 
 /**
- * 异步任务代理类
+ * 代理模式  异步任务代理类
  */
-public  class AyyncWorker{
+public class AyyncWorker implements AyncWorkerRunnable {
     private User user;
     private boolean isTask;
     private AyncWorkerRunnable ayncWorkerRunnable;
@@ -17,8 +17,11 @@ public  class AyyncWorker{
         this.ayncWorkerRunnable = ayncWorkerRunnable;
     }
 
-    public void exec() throws Exception {
-        ayncWorkerRunnable.work(user);
+
+    @Override
+    public void work(User user) throws Exception {
+        if (null != ayncWorkerRunnable)
+            ayncWorkerRunnable.work(user);
     }
 
     public void setUser(User user) {