From 3564bdad13d31ab3e9cc14ab7d16cd0b1173ea53 Mon Sep 17 00:00:00 2001
From: javazyk2021 <zyk001123@163.com>
Date: Thu, 25 Jan 2024 23:24:11 +0800
Subject: [PATCH] =?UTF-8?q?feature:eventloop=20handler=20=E7=9A=84?=
 =?UTF-8?q?=E6=B5=8B=E8=AF=95=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .idea/uiDesigner.xml                          | 124 +++++++++++++++++
 .idea/workspace.xml                           | 127 ++++++++++++++++--
 netty-client/pom.xml                          |   8 ++
 .../tool/zyk/channel/ChannelTestClient.java   |  43 ++++++
 .../zyk/eventgroup/EventGroupTestClient.java  |  44 ++++++
 .../handler_pipeline/HandlerClientTest.java   |  44 ++++++
 netty-server/pom.xml                          |   9 ++
 .../zyk/eventgroup/EventGroupServerTest.java  |  53 ++++++++
 .../handler_pipeline/HandlerServerTest.java   |  75 +++++++++++
 .../tool/zyk/eventgroup/EventGroupTest.java   |  42 ++++++
 .../java/tool/zyk/promise/PromiseTest.java    |  72 ++++++++++
 pom.xml                                       |  10 ++
 12 files changed, 637 insertions(+), 14 deletions(-)
 create mode 100644 .idea/uiDesigner.xml
 create mode 100644 netty-client/src/main/java/tool/zyk/channel/ChannelTestClient.java
 create mode 100644 netty-client/src/main/java/tool/zyk/eventgroup/EventGroupTestClient.java
 create mode 100644 netty-client/src/main/java/tool/zyk/handler_pipeline/HandlerClientTest.java
 create mode 100644 netty-server/src/main/java/tool/zyk/eventgroup/EventGroupServerTest.java
 create mode 100644 netty-server/src/main/java/tool/zyk/handler_pipeline/HandlerServerTest.java
 create mode 100644 netty-server/src/test/java/tool/zyk/eventgroup/EventGroupTest.java
 create mode 100644 netty-server/src/test/java/tool/zyk/promise/PromiseTest.java

