重构监控上报消息实体.

hippo4j-common/src/main/java/cn/hippo4j/common/monitor/AbstractMessage.java

@@ -1,6 +1,7 @@
 package cn.hippo4j.common.monitor;
 
 import lombok.Data;
+import lombok.NoArgsConstructor;
 
 import java.util.List;
 
@@ -11,6 +12,7 @@ import java.util.List;
  * @date 2021/12/7 20:31
  */
 @Data
+@NoArgsConstructor
 public abstract class AbstractMessage implements Message {
 
     /**
@@ -21,7 +23,7 @@ public abstract class AbstractMessage implements Message {
     /**
      * messageTypeEnum
      */
-    private MessageTypeEnum messageTypeEnum;
+    private MessageTypeEnum messageType;
 
     /**
      * message

hippo4j-common/src/main/java/cn/hippo4j/common/monitor/Message.java

@@ -1,12 +1,15 @@
 package cn.hippo4j.common.monitor;
 
+import java.io.Serializable;
+import java.util.List;
+
 /**
  * Abstract message monitoring interface.
  *
  * @author chen.ma
  * @date 2021/12/6 20:16
  */
-public interface Message {
+public interface Message extends Serializable {
 
     /**
      * Get groupKey.
@@ -15,4 +18,18 @@ public interface Message {
      */
     String getGroupKey();
 
+    /**
+     * Get message type.
+     *
+     * @return
+     */
+    MessageTypeEnum getMessageType();
+
+    /**
+     * Get messages.
+     *
+     * @return
+     */
+    List<Message> getMessages();
+
 }

hippo4j-common/src/main/java/cn/hippo4j/common/monitor/MessageWrapper.java

@@ -0,0 +1,25 @@
+package cn.hippo4j.common.monitor;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+
+/**
+ * Message wrapper.
+ *
+ * @author chen.ma
+ * @date 2021/12/7 22:42
+ */
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class MessageWrapper extends AbstractMessage implements Serializable {
+
+    /**
+     * messageObj
+     */
+    private Object messageObj;
+
+}

hippo4j-common/src/main/java/cn/hippo4j/common/monitor/RuntimeMessage.java

@@ -1,6 +1,7 @@
 package cn.hippo4j.common.monitor;
 
 import lombok.Data;
+import lombok.NoArgsConstructor;
 
 /**
  * Dynamic thread pool runtime data.
@@ -9,6 +10,7 @@ import lombok.Data;
  * @date 2021/12/6 18:18
  */
 @Data
+@NoArgsConstructor
 public class RuntimeMessage extends AbstractMessage {
 
     /**