From 469c23fef86baee82fa0c2e767523db45fbd31e2 Mon Sep 17 00:00:00 2001
From: shaozhuguang <shaozhuguang@jd.com>
Date: Fri, 19 Apr 2019 09:56:49 +0800
Subject: [PATCH] Modify Class Note......

---
 .../stp/communication/MessageExecutor.java    | 22 ++++++++++-
 .../stp/communication/RemoteSession.java      |  2 +-
 .../callback/CallBackBarrier.java             |  2 +-
 .../callback/CallBackDataListener.java        |  2 +-
 .../callback/CallBackLauncher.java            |  3 +-
 .../connection/AbstractAsyncExecutor.java     |  2 +-
 .../connection/AsyncExecutor.java             |  2 +-
 .../communication/connection/Connection.java  |  2 +-
 .../communication/connection/Receiver.java    |  2 +-
 .../stp/communication/connection/Sender.java  | 38 ++++++++++++++++++-
 .../handler/HeartBeatReceiverHandler.java     |  2 +-
 .../handler/HeartBeatReceiverTrigger.java     |  2 +-
 .../handler/HeartBeatSenderHandler.java       |  2 +-
 .../handler/HeartBeatSenderTrigger.java       |  2 +-
 .../connection/handler/ReceiverHandler.java   |  2 +-
 .../connection/handler/SenderHandler.java     |  2 +-
 .../connection/handler/WatchDogHandler.java   | 30 +++++++++++++--
 .../connection/listener/ReplyListener.java    |  2 +-
 .../manager/ConnectionManager.java            |  2 +-
 .../manager/RemoteSessionManager.java         |  2 +-
 .../message/AbstractMessage.java              |  2 +-
 .../message/HeartBeatMessage.java             |  2 +-
 .../stp/communication/message/IMessage.java   |  2 +-
 .../communication/message/LoadMessage.java    |  2 +-
 .../communication/message/SessionMessage.java |  2 +-
 .../message/TransferMessage.java              |  2 +-
 .../stp/communication/node/LocalNode.java     |  3 +-
 .../stp/communication/node/RemoteNode.java    |  3 +-
 28 files changed, 111 insertions(+), 32 deletions(-)

diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/MessageExecutor.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/MessageExecutor.java
index ca85b0c8..dba7e0d0 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/MessageExecutor.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/MessageExecutor.java
@@ -1,8 +1,8 @@
 /**
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
- * FileName: com.jd.blockchain.stp.communication.MessageExecute
+ * FileName: com.jd.blockchain.stp.communication.MessageExecutor
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/11 上午10:59
  * Description:
  */