diff --git a/.idea/uiDesigner.xml b/.idea/uiDesigner.xml
new file mode 100644
index 0000000..2b63946
--- /dev/null
+++ b/.idea/uiDesigner.xml
@@ -0,0 +1,124 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="Palette2">
+    <group name="Swing">
+      <item class="com.intellij.uiDesigner.HSpacer" tooltip-text="Horizontal Spacer" icon="/com/intellij/uiDesigner/icons/hspacer.svg" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="1" hsize-policy="6" anchor="0" fill="1" />
+      </item>
+      <item class="com.intellij.uiDesigner.VSpacer" tooltip-text="Vertical Spacer" icon="/com/intellij/uiDesigner/icons/vspacer.svg" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="6" hsize-policy="1" anchor="0" fill="2" />
+      </item>
+      <item class="javax.swing.JPanel" icon="/com/intellij/uiDesigner/icons/panel.svg" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3" />
+      </item>
+      <item class="javax.swing.JScrollPane" icon="/com/intellij/uiDesigner/icons/scrollPane.svg" removable="false" auto-create-binding="false" can-attach-label="true">
+        <default-constraints vsize-policy="7" hsize-policy="7" anchor="0" fill="3" />
+      </item>
+      <item class="javax.swing.JButton" icon="/com/intellij/uiDesigner/icons/button.svg" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="3" anchor="0" fill="1" />
+        <initial-values>
+          <property name="text" value="Button" />
+        </initial-values>
+      </item>
+      <item class="javax.swing.JRadioButton" icon="/com/intellij/uiDesigner/icons/radioButton.svg" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="3" anchor="8" fill="0" />
+        <initial-values>
+          <property name="text" value="RadioButton" />
+        </initial-values>
+      </item>
+      <item class="javax.swing.JCheckBox" icon="/com/intellij/uiDesigner/icons/checkBox.svg" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="3" anchor="8" fill="0" />
+        <initial-values>
+          <property name="text" value="CheckBox" />
+        </initial-values>
+      </item>
+      <item class="javax.swing.JLabel" icon="/com/intellij/uiDesigner/icons/label.svg" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="0" anchor="8" fill="0" />
+        <initial-values>
+          <property name="text" value="Label" />
+        </initial-values>
+      </item>
+      <item class="javax.swing.JTextField" icon="/com/intellij/uiDesigner/icons/textField.svg" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
+          <preferred-size width="150" height="-1" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JPasswordField" icon="/com/intellij/uiDesigner/icons/passwordField.svg" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
+          <preferred-size width="150" height="-1" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JFormattedTextField" icon="/com/intellij/uiDesigner/icons/formattedTextField.svg" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1">
+          <preferred-size width="150" height="-1" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JTextArea" icon="/com/intellij/uiDesigner/icons/textArea.svg" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
+          <preferred-size width="150" height="50" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JTextPane" icon="/com/intellij/uiDesigner/icons/textPane.svg" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
+          <preferred-size width="150" height="50" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JEditorPane" icon="/com/intellij/uiDesigner/icons/editorPane.svg" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
+          <preferred-size width="150" height="50" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JComboBox" icon="/com/intellij/uiDesigner/icons/comboBox.svg" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="0" hsize-policy="2" anchor="8" fill="1" />
+      </item>
+      <item class="javax.swing.JTable" icon="/com/intellij/uiDesigner/icons/table.svg" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
+          <preferred-size width="150" height="50" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JList" icon="/com/intellij/uiDesigner/icons/list.svg" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="6" hsize-policy="2" anchor="0" fill="3">
+          <preferred-size width="150" height="50" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JTree" icon="/com/intellij/uiDesigner/icons/tree.svg" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3">
+          <preferred-size width="150" height="50" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JTabbedPane" icon="/com/intellij/uiDesigner/icons/tabbedPane.svg" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3">
+          <preferred-size width="200" height="200" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JSplitPane" icon="/com/intellij/uiDesigner/icons/splitPane.svg" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="3" hsize-policy="3" anchor="0" fill="3">
+          <preferred-size width="200" height="200" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JSpinner" icon="/com/intellij/uiDesigner/icons/spinner.svg" removable="false" auto-create-binding="true" can-attach-label="true">
+        <default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1" />
+      </item>
+      <item class="javax.swing.JSlider" icon="/com/intellij/uiDesigner/icons/slider.svg" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="6" anchor="8" fill="1" />
+      </item>
+      <item class="javax.swing.JSeparator" icon="/com/intellij/uiDesigner/icons/separator.svg" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="6" hsize-policy="6" anchor="0" fill="3" />
+      </item>
+      <item class="javax.swing.JProgressBar" icon="/com/intellij/uiDesigner/icons/progressbar.svg" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="6" anchor="0" fill="1" />
+      </item>
+      <item class="javax.swing.JToolBar" icon="/com/intellij/uiDesigner/icons/toolbar.svg" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="6" anchor="0" fill="1">
+          <preferred-size width="-1" height="20" />
+        </default-constraints>
+      </item>
+      <item class="javax.swing.JToolBar$Separator" icon="/com/intellij/uiDesigner/icons/toolbarSeparator.svg" removable="false" auto-create-binding="false" can-attach-label="false">
+        <default-constraints vsize-policy="0" hsize-policy="0" anchor="0" fill="1" />
+      </item>
+      <item class="javax.swing.JScrollBar" icon="/com/intellij/uiDesigner/icons/scrollbar.svg" removable="false" auto-create-binding="true" can-attach-label="false">
+        <default-constraints vsize-policy="6" hsize-policy="0" anchor="0" fill="2" />
+      </item>
+    </group>
+  </component>
+</project>
\ No newline at end of file
diff --git a/.idea/workspace.xml b/.idea/workspace.xml
index f8da396..f6c3be8 100644
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
@@ -4,7 +4,20 @@
     <option name="autoReloadType" value="SELECTIVE" />
   </component>
   <component name="ChangeListManager">
