调整 cn.reghao.jutil.jdk.event 的结构和某些方法名

jdk/src/main/java/cn/reghao/jutil/jdk/event/AbstractMessage.java

@@ -1,8 +0,0 @@
-package cn.reghao.jutil.jdk.event;
-
-/**
- * @author reghao
- * @date 2022-05-05 09:51:15
- */
-public abstract class AbstractMessage implements Message {
-}

jdk/src/main/java/cn/reghao/jutil/jdk/event/Channel.java

@@ -1,9 +0,0 @@
-package cn.reghao.jutil.jdk.event;
-
-/**
- * @author reghao
- * @date 2022-05-05 09:51:45
- */
-public interface Channel<E extends Message> {
-    void dispatch(E message);
-}

jdk/src/main/java/cn/reghao/jutil/jdk/event/DynamicRouter.java

@@ -1,10 +0,0 @@
-package cn.reghao.jutil.jdk.event;
-
-/**
- * @author reghao
- * @date 2022-05-05 09:52:19
- */
-public interface DynamicRouter<E extends Message> {
-    void registerChannel(Class<? extends E> contentType, Channel<? extends E> channel);
-    void dispatch(E content);
-}

jdk/src/main/java/cn/reghao/jutil/jdk/event/Handler.java

@@ -1,11 +0,0 @@
-package cn.reghao.jutil.jdk.event;
-
-/**
- * @author reghao
- * @date 2022-05-05 09:54:21
- */
-public class Handler implements Channel<Event> {
-    @Override
-    public void dispatch(Event message) {
-    }
-}

jdk/src/main/java/cn/reghao/jutil/jdk/event/handler/Channel.java

@@ -0,0 +1,11 @@
+package cn.reghao.jutil.jdk.event.handler;
+
+import cn.reghao.jutil.jdk.event.message.Message;
+
+/**
+ * @author reghao
+ * @date 2022-05-05 09:51:45
+ */
+public interface Channel<E extends Message> {
+    void handle(E message);
+}

jdk/src/main/java/cn/reghao/jutil/jdk/event/handler/Handler.java

@@ -0,0 +1,13 @@
+package cn.reghao.jutil.jdk.event.handler;
+
+import cn.reghao.jutil.jdk.event.message.Event;
+
+/**
+ * @author reghao
+ * @date 2022-05-05 09:54:21
+ */
+public class Handler implements Channel<Event> {
+    @Override
+    public void handle(Event message) {
+    }
+}

jdk/src/main/java/cn/reghao/jutil/jdk/event/Event.java → jdk/src/main/java/cn/reghao/jutil/jdk/event/message/Event.java

@@ -1,4 +1,4 @@
-package cn.reghao.jutil.jdk.event;
+package cn.reghao.jutil.jdk.event.message;
 
 /**
  * @author reghao

jdk/src/main/java/cn/reghao/jutil/jdk/event/EventMessage.java → jdk/src/main/java/cn/reghao/jutil/jdk/event/message/EventMessage.java

@@ -1,4 +1,4 @@
-package cn.reghao.jutil.jdk.event;
+package cn.reghao.jutil.jdk.event.message;
 
 import java.io.Serializable;
 import java.util.UUID;
@@ -10,8 +10,8 @@ import java.util.UUID;
 public class EventMessage implements Serializable {
     private static final long serialVersionUID = 1L;
 
-    private String msgId;
-    private long sendTime;
+    private final String msgId;
+    private final long sendTime;
     private Event event;
 
     private EventMessage() {

jdk/src/main/java/cn/reghao/jutil/jdk/event/Message.java → jdk/src/main/java/cn/reghao/jutil/jdk/event/message/Message.java

@@ -1,4 +1,4 @@
-package cn.reghao.jutil.jdk.event;
+package cn.reghao.jutil.jdk.event.message;
 
 import java.io.Serializable;
 

jdk/src/main/java/cn/reghao/jutil/jdk/event/router/DynamicRouter.java

@@ -0,0 +1,13 @@
+package cn.reghao.jutil.jdk.event.router;
+
+import cn.reghao.jutil.jdk.event.handler.Channel;
+import cn.reghao.jutil.jdk.event.message.Message;
+
+/**
+ * @author reghao
+ * @date 2022-05-05 09:52:19
+ */
+public interface DynamicRouter<E extends Message> {
+    void register(Class<? extends E> eventType, Channel<? extends E> channel);
+    void dispatch(E content);
+}

jdk/src/main/java/cn/reghao/jutil/jdk/event/EventDispatcher.java → jdk/src/main/java/cn/reghao/jutil/jdk/event/router/EventDispatcher.java

@@ -1,4 +1,8 @@
-package cn.reghao.jutil.jdk.event;
+package cn.reghao.jutil.jdk.event.router;
+
+import cn.reghao.jutil.jdk.event.handler.Channel;
+import cn.reghao.jutil.jdk.event.message.Event;
+import cn.reghao.jutil.jdk.event.handler.Handler;
 
 import java.util.HashMap;
 import java.util.Map;
@@ -11,12 +15,12 @@ public class EventDispatcher implements DynamicRouter<Event> {
     private final Map<Class<? extends Event>, Handler> handlers = new HashMap<>();
 
     @Override
-    public void registerChannel(Class<? extends Event> contentType, Channel<? extends Event> channel) {
+    public void register(Class<? extends Event> contentType, Channel<? extends Event> channel) {
         handlers.put(contentType, (Handler) channel);
     }
 
     @Override
     public void dispatch(Event content) {
-        handlers.get(content.getClass()).dispatch(content);
+        handlers.get(content.getClass()).handle(content);
     }
 }