@@ -19,8 +19,26 @@ package com.jd.blockchain.stp.communication;
 
 public interface MessageExecutor {
 
+    /**
+     * 接收到receive消息如何处理
+     *
+     * @param key
+     *     请求消息的Key，调用者需要在应答时通过该Key应答远端
+     * @param data
+     *     请求消息的内容
+     * @param session
+     *     远端Session，描述该消息是从哪发送来的
+     * @return
+     *     应答结果
+     */
     byte[] receive(String key, byte[] data, RemoteSession session);
 
+    /**
+     * 应答方式
+     *
+     * @return
+     *     参考：{@link REPLY}
+     */
     REPLY replyType();
 
     // 应答方式
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/RemoteSession.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/RemoteSession.java
index cc4dd167..f72a071c 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/RemoteSession.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/RemoteSession.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.RemoteSession
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/11 上午11:15
  * Description:
  */
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/callback/CallBackBarrier.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/callback/CallBackBarrier.java
index c9580e10..41da6b66 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/callback/CallBackBarrier.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/callback/CallBackBarrier.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.CallBackBarrier
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/12 上午10:22
  * Description:
  */
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/callback/CallBackDataListener.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/callback/CallBackDataListener.java
index e9aa4417..9de7aa32 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/callback/CallBackDataListener.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/callback/CallBackDataListener.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.callback.CallBackDataListener
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/15 下午4:40
  * Description:
  */
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/callback/CallBackLauncher.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/callback/CallBackLauncher.java
index bef91db4..e1f9473a 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/callback/CallBackLauncher.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/callback/CallBackLauncher.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.callback.CallBackLauncher
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/17 下午6:27
  * Description:
  */
@@ -15,6 +15,7 @@ import java.util.concurrent.Semaphore;
  * @author shaozhuguang
  * @create 2019/4/17
  * @since 1.0.0
+ * @date 2019-04-19 09:53
  */
 
 public class CallBackLauncher {
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/AbstractAsyncExecutor.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/AbstractAsyncExecutor.java
index 273fcbc0..fc99cb05 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/AbstractAsyncExecutor.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/AbstractAsyncExecutor.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.connection.AbstractAsyncExecutor
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/17 上午11:16
  * Description:
  */
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/AsyncExecutor.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/AsyncExecutor.java
index 22c0c28a..5bfdd682 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/AsyncExecutor.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/AsyncExecutor.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.connection.AsyncExecutor
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/17 上午11:14
  * Description:
  */
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/Connection.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/Connection.java
index 7ceedf77..1c6d2dc6 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/Connection.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/Connection.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.connection.Connection
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/11 下午5:39
  * Description:
  */
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/Receiver.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/Receiver.java
index c9dae7fa..50eab985 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/Receiver.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/Receiver.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.inner.Receiver
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/11 上午10:59
  * Description:
  */
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/Sender.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/Sender.java
index cbc57467..dcef4009 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/Sender.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/Sender.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.inner.Sender
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/11 上午10:58
  * Description:
  */
@@ -101,6 +101,7 @@ public class Sender extends AbstractAsyncExecutor implements Closeable {
 
         ThreadPoolExecutor runThread = initRunThread();
 
+        // 单独线程进行连接，防止当前调用线程阻塞
         runThread.execute(() -> {
             try {
                 // 发起连接请求
@@ -126,10 +127,28 @@ public class Sender extends AbstractAsyncExecutor implements Closeable {
         });
     }
 
+    /**
+     * 初始化相关配置
+     *
+     * @param remoteNode
+     *     远端节点
+     * @param sessionMessage
+     *     本地节点连接到远端节点后发送的SessionMessage
+     */
     private void init(RemoteNode remoteNode, SessionMessage sessionMessage) {
         init(remoteNode.getHostName(), remoteNode.getPort(), sessionMessage);
     }
 
+    /**
+     * 初始化相关配置
+     *
+     * @param remoteHost
+     *     远端HOST
+     * @param remotePort
+     *     远端端口
+     * @param sessionMessage
+     *     本地节点连接到远端节点后发送的SessionMessage
+     */
     private void init(String remoteHost, int remotePort, SessionMessage sessionMessage) {
         this.remoteHost = remoteHost;
         this.remotePort = remotePort;
@@ -149,7 +168,9 @@ public class Sender extends AbstractAsyncExecutor implements Closeable {
 
     /**
      * 发送消息
+     *
      * @param message
+     *     消息统一接口
      */
     public void send(IMessage message) {
         watchDogHandler.channelFuture().channel().writeAndFlush(message.toTransferByteBuf());
@@ -161,15 +182,30 @@ public class Sender extends AbstractAsyncExecutor implements Closeable {
 //        loopGroup.shutdownGracefully();
     }
 
+    /**
+     * ChannelHandler集合管理类
+     */
     public static class ChannelHandlers {
 
         private List<ChannelHandler> channelHandlers = new ArrayList<>();
 
+        /**
+         * 添加指定的ChannelHandler
+         *
+         * @param channelHandler
+         *     需要加入的ChannelHandler
+         * @return
+         */
         public ChannelHandlers addHandler(ChannelHandler channelHandler) {
             channelHandlers.add(channelHandler);
             return this;
         }
 
+        /**
+         * List集合转换为数组
+         *
+         * @return
+         */
         public ChannelHandler[] toArray() {
             ChannelHandler[] channelHandlerArray = new ChannelHandler[channelHandlers.size()];
             return channelHandlers.toArray(channelHandlerArray);
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/HeartBeatReceiverHandler.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/HeartBeatReceiverHandler.java
index 47d65176..ab3595e9 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/HeartBeatReceiverHandler.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/HeartBeatReceiverHandler.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.connection.handler.HeartBeatSenderHandler
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/15 上午10:10
  * Description:
  */
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/HeartBeatReceiverTrigger.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/HeartBeatReceiverTrigger.java
index 588b6de3..48288dc6 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/HeartBeatReceiverTrigger.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/HeartBeatReceiverTrigger.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.connection.handler.HeartBeatSenderTrigger
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/15 上午10:11
  * Description:
  */
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/HeartBeatSenderHandler.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/HeartBeatSenderHandler.java
index a477c42c..be1c187b 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/HeartBeatSenderHandler.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/HeartBeatSenderHandler.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.connection.handler.HeartBeatSenderHandler
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/15 上午10:10
  * Description:
  */
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/HeartBeatSenderTrigger.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/HeartBeatSenderTrigger.java
index fc059d54..9a61f31a 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/HeartBeatSenderTrigger.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/HeartBeatSenderTrigger.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.connection.handler.HeartBeatSenderTrigger
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/15 上午10:11
  * Description:
  */
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/ReceiverHandler.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/ReceiverHandler.java
index 1bcb5ef3..8a13db4e 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/ReceiverHandler.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/ReceiverHandler.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.connection.handler.ReceiverHandler
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/12 上午11:14
  * Description:
  */
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/SenderHandler.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/SenderHandler.java
index ac86ea54..b3d194cb 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/SenderHandler.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/SenderHandler.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.connection.handler.SenderHandler
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/16 下午2:00
  * Description:
  */
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/WatchDogHandler.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/WatchDogHandler.java
index ca41fc9a..bdcb82de 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/WatchDogHandler.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/handler/WatchDogHandler.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.connection.SenderWatchDog
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/12 下午4:56
  * Description:
  */
@@ -27,6 +27,7 @@ import java.util.concurrent.locks.ReentrantLock;
  * @author shaozhuguang
  * @create 2019/4/12
  * @since 1.0.0
+ * @date 2019-04-19 09:21
  */
 @ChannelHandler.Sharable
 public class WatchDogHandler extends ChannelInboundHandlerAdapter implements Runnable, Closeable {
@@ -42,13 +43,19 @@ public class WatchDogHandler extends ChannelInboundHandlerAdapter implements Run
      */
     private final Lock reconnectLock = new ReentrantLock();
 
-    // 默认的最多重连次数
+    /**
+     * 默认的最多重连次数
+     */
     private final int maxReconnectSize = 16;
 
-    // 默认重连的时间
+    /**
+     * 默认重连的时间，下次重连时间会变长
+     */
     private final int defaultReconnectSeconds = 2;
 
-    // 标识是否正常工作中，假设不再工作则不再重连
+    /**
+     * 标识是否正常工作中，假设不再工作则不再重连
+     */
     private boolean isWorking = true;
 
     /**
@@ -121,12 +128,27 @@ public class WatchDogHandler extends ChannelInboundHandlerAdapter implements Run
         initTimer();
     }
 
+    /**
+     * 初始化ChannelFuture
+     *
+     * @param channelFuture
+     */
     public void initChannelFuture(ChannelFuture channelFuture) {
         this.channelFuture = channelFuture;
     }
 
+    /**
+     * 返回ChannelFuture
+     *
+     * @return
+     *     该返回对象目前未处理是否连接成功的情况
+     *     调用者可直接使用，但假设发送不成功的话会存在异常抛出
+     *     调用者可手动处理异常
+     */
     public ChannelFuture channelFuture() {
         try {
+            // 使用锁防止在重连进行过程中互相竞争
+            // 一定是等待本次重连完成才返回
             reconnectLock.lock();
             return this.channelFuture;
         } finally {
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/listener/ReplyListener.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/listener/ReplyListener.java
index 47d11883..ac9221d0 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/listener/ReplyListener.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/connection/listener/ReplyListener.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.connection.listener.ReplyListener
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/12 上午10:36
  * Description:
  */
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/manager/ConnectionManager.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/manager/ConnectionManager.java
index 0db2cdfe..c4f8097f 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/manager/ConnectionManager.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/manager/ConnectionManager.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.ConnectionManager
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/11 下午6:11
  * Description:
  */
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/manager/RemoteSessionManager.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/manager/RemoteSessionManager.java
index 50adda54..8025252a 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/manager/RemoteSessionManager.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/manager/RemoteSessionManager.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.RemoteSessionManager
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/11 上午11:22
  * Description:
  */
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/AbstractMessage.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/AbstractMessage.java
index 8cd0a3e9..a20ef623 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/AbstractMessage.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/AbstractMessage.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.message.AbstractMessage
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/17 下午4:00
  * Description:
  */
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/HeartBeatMessage.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/HeartBeatMessage.java
index a0f5974c..eba5e4b6 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/HeartBeatMessage.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/HeartBeatMessage.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.message.HeartBeatMessage
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/12 下午4:55
  * Description:
  */
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/IMessage.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/IMessage.java
index 6cb0a0a4..c43e8d84 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/IMessage.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/IMessage.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.message.IMessage
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/16 下午1:58
  * Description:
  */
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/LoadMessage.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/LoadMessage.java
index 795fa8c1..b8971293 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/LoadMessage.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/LoadMessage.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.message.LoadMessage
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/11 上午10:59
  * Description:
  */
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/SessionMessage.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/SessionMessage.java
index c685b77c..b3ce460b 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/SessionMessage.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/SessionMessage.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.message.SessionMessage
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/16 上午10:40
  * Description:
  */
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/TransferMessage.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/TransferMessage.java
index 8bc9a448..b6000866 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/TransferMessage.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/message/TransferMessage.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.message.TransferMessage
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/11 上午11:00
  * Description:
  */
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/node/LocalNode.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/node/LocalNode.java
index 64c203bd..60b9b11b 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/node/LocalNode.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/node/LocalNode.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.node.LocalNode
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/16 下午3:12
  * Description:
  */
@@ -15,6 +15,7 @@ import com.jd.blockchain.stp.communication.MessageExecutor;
  * @author shaozhuguang
  * @create 2019/4/16
  * @since 1.0.0
+ * @date 2019-04-19 09:28
  */
 
 public class LocalNode extends RemoteNode {
diff --git a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/node/RemoteNode.java b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/node/RemoteNode.java
index 7e2004c8..89287380 100644
--- a/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/node/RemoteNode.java
+++ b/source/stp/stp-communication/src/main/java/com/jd/blockchain/stp/communication/node/RemoteNode.java
@@ -2,7 +2,7 @@
  * Copyright: Copyright 2016-2020 JD.COM All Right Reserved
  * FileName: com.jd.blockchain.stp.communication.RemoteNode
  * Author: shaozhuguang
- * Department: Y事业部
+ * Department: Jingdong Digits Technology
  * Date: 2019/4/11 下午3:40
  * Description:
  */
@@ -13,6 +13,7 @@ package com.jd.blockchain.stp.communication.node;
  * @author shaozhuguang
  * @create 2019/4/11
  * @since 1.0.0
+ * @date 2019-04-19 09:28
  */
 
 public class RemoteNode {