使用两个方法分别构建 rpcParamMsg 和 rpcResultMsg

common/src/main/java/cn/reghao/autodop/common/msg/Message.java

@@ -26,6 +26,11 @@ public class Message implements Serializable {
         this.sendTime = System.currentTimeMillis();
     }
 
+    private Message(String msgId) {
+        this.msgId = msgId;
+        this.sendTime = System.currentTimeMillis();
+    }
+
     public static Message pubMsg(PubMsg pubMsg) {
         Message message = new Message();
         message.setMsgType(MsgType.pub.name());
@@ -33,9 +38,16 @@ public class Message implements Serializable {
         return message;
     }
 
-    public static Message rpcMsg(RpcMsg rpcMsg, MsgType msgType) {
+    public static Message rpcParamMsg(RpcMsg rpcMsg) {
         Message message = new Message();
-        message.setMsgType(msgType.name());
+        message.setMsgType(MsgType.rpcParam.name());
+        message.setRpcMsg(rpcMsg);
+        return message;
+    }
+
+    public static Message rpcResultMsg(String msgId, RpcMsg rpcMsg) {
+        Message message = new Message(msgId);
+        message.setMsgType(MsgType.rpcResult.name());
         message.setRpcMsg(rpcMsg);
         return message;
     }