fix:bytebuf数据合并

src/main/java/com/kwan/shuyu/heima/netty_07_bytebuf/ByteBuf_11.java

+package com.kwan.shuyu.heima.netty_07_bytebuf;
+
+import io.netty.buffer.*;
+import lombok.extern.slf4j.Slf4j;
+
+/**
+ * ByteBuf使用Unpooled方式合并
+ *
+ * @author : qinyingjie
+ * @version : 2.2.0
+ * @date : 2023/4/27 09:34
+ */
+@Slf4j
+public class ByteBuf_11 {
+
+    public static void main(String[] args) {
+        ByteBuf buf1 = ByteBufAllocator.DEFAULT.buffer(5);
+        buf1.writeBytes(new byte[]{1, 2, 3, 4, 5});
+        ByteBuf buf2 = ByteBufAllocator.DEFAULT.buffer(5);
+        buf2.writeBytes(new byte[]{6, 7, 8, 9, 10});
+        System.out.println(ByteBufUtil.prettyHexDump(buf1));
+        System.out.println(ByteBufUtil.prettyHexDump(buf2));
+        // 当包装 ByteBuf 个数超过一个时, 底层使用了 CompositeByteBuf
+        ByteBuf buf3 = Unpooled.wrappedBuffer(buf1, buf2);
+        System.out.println(ByteBufUtil.prettyHexDump(buf3));
+
+        /**
+         * +-------------------------------------------------+
+         *          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
+         * +--------+-------------------------------------------------+----------------+
+         * |00000000| 01 02 03 04 05                                  |.....           |
+         * +--------+-------------------------------------------------+----------------+
+         *          +-------------------------------------------------+
+         *          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
+         * +--------+-------------------------------------------------+----------------+
+         * |00000000| 06 07 08 09 0a                                  |.....           |
+         * +--------+-------------------------------------------------+----------------+
+         *          +-------------------------------------------------+
+         *          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
+         * +--------+-------------------------------------------------+----------------+
+         * |00000000| 01 02 03 04 05 06 07 08 09 0a                   |..........      |
+         * +--------+-------------------------------------------------+----------------+
+         */
+        ByteBuf buf4 = Unpooled.wrappedBuffer(new byte[]{1, 2, 3}, new byte[]{4, 5, 6});
+        System.out.println(buf4.getClass());
+        System.out.println(ByteBufUtil.prettyHexDump(buf4));
+        /**
+         * class io.netty.buffer.CompositeByteBuf
+         *          +-------------------------------------------------+
+         *          |  0  1  2  3  4  5  6  7  8  9  a  b  c  d  e  f |
+         * +--------+-------------------------------------------------+----------------+
+         * |00000000| 01 02 03 04 05 06                               |......          |
+         * +--------+-------------------------------------------------+----------------+
+         */
+    }
+}

src/main/java/com/kwan/shuyu/heima/netty_08_socket/TestClient.java

+package com.kwan.shuyu.heima.netty_08_socket;
+
+import java.io.*;
+import java.net.Socket;
+
+
+/**
+ * 客户端读写
+ *
+ * @author : qinyingjie
+ * @version : 2.2.0
+ * @date : 2023/4/27 16:58
+ */
+public class TestClient {
+    public static void main(String[] args) throws IOException {
+        Socket s = new Socket("localhost", 8888);
+
+        new Thread(() -> {
+            try {
+                BufferedReader reader = new BufferedReader(new InputStreamReader(s.getInputStream()));
+                while (true) {
+                    System.out.println(reader.readLine());
+                }
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }).start();
+
+        new Thread(() -> {
+            try {
+                BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
+                for (int i = 0; i < 100; i++) {
+                    writer.write(String.valueOf(i));
+                    writer.newLine();
+                    writer.flush();
+                }
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }).start();
+    }
+}
+

src/main/java/com/kwan/shuyu/heima/netty_08_socket/TestServer.java

+package com.kwan.shuyu.heima.netty_08_socket;
+
+import java.io.*;
+import java.net.ServerSocket;
+import java.net.Socket;
+
+
+/**
+ * 服务端读写
+ *
+ * @author : qinyingjie
+ * @version : 2.2.0
+ * @date : 2023/4/27 16:58
+ */
+public class TestServer {
+    public static void main(String[] args) throws IOException {
+        ServerSocket ss = new ServerSocket(8888);
+        Socket s = ss.accept();
+
+        new Thread(() -> {
+            try {
+                BufferedReader reader = new BufferedReader(new InputStreamReader(s.getInputStream()));
+                while (true) {
+                    System.out.println(reader.readLine());
+                }
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }).start();
+
+        new Thread(() -> {
+            try {
+                BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
+                // 例如在这个位置加入 thread 级别断点，可以发现即使不写入数据，也不妨碍前面线程读取客户端数据
+                for (int i = 0; i < 100; i++) {
+                    writer.write(String.valueOf(i));
+                    writer.newLine();
+                    writer.flush();
+                }
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }).start();
+    }
+}
+