-    <list default="true" id="678613ce-6ba2-4fc8-bda2-991ee5e0d261" name="更改" comment="feature:init hello world初始化完成" />
+    <list default="true" id="678613ce-6ba2-4fc8-bda2-991ee5e0d261" name="更改" comment="feature:init hello world初始化完成">
+      <change afterPath="$PROJECT_DIR$/.idea/uiDesigner.xml" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/netty-client/src/main/java/tool/zyk/channel/ChannelTestClient.java" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/netty-client/src/main/java/tool/zyk/eventgroup/EventGroupTestClient.java" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/netty-client/src/main/java/tool/zyk/handler_pipeline/HandlerClientTest.java" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/netty-server/src/main/java/tool/zyk/eventgroup/EventGroupServerTest.java" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/netty-server/src/main/java/tool/zyk/handler_pipeline/HandlerServerTest.java" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/netty-server/src/test/java/tool/zyk/eventgroup/EventGroupTest.java" afterDir="false" />
+      <change afterPath="$PROJECT_DIR$/netty-server/src/test/java/tool/zyk/promise/PromiseTest.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/netty-client/pom.xml" beforeDir="false" afterPath="$PROJECT_DIR$/netty-client/pom.xml" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/netty-server/pom.xml" beforeDir="false" afterPath="$PROJECT_DIR$/netty-server/pom.xml" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/pom.xml" beforeDir="false" afterPath="$PROJECT_DIR$/pom.xml" afterDir="false" />
+    </list>
     <option name="SHOW_DIALOG" value="false" />
     <option name="HIGHLIGHT_CONFLICTS" value="true" />
     <option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" />
@@ -30,6 +43,7 @@
       </map>
     </option>
     <option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$" />
+    <option name="UPDATE_TYPE" value="REBASE" />
   </component>
   <component name="GitToolBoxStore">
     <option name="projectConfigVersion" value="5" />
@@ -42,7 +56,11 @@
                 <list>
                   <RecentBranch>
                     <option name="branchName" value="init" />
-                    <option name="lastUsedInstant" value="1706190849" />
+                    <option name="lastUsedInstant" value="1706191367" />
+                  </RecentBranch>
+                  <RecentBranch>
+                    <option name="branchName" value="master" />
+                    <option name="lastUsedInstant" value="1706191242" />
                   </RecentBranch>
                   <RecentBranch>
                     <option name="branchName" value="main" />
