From 5c96eb37564143228b4bf2fbf316cd762355ee44 Mon Sep 17 00:00:00 2001 From: wangyuan Date: Tue, 27 Aug 2019 12:04:05 +0800 Subject: [PATCH] fix indicaiton --- .../main/java/com/ljsd/jieling/core/HandlerLogicThread.java | 1 - .../src/main/java/com/ljsd/jieling/util/MessageUtil.java | 4 ++++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/serverlogic/src/main/java/com/ljsd/jieling/core/HandlerLogicThread.java b/serverlogic/src/main/java/com/ljsd/jieling/core/HandlerLogicThread.java index 5c0da6438..39af25616 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/core/HandlerLogicThread.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/core/HandlerLogicThread.java @@ -145,7 +145,6 @@ public class HandlerLogicThread extends Thread{ MissionEventDistributor.requestStart(); baseHandler.execute(session, packetNetData); MissionEventDistributor.requestEnd(session,true); - current().commit(); MongoUtil.getInstence().lastUpdate(); if(msgId != MessageTypeProto.MessageType.GET_CHAT_MESSAGE_REQUEST_VALUE){ long useTime = System.currentTimeMillis() - curTimeMillis; diff --git a/serverlogic/src/main/java/com/ljsd/jieling/util/MessageUtil.java b/serverlogic/src/main/java/com/ljsd/jieling/util/MessageUtil.java index 27113ddda..a904cb61d 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/util/MessageUtil.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/util/MessageUtil.java @@ -97,6 +97,10 @@ public class MessageUtil { } public static void sendMessage(ISession session, int result, int msgId, GeneratedMessage generatedMessage, boolean flush) { + if( null!=HandlerLogicThread.current()){ + HandlerLogicThread.current().commit(); + } + byte[] byteBuf = wrappedBuffer(session.getUid(), session.getToken(), session.getIndex(), result, msgId, generatedMessage); if (flush) { session.writeAndFlush(byteBuf);