From f0ff7a82f1fff7b9217f0c5c85c153bc00682e0b Mon Sep 17 00:00:00 2001
From: Bunny <1319900154@qq.com>
Date: Thu, 23 May 2024 22:27:15 +0800
Subject: [PATCH] =?UTF-8?q?feat(=E6=96=B0=E5=A2=9E):=20:rocket:=20netty?=
 =?UTF-8?q?=E5=BC=80=E5=A7=8B=E7=9A=84=E5=AE=A2=E6=88=B7=E7=AB=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/netty/demo1/StartClient01.java    | 36 +++++++++++++++++++
 .../StartServer01.java}                       |  7 ++--
 2 files changed, 41 insertions(+), 2 deletions(-)
 create mode 100644 netty/service/src/main/java/cn/bunny/service/netty/demo1/StartClient01.java
 rename netty/service/src/main/java/cn/bunny/service/netty/{Start01.java => demo1/StartServer01.java} (94%)

diff --git a/netty/service/src/main/java/cn/bunny/service/netty/demo1/StartClient01.java b/netty/service/src/main/java/cn/bunny/service/netty/demo1/StartClient01.java
new file mode 100644
index 0000000..f1dc2ab
--- /dev/null
+++ b/netty/service/src/main/java/cn/bunny/service/netty/demo1/StartClient01.java
@@ -0,0 +1,36 @@
+package cn.bunny.service.netty.demo1;
+
+import io.netty.bootstrap.Bootstrap;
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.nio.NioServerSocketChannel;
+import io.netty.channel.socket.nio.NioSocketChannel;
+import io.netty.handler.codec.string.StringDecoder;
+
+import java.net.InetSocketAddress;
+
+public class StartClient01 {
+    /*
+    客户端处理内容
+     */
+    public static void main(String[] args) throws InterruptedException {
+        // 启动类
+        new Bootstrap()
+                // 添加 事件循环
+                .group(new NioEventLoopGroup())
+                // 选择客户端 channel 实现
+                .channel(NioServerSocketChannel.class)
+                // 添加处理器
+                .handler(new ChannelInitializer<NioSocketChannel>() {
+                    // 连接后被调用
+                    @Override
+                    protected void initChannel(NioSocketChannel nioSocketChannel) throws Exception {
+                        nioSocketChannel.pipeline().addLast(new StringDecoder());
+                    }
+                })
+                .connect(new InetSocketAddress("localhost", 8080))
+                .sync()
+                .channel()
+                .writeAndFlush("你好啊啊啊");
+    }
+}
diff --git a/netty/service/src/main/java/cn/bunny/service/netty/Start01.java b/netty/service/src/main/java/cn/bunny/service/netty/demo1/StartServer01.java
similarity index 94%
rename from netty/service/src/main/java/cn/bunny/service/netty/Start01.java
rename to netty/service/src/main/java/cn/bunny/service/netty/demo1/StartServer01.java
index 165169c..947e6af 100644
--- a/netty/service/src/main/java/cn/bunny/service/netty/Start01.java
+++ b/netty/service/src/main/java/cn/bunny/service/netty/demo1/StartServer01.java
@@ -1,4 +1,4 @@
-package cn.bunny.service.netty;
+package cn.bunny.service.netty.demo1;
 
 import io.netty.bootstrap.ServerBootstrap;
 import io.netty.channel.ChannelHandlerContext;
@@ -11,7 +11,10 @@ import io.netty.handler.codec.string.StringDecoder;
 
 import static java.lang.StringTemplate.STR;
 
-public class Start01 {
+public class StartServer01 {
+    /*
+        服务器端处理内容
+     */
     public static void main(String[] args) {
         // 启动器
         new ServerBootstrap()