@@ -81,10 +99,14 @@
   </component>
   <component name="PropertiesComponent"><![CDATA[{
   "keyToString": {
+    "JUnit.EventGroupTest.invokeTimeTask.executor": "Run",
+    "JUnit.EventGroupTest.test1.executor": "Run",
+    "JUnit.PromiseTest.test1.executor": "Run",
+    "JUnit.PromiseTest.test2.executor": "Run",
     "RunOnceActivity.OpenProjectViewOnStart": "true",
     "RunOnceActivity.ShowReadmeOnStart": "true",
     "SHARE_PROJECT_CONFIGURATION_FILES": "true",
-    "git-widget-placeholder": "main",
+    "git-widget-placeholder": "init",
     "jdk.selected.JAVA_MODULE": "corretto-1.8",
     "kotlin-language-version-configured": "true",
     "node.js.detected.package.eslint": "true",
@@ -97,6 +119,11 @@
     "project.structure.side.proportion": "0.26091954",
     "settings.editor.selected.configurable": "MavenSettings",
     "vue.rearranger.settings.migration": "true",
+    "应用程序.ChannelTestClient.executor": "Run",
+    "应用程序.EventGroupServerTest.executor": "Run",
+    "应用程序.EventGroupTestClient.executor": "Run",
+    "应用程序.HandlerClientTest.executor": "Run",
+    "应用程序.HandlerServerTest.executor": "Run",
     "应用程序.NettyHelloClient.executor": "Run",
     "应用程序.NettyHelloServer.executor": "Run"
   }
@@ -108,13 +135,52 @@
       </set>
     </option>
   </component>
-  <component name="RunManager" selected="应用程序.NettyHelloClient">
-    <configuration name="NettyHelloClient" type="Application" factoryName="Application" temporary="true" nameIsGenerated="true">
-      <option name="MAIN_CLASS_NAME" value="tool.zyk.hello.NettyHelloClient" />
+  <component name="RunManager" selected="应用程序.HandlerClientTest">
+    <configuration name="EventGroupServerTest" type="Application" factoryName="Application" temporary="true" nameIsGenerated="true">
+      <option name="MAIN_CLASS_NAME" value="tool.zyk.eventgroup.EventGroupServerTest" />
+      <module name="netty-server" />
+      <extension name="coverage">
+        <pattern>
+          <option name="PATTERN" value="tool.zyk.eventgroup.*" />
+          <option name="ENABLED" value="true" />
+        </pattern>
+      </extension>
+      <method v="2">
+        <option name="Make" enabled="true" />
+      </method>
+    </configuration>
+    <configuration name="EventGroupTestClient" type="Application" factoryName="Application" temporary="true" nameIsGenerated="true">
+      <option name="MAIN_CLASS_NAME" value="tool.zyk.eventgroup.EventGroupTestClient" />
+      <module name="netty-client" />
+      <extension name="coverage">
+        <pattern>
+          <option name="PATTERN" value="tool.zyk.eventgroup.*" />
+          <option name="ENABLED" value="true" />
+        </pattern>
+      </extension>
+      <method v="2">
+        <option name="Make" enabled="true" />
+      </method>
+    </configuration>
+    <configuration name="HandlerClientTest" type="Application" factoryName="Application" temporary="true" nameIsGenerated="true">
+      <option name="MAIN_CLASS_NAME" value="tool.zyk.handler_pipeline.HandlerClientTest" />
       <module name="netty-client" />
       <extension name="coverage">
         <pattern>
-          <option name="PATTERN" value="tool.zyk.hello.*" />
+          <option name="PATTERN" value="tool.zyk.handler_pipeline.*" />
+          <option name="ENABLED" value="true" />
+        </pattern>
+      </extension>
+      <method v="2">
+        <option name="Make" enabled="true" />
+      </method>
+    </configuration>
+    <configuration name="HandlerServerTest" type="Application" factoryName="Application" temporary="true" nameIsGenerated="true">
+      <option name="MAIN_CLASS_NAME" value="tool.zyk.handler_pipeline.HandlerServerTest" />
+      <module name="netty-server" />
+      <extension name="coverage">
+        <pattern>
+          <option name="PATTERN" value="tool.zyk.handler_pipeline.*" />
           <option name="ENABLED" value="true" />
         </pattern>
       </extension>
@@ -122,23 +188,29 @@
         <option name="Make" enabled="true" />
       </method>
     </configuration>
-    <configuration name="NettyHelloServer" type="Application" factoryName="Application" temporary="true" nameIsGenerated="true">
-      <option name="MAIN_CLASS_NAME" value="tool.zyk.hello.NettyHelloServer" />
+    <configuration name="PromiseTest.test2" type="JUnit" factoryName="JUnit" temporary="true" nameIsGenerated="true">
       <module name="netty-server" />
       <extension name="coverage">
         <pattern>
-          <option name="PATTERN" value="tool.zyk.hello.*" />
+          <option name="PATTERN" value="tool.zyk.promise.*" />
           <option name="ENABLED" value="true" />
         </pattern>
       </extension>
+      <option name="PACKAGE_NAME" value="tool.zyk.promise" />
+      <option name="MAIN_CLASS_NAME" value="tool.zyk.promise.PromiseTest" />
+      <option name="METHOD_NAME" value="test2" />
+      <option name="TEST_OBJECT" value="method" />
       <method v="2">
         <option name="Make" enabled="true" />
       </method>
     </configuration>
     <recent_temporary>
       <list>
-        <item itemvalue="应用程序.NettyHelloClient" />
-        <item itemvalue="应用程序.NettyHelloServer" />
+        <item itemvalue="应用程序.HandlerClientTest" />
+        <item itemvalue="应用程序.HandlerServerTest" />
+        <item itemvalue="应用程序.EventGroupTestClient" />
+        <item itemvalue="应用程序.EventGroupServerTest" />
+        <item itemvalue="JUnit.PromiseTest.test2" />
       </list>
     </recent_temporary>
   </component>
@@ -158,7 +230,7 @@
       <option name="number" value="Default" />
       <option name="presentableId" value="Default" />
       <updated>1706188747019</updated>
-      <workItem from="1706188748506" duration="2111000" />
+      <workItem from="1706188748506" duration="7204000" />
     </task>
     <task id="LOCAL-00001" summary="feature:init hello world初始化完成">
       <option name="closed" value="true" />
@@ -168,12 +240,39 @@
       <option name="project" value="LOCAL" />
       <updated>1706190216538</updated>
     </task>
-    <option name="localTasksCounter" value="2" />
+    <task id="LOCAL-00002" summary="feature:init hello world初始化完成">
+      <option name="closed" value="true" />
+      <created>1706191158591</created>
+      <option name="number" value="00002" />
+      <option name="presentableId" value="LOCAL-00002" />
+      <option name="project" value="LOCAL" />
+      <updated>1706191158591</updated>
+    </task>
+    <task id="LOCAL-00003" summary="feature:init hello world初始化完成">
+      <option name="closed" value="true" />
+      <created>1706191426158</created>
+      <option name="number" value="00003" />
+      <option name="presentableId" value="LOCAL-00003" />
+      <option name="project" value="LOCAL" />
+      <updated>1706191426158</updated>
+    </task>
+    <option name="localTasksCounter" value="4" />
     <servers />
   </component>
   <component name="TypeScriptGeneratedFilesManager">
     <option name="version" value="3" />
   </component>
+  <component name="Vcs.Log.Tabs.Properties">
+    <option name="TAB_STATES">
+      <map>
+        <entry key="MAIN">
+          <value>
+            <State />
+          </value>
+        </entry>
+      </map>
+    </option>
+  </component>
   <component name="VcsManagerConfiguration">
     <MESSAGE value="feature:init hello world初始化完成" />
     <option name="LAST_COMMIT_MESSAGE" value="feature:init hello world初始化完成" />
diff --git a/netty-client/pom.xml b/netty-client/pom.xml
index b23916e..e4d8b17 100644
--- a/netty-client/pom.xml
+++ b/netty-client/pom.xml
@@ -22,5 +22,13 @@
             <groupId>io.netty</groupId>
             <artifactId>netty-all</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-logging</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+        </dependency>
     </dependencies>
 </project>
\ No newline at end of file
diff --git a/netty-client/src/main/java/tool/zyk/channel/ChannelTestClient.java b/netty-client/src/main/java/tool/zyk/channel/ChannelTestClient.java
new file mode 100644
index 0000000..3efe59a
--- /dev/null
+++ b/netty-client/src/main/java/tool/zyk/channel/ChannelTestClient.java
@@ -0,0 +1,43 @@
+package tool.zyk.channel;
+
+import io.netty.bootstrap.Bootstrap;
+import io.netty.buffer.ByteBufAllocator;
+import io.netty.channel.Channel;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelFutureListener;
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.nio.NioSocketChannel;
+import io.netty.handler.logging.LogLevel;
+import io.netty.handler.logging.LoggingHandler;
+import lombok.extern.slf4j.Slf4j;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * author: zyk
+ * datetime: 2024/1/25 22:41
+ * describe:
+ */
+@Slf4j
+public class ChannelTestClient {
+    public static void main(String[] args) throws InterruptedException {
+        ChannelFuture channelFuture = new Bootstrap()
+                .group(new NioEventLoopGroup())
+                .channel(NioSocketChannel.class)
+                .handler(new ChannelInitializer<Channel>() {
+                    @Override
+                    protected void initChannel(Channel channel) throws Exception {
+                        System.out.println("init...");
+                        channel.pipeline().addLast(new LoggingHandler(LogLevel.DEBUG));
+                    }
+                })
+                .connect("127.0.0.1", 8081);
+        log.warn("channel:{}", channelFuture.channel());
+        channelFuture.addListener((ChannelFutureListener) future -> log.warn("channel in listener:{}", future.channel()));
+//        channelFuture.sync();
+//        log.warn("channel:{}",channelFuture.channel());
+
+
+    }
+}
diff --git a/netty-client/src/main/java/tool/zyk/eventgroup/EventGroupTestClient.java b/netty-client/src/main/java/tool/zyk/eventgroup/EventGroupTestClient.java
new file mode 100644
index 0000000..2a65335
--- /dev/null
+++ b/netty-client/src/main/java/tool/zyk/eventgroup/EventGroupTestClient.java
@@ -0,0 +1,44 @@
+package tool.zyk.eventgroup;
+
+import io.netty.bootstrap.Bootstrap;
+import io.netty.buffer.ByteBufAllocator;
+import io.netty.channel.Channel;
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.nio.NioSocketChannel;
+import io.netty.handler.codec.string.StringEncoder;
+import io.netty.handler.logging.LogLevel;
+import io.netty.handler.logging.LoggingHandler;
+import lombok.extern.slf4j.Slf4j;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * author: zyk
+ * datetime: 2024/1/25 22:15
+ * describe:
+ */
+@Slf4j
+public class EventGroupTestClient {
+    public static void main(String[] args) throws InterruptedException {
+        Channel channel = new Bootstrap()
+                .group(new NioEventLoopGroup())
+                .channel(NioSocketChannel.class)
+                .handler(new ChannelInitializer<Channel>() {
+                    @Override
+                    protected void initChannel(Channel channel) throws Exception {
+                        System.out.println("init...");
+                        channel.pipeline().addLast(new LoggingHandler(LogLevel.DEBUG));
+                    }
+                })
+                .connect("127.0.0.1", 8081)
+                .sync()
+                .channel();
+        channel.writeAndFlush(ByteBufAllocator.DEFAULT.buffer().writeBytes("zhangyongkang".getBytes()));
+        TimeUnit.SECONDS.sleep(2);
+        channel.writeAndFlush(ByteBufAllocator.DEFAULT.buffer().writeBytes("zhangyongkang".getBytes()));
+
+    }
+}
diff --git a/netty-client/src/main/java/tool/zyk/handler_pipeline/HandlerClientTest.java b/netty-client/src/main/java/tool/zyk/handler_pipeline/HandlerClientTest.java
new file mode 100644
index 0000000..2d5d525
--- /dev/null
+++ b/netty-client/src/main/java/tool/zyk/handler_pipeline/HandlerClientTest.java
@@ -0,0 +1,44 @@
+package tool.zyk.handler_pipeline;
+
+import io.netty.bootstrap.Bootstrap;
+import io.netty.buffer.ByteBufAllocator;
+import io.netty.channel.Channel;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelFutureListener;
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.nio.NioSocketChannel;
+import io.netty.handler.codec.string.StringEncoder;
+import io.netty.handler.logging.LogLevel;
+import io.netty.handler.logging.LoggingHandler;
+import lombok.extern.slf4j.Slf4j;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * author: zyk
+ * datetime: 2024/1/25 22:59
+ * describe:
+ */
+@Slf4j
+public class HandlerClientTest {
+    public static void main(String[] args) throws InterruptedException {
+        ChannelFuture channelFuture = new Bootstrap()
+                .group(new NioEventLoopGroup())
+                .channel(NioSocketChannel.class)
+                .handler(new ChannelInitializer<Channel>() {
+                    @Override
+                    protected void initChannel(Channel channel) throws Exception {
+                        System.out.println("init...");
+                        channel.pipeline().addLast(new LoggingHandler(LogLevel.DEBUG));
+                        channel.pipeline().addLast(new StringEncoder());
+                    }
+                })
+                .connect("127.0.0.1", 8082);
+        channelFuture.addListener((ChannelFutureListener) future -> {
+            Channel channel = future.channel();
+            log.info("channel:{}",channel);
+            channel.writeAndFlush("hello world");
+        });
+    }
+}
diff --git a/netty-server/pom.xml b/netty-server/pom.xml
index 7cd5402..4e99484 100644
--- a/netty-server/pom.xml
+++ b/netty-server/pom.xml
@@ -30,5 +30,14 @@
             <groupId>org.projectlombok</groupId>
             <artifactId>lombok</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-api</artifactId>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
 </project>
\ No newline at end of file
diff --git a/netty-server/src/main/java/tool/zyk/eventgroup/EventGroupServerTest.java b/netty-server/src/main/java/tool/zyk/eventgroup/EventGroupServerTest.java
new file mode 100644
index 0000000..8207a8a
--- /dev/null
+++ b/netty-server/src/main/java/tool/zyk/eventgroup/EventGroupServerTest.java
@@ -0,0 +1,53 @@
+package tool.zyk.eventgroup;
+
+import io.netty.bootstrap.ServerBootstrap;
+import io.netty.buffer.ByteBuf;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelInboundHandlerAdapter;
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.DefaultEventLoopGroup;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.nio.NioServerSocketChannel;
+import io.netty.channel.socket.nio.NioSocketChannel;
+import io.netty.handler.logging.LogLevel;
+import io.netty.handler.logging.LoggingHandler;
+import lombok.extern.slf4j.Slf4j;
+
+import java.util.Optional;
+
+/**
+ * author: zyk
+ * datetime: 2024/1/25 22:14
+ * describe:
+ */
+@Slf4j
+public class EventGroupServerTest {
+    public static void main(String[] args) {
+        DefaultEventLoopGroup normalWorkers=new DefaultEventLoopGroup(2);
+        new ServerBootstrap()
+                .group(new NioEventLoopGroup(1), new NioEventLoopGroup(2))
+                .channel(NioServerSocketChannel.class)
+                .childHandler(new ChannelInitializer<NioSocketChannel>() {
+                    @Override
+                    protected void initChannel(NioSocketChannel nioSocketChannel) throws Exception {
+                        nioSocketChannel.pipeline().addLast(new LoggingHandler(LogLevel.DEBUG));
+                        nioSocketChannel.pipeline().addLast(normalWorkers,"myHandler",
+                                new ChannelInboundHandlerAdapter() {
+                                    @Override
+                                    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+                                        System.out.println(msg);
+                                        ByteBuf byteBuf = msg instanceof ByteBuf ? (ByteBuf) msg : null;
+                                        Optional.ofNullable(byteBuf).ifPresent(byt -> {
+                                            byte[] buf = new byte[16];
+                                            ByteBuf len = byt.readBytes(buf, 0, byt.readableBytes());
+                                            log.info("传来的数据：{}", new String(buf));
+                                        });
+                                    }
+                                }
+                        );
+
+                    }
+                })
+                .bind(8081);
+    }
+}
diff --git a/netty-server/src/main/java/tool/zyk/handler_pipeline/HandlerServerTest.java b/netty-server/src/main/java/tool/zyk/handler_pipeline/HandlerServerTest.java
new file mode 100644
index 0000000..b05c94a
--- /dev/null
+++ b/netty-server/src/main/java/tool/zyk/handler_pipeline/HandlerServerTest.java
@@ -0,0 +1,75 @@
+package tool.zyk.handler_pipeline;
+
+import io.netty.bootstrap.ServerBootstrap;
+import io.netty.channel.*;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.nio.NioServerSocketChannel;
+import io.netty.channel.socket.nio.NioSocketChannel;
+import lombok.extern.slf4j.Slf4j;
+
+/**
+ * author: zyk
+ * datetime: 2024/1/25 23:00
+ * describe:
+ */
+@Slf4j
+public class HandlerServerTest {
+    public static void main(String[] args) {
+        new ServerBootstrap()
+                .channel(NioServerSocketChannel.class)
+                .group(new NioEventLoopGroup())
+                .childHandler(new ChannelInitializer<NioSocketChannel>() {
+                    @Override
+                    protected void initChannel(NioSocketChannel ch) throws Exception {
+                        log.info("channel 进来了");
+                        ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {
+                            @Override
+                            public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+                                log.info("invoke 1");
+                                super.channelRead(ctx, msg);
+                            }
+                        });
+                        ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {
+                            @Override
+                            public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+                                log.info("invoke 2");
+                                ctx.channel().write(msg);
+//                                super.channelRead(ctx, msg);
+                            }
+                        });
+                        ch.pipeline().addLast(new ChannelInboundHandlerAdapter() {
+                            @Override
+                            public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+                                log.info("invoke 3");
+                                super.channelRead(ctx, msg);
+//                                ctx.channel().write(msg);
+                            }
+                        });
+
+                        ch.pipeline().addLast(new ChannelOutboundHandlerAdapter() {
+                            @Override
+                            public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
+                                log.info("outbound 4");
+                                super.write(ctx, msg, promise);
+                            }
+                        });
+                        ch.pipeline().addLast(new ChannelOutboundHandlerAdapter() {
+                            @Override
+                            public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
+                                log.info("outbound 5");
+                                super.write(ctx, msg, promise);
+                            }
+                        });
+                        ch.pipeline().addLast(new ChannelOutboundHandlerAdapter() {
+                            @Override
+                            public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
+                                log.info("outbound 6");
+                                super.write(ctx, msg, promise);
+                            }
+                        });
+
+                    }
+                })
+                .bind(8082);
+    }
+}
diff --git a/netty-server/src/test/java/tool/zyk/eventgroup/EventGroupTest.java b/netty-server/src/test/java/tool/zyk/eventgroup/EventGroupTest.java
new file mode 100644
index 0000000..0e09cc2
--- /dev/null
+++ b/netty-server/src/test/java/tool/zyk/eventgroup/EventGroupTest.java
@@ -0,0 +1,42 @@
+package tool.zyk.eventgroup;
+
+import io.netty.channel.nio.NioEventLoopGroup;
+import lombok.extern.slf4j.Slf4j;
+import org.junit.jupiter.api.Test;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * author: zyk
+ * datetime: 2024/1/25 22:30
+ * describe:
+ */
+@Slf4j
+public class EventGroupTest {
+
+    //处理普通任务
+    @Test
+    public void test1() throws InterruptedException {
+        NioEventLoopGroup eventExecutors = new NioEventLoopGroup(2);
+        log.debug("server start");
+        TimeUnit.SECONDS.sleep(2);
+        eventExecutors.execute(() -> {
+            log.debug("working ~");
+        });
+        eventExecutors.execute(() -> {
+            log.debug("working ~");
+        });
+        eventExecutors.execute(() -> {
+            log.debug("working ~");
+        });
+    }
+
+    //处理定时任务
+    @Test
+    public void invokeTimeTask() {
+        NioEventLoopGroup eventExecutors = new NioEventLoopGroup(2);
+        eventExecutors.scheduleAtFixedRate(() -> log.info("执行定时任务~"),
+                0, 1, TimeUnit.SECONDS);
+
+    }
+}
diff --git a/netty-server/src/test/java/tool/zyk/promise/PromiseTest.java b/netty-server/src/test/java/tool/zyk/promise/PromiseTest.java
new file mode 100644
index 0000000..09fc1e8
--- /dev/null
+++ b/netty-server/src/test/java/tool/zyk/promise/PromiseTest.java
@@ -0,0 +1,72 @@
+package tool.zyk.promise;
+
+import io.netty.channel.DefaultEventLoop;
+import io.netty.util.concurrent.DefaultPromise;
+import lombok.extern.slf4j.Slf4j;
+import org.junit.jupiter.api.Test;
+
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * author: zyk
+ * datetime: 2024/1/25 22:48
+ * describe:
+ */
+@Slf4j
+public class PromiseTest {
+
+    @Test//同步处理任务
+    public void test1() throws ExecutionException, InterruptedException {
+        DefaultEventLoop eventExecutors = new DefaultEventLoop();
+        DefaultPromise<Integer> promise = new DefaultPromise<>(eventExecutors);
+
+        eventExecutors.execute(()->{
+            try {
+                TimeUnit.SECONDS.sleep(2);
+            } catch (InterruptedException e) {
+                throw new RuntimeException(e);
+            }
+            log.debug("success :{}",10);
+            promise.setSuccess(10);
+        });
+        eventExecutors.execute(()->{
+            try {
+                TimeUnit.SECONDS.sleep(1);
+            } catch (InterruptedException e) {
+                throw new RuntimeException(e);
+            }
+            log.debug("success :{}",20);
+            promise.setSuccess(20);
+        });
+
+        log.debug("start...");
+        log.debug("getNow:{}",promise.getNow());
+        log.debug("getBlock:{}",promise.get());//阻塞
+
+    }
+
+    @Test//异步处理任务
+    public void test2() throws InterruptedException {
+        DefaultEventLoop eventExecutors = new DefaultEventLoop();
+        DefaultPromise<Integer> promise = new DefaultPromise<>(eventExecutors);
+
+        promise.addListener(future -> {//成功之后的回掉
+            log.debug("getNow:{}",future.getNow());
+        });
+
+        eventExecutors.execute(()->{
+            try {
+                TimeUnit.SECONDS.sleep(2);
+            } catch (InterruptedException e) {
+                throw new RuntimeException(e);
+            }
+            log.debug("success :{}",10);
+            promise.setSuccess(10);
+        });
+
+
+        log.debug("start..");
+        TimeUnit.SECONDS.sleep(10);
+    }
+}
diff --git a/pom.xml b/pom.xml
index 82098ec..4f9bdee 100644
--- a/pom.xml
+++ b/pom.xml
@@ -24,6 +24,7 @@
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <netty-all.version>4.1.39.Final</netty-all.version>
         <lombok.version>1.18.30</lombok.version>
+        <junit-api.version>5.7.0</junit-api.version>
     </properties>
     <dependencyManagement>
         <dependencies>
@@ -37,6 +38,15 @@
                 <artifactId>lombok</artifactId>
                 <version>${lombok.version}</version>
             </dependency>
+            <!-- https://mvnrepository.com/artifact/org.junit.jupiter/junit-jupiter-api -->
+            <!-- https://mvnrepository.com/artifact/org.junit.jupiter/junit-jupiter-api -->
+            <dependency>
+                <groupId>org.junit.jupiter</groupId>
+                <artifactId>junit-jupiter-api</artifactId>
+                <version>${junit-api.version}</version>
+                <scope>test</scope>
+            </dependency>
+
         </dependencies>
     </dependencyManagement>
 
-- 
Gitee