From e8fb6fa33dbdf65cabdd974924400abd3ed3e424 Mon Sep 17 00:00:00 2001
From: jianan <1072772483@qq.com>
Date: Fri, 8 Jul 2022 12:10:36 +0800
Subject: [PATCH] =?UTF-8?q?perf[module]:=20=E5=86=8D=E6=AC=A1=E7=90=86?=
 =?UTF-8?q?=E8=A7=A3asyncAsk=E5=BC=82=E6=AD=A5=E5=9B=9E=E8=B0=83=E7=9A=84a?=
 =?UTF-8?q?rgument=E5=8F=82=E6=95=B0=E7=9A=84=E4=BD=9C=E7=94=A8:=E8=AF=B7?=
 =?UTF-8?q?=E6=B1=82=E6=96=B9=20=E5=92=8C=20=E6=89=A7=E8=A1=8C=E6=96=B9?=
 =?UTF-8?q?=E9=83=BD=E7=94=A8=E5=88=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 net/src/main/java/com/zfoo/net/router/Router.java | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/net/src/main/java/com/zfoo/net/router/Router.java b/net/src/main/java/com/zfoo/net/router/Router.java
index 0c3a7843..df29d7d8 100644
--- a/net/src/main/java/com/zfoo/net/router/Router.java
+++ b/net/src/main/java/com/zfoo/net/router/Router.java
@@ -148,7 +148,7 @@ public class Router implements IRouter {
         }
 
         // 正常发送消息的接收,把客户端的业务请求包装下到路由策略指定的线程进行业务处理
-        // 注意：像客户端以asyncAsk发送请求，在服务器处理完后返回结果，也是进入这个receive方法，但是attachment不为空，会提前return掉不会走到这
+        // 注意：像客户端以asyncAsk发送请求，在服务器处理完后返回结果，在请求方也是进入这个receive方法，但是attachment不为空，会提前return掉不会走到这
         TaskBus.submit(new PacketReceiverTask(session, packet, attachment));
     }
 
@@ -219,7 +219,9 @@ public class Router implements IRouter {
     }
 
     /**
-     * 注意：这个里面其实还是调用send发送的消息
+     * 注意：
+     * 1.这个里面其实还是调用send发送的消息
+     * 2.这个argument的参数，不仅是在asyncAsk回调时要到哪个线程用， 在provider执行方也用
      *
      * @param session
      * @param packet
@@ -328,7 +330,8 @@ public class Router implements IRouter {
                 }
             }
 
-            // 调用PacketReceiver,进行真正的业务处理
+            // 调用PacketReceiver,进行真正的业务处理,这个submit只是根据packet找到protocolId，然后进行反射调用
+            // 这个在哪个线程处理取决于：这个上层的PacketReceiverTask被丢到了哪个线程中
             PacketBus.submit(session, packet, attachment);
         } catch (Exception e) {
             logger.error(StringUtils.format("e[uid:{}][sid:{}]未知exception异常", session.getAttribute(AttributeType.UID), session.getSid(), e.getMessage()), e);