From 897f6c094b1d3d7896d9c1f04bfd9af4d70360a8 Mon Sep 17 00:00:00 2001
From: bingor <bingor19890207@163.com>
Date: Fri, 11 Nov 2022 12:54:03 +0800
Subject: [PATCH] =?UTF-8?q?=E5=9D=A6=E5=85=8BNetty=E7=89=88?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../executionHistory/executionHistory.lock    | Bin 17 -> 17 bytes
 .gradle/6.3/fileHashes/fileHashes.lock        | Bin 17 -> 17 bytes
 .../buildOutputCleanup.lock                   | Bin 17 -> 17 bytes
 src/main/java/com/msb/model/ClientFrame.java  |  52 +++++++++++
 src/main/java/com/msb/socket/Server.java      |  82 ++++++++++++++++++
 5 files changed, 134 insertions(+)
 create mode 100644 src/main/java/com/msb/model/ClientFrame.java
 create mode 100644 src/main/java/com/msb/socket/Server.java

diff --git a/.gradle/6.3/executionHistory/executionHistory.lock b/.gradle/6.3/executionHistory/executionHistory.lock
index 5626c2caddf39604535665a8891e6bc10099c4f7..90343c79a65ea136d127f2b2e0f03d64f8112076 100644
GIT binary patch
literal 17
TcmZSXb<oaN+oSc70Rof&DC`4@

literal 17
ScmZSXb<oaN+oSc70SW*p$^&Qs

diff --git a/.gradle/6.3/fileHashes/fileHashes.lock b/.gradle/6.3/fileHashes/fileHashes.lock
index 50f70c747a8f55f60599686f84ea7d70d9695b46..c9c7ad31fc08a268e4148580e33774b4003811c3 100644
GIT binary patch
literal 17
UcmZQRaCugzet}*n0|cl805kRk0{{R3

literal 17
TcmZQRaCugzet}*n0~7!NGtUFu

diff --git a/.gradle/buildOutputCleanup/buildOutputCleanup.lock b/.gradle/buildOutputCleanup/buildOutputCleanup.lock
index 7fd316479b053b80899e2d483bc34d6a217833c4..8b24fb30a99d01da39d58d3f2b7f12cd3e8e0d68 100644
GIT binary patch
literal 17
TcmZSf@lvmt;bJAm00A}t9_9j}

literal 17
TcmZSf@lvmt;bJAm00F!J9=8H=

diff --git a/src/main/java/com/msb/model/ClientFrame.java b/src/main/java/com/msb/model/ClientFrame.java
new file mode 100644
index 0000000..4015d55
--- /dev/null
+++ b/src/main/java/com/msb/model/ClientFrame.java
@@ -0,0 +1,52 @@
+package com.msb.model;/**
+ * @Author bingor
+ * @Date 2022/11/10 15:55
+ * @Description: com.msb.model
+ * @Version: 1.0
+ */
+
+import java.awt.*;
+import java.awt.event.ActionEvent;
+import java.awt.event.ActionListener;
+import java.awt.event.WindowAdapter;
+import java.awt.event.WindowEvent;
+
+/**
+ *@ClassName ClientFrame
+ *@Description TODO
+ *@Author bingor
+ *@Date 2022/11/10 15:55
+ *@Version 3.0
+ */
+public class ClientFrame extends Frame {
+
+    public ClientFrame() {
+        TextArea ta = new TextArea();
+        TextField tf = new TextField();
+        this.setSize(600, 400);
+        this.add(ta, BorderLayout.CENTER);
+        this.add(tf, BorderLayout.SOUTH);
+        this.setVisible(true);
+        this.addWindowListener(new WindowAdapter() {
+            @Override
+            public void windowClosing(WindowEvent e) {
+                System.exit(1);
+            }
+        });
+
+        ta.setEditable(false);
+
+        tf.addActionListener(new ActionListener() {
+            @Override
+            public void actionPerformed(ActionEvent e) {
+                ta.setText(ta.getText() + tf.getText() + "\r\n");
+                tf.setText("");
+            }
+        });
+    }
+
+    public static void main(String[] args) {
+        new ClientFrame();
+    }
+
+}
diff --git a/src/main/java/com/msb/socket/Server.java b/src/main/java/com/msb/socket/Server.java
new file mode 100644
index 0000000..be7ef0e
--- /dev/null
+++ b/src/main/java/com/msb/socket/Server.java
@@ -0,0 +1,82 @@
+package com.msb.socket;/**
+ * @Author bingor
+ * @Date 2022/11/10 16:12
+ * @Description: com.msb.socket
+ * @Version: 1.0
+ */
+
+import io.netty.bootstrap.ServerBootstrap;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelInboundHandlerAdapter;
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.EventLoopGroup;
+import io.netty.channel.group.ChannelGroup;
+import io.netty.channel.group.DefaultChannelGroup;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioServerSocketChannel;
+import io.netty.util.concurrent.GlobalEventExecutor;
+
+/**
+ *@ClassName Server
+ *@Description TODO
+ *@Author bingor
+ *@Date 2022/11/10 16:12
+ *@Version 3.0
+ */
+public class Server {
+
+    private int port;
+
+    public Server(int port) {
+        this.port = port;
+    }
+
+    public void serverStart() {
+        EventLoopGroup bootGroup = new NioEventLoopGroup(1);
+        EventLoopGroup workGroup = new NioEventLoopGroup(3);
+        ServerBootstrap bootstrap = new ServerBootstrap();
+        bootstrap.group(bootGroup, workGroup)
+            .channel(NioServerSocketChannel.class)
+            .childHandler(new ChannelInitializer<SocketChannel>() {
+                @Override
+                protected void initChannel(SocketChannel socketChannel) throws Exception {
+                    socketChannel.pipeline().addLast(new Handler());
+                }
+            });
+
+        try {
+            bootstrap.bind(this.port).sync();
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        } finally {
+            bootGroup.shutdownGracefully();
+            workGroup.shutdownGracefully();
+        }
+    }
+
+    public static void main(String[] args) {
+        new Server(8888);
+    }
+
+}
+
+class Handler extends ChannelInboundHandlerAdapter {
+
+    private static ChannelGroup channelGroup = new DefaultChannelGroup(GlobalEventExecutor.INSTANCE);
+
+    @Override
+    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+//        super.channelRead(ctx, msg);
+        channelGroup.forEach(channel -> {
+
+        });
+    }
+
+    @Override
+    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+//        super.exceptionCaught(ctx, cause);
+        cause.printStackTrace();
+        ctx.close();
+    }
+}