add netty tcp client to server logic in spring boot sample

Author: ipipman

springboot-netty-sample/pom.xml

@@ -5,17 +5,21 @@
     <parent>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-parent</artifactId>
-        <version>2.6.2</version>
+        <version>2.4.1</version>
         <relativePath/> <!-- lookup parent from repository -->
     </parent>
     <groupId>com.example</groupId>
     <artifactId>springboot-netty-sample</artifactId>
     <version>0.0.1-SNAPSHOT</version>
     <name>springboot-netty-sample</name>
     <description>Demo project for Spring Boot</description>
+
     <properties>
         <java.version>1.8</java.version>
+        <maven.version>1.8</maven.version>
     </properties>
+
+
     <dependencies>
         <dependency>
             <groupId>org.springframework.boot</groupId>
@@ -27,6 +31,13 @@
             <artifactId>spring-boot-starter-test</artifactId>
             <scope>test</scope>
         </dependency>
+
+        <!--   引入Netty依赖     -->
+        <dependency>
+            <groupId>io.netty</groupId>
+            <artifactId>netty-all</artifactId>
+            <version>4.1.39.Final</version>
+        </dependency>
     </dependencies>
 
     <build>

springboot-netty-sample/src/main/java/com/ipman/netty/springboot/sample/echo/EchoClient.java

@@ -0,0 +1,48 @@
+package com.ipman.netty.springboot.sample.echo;
+
+import io.netty.bootstrap.Bootstrap;
+import io.netty.channel.*;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioSocketChannel;
+import io.netty.handler.logging.LogLevel;
+import io.netty.handler.logging.LoggingHandler;
+
+/**
+ * Created by ipipman on 2022/1/19.
+ *
+ * @version V1.0
+ * @Package com.ipman.netty.springboot.sample.echo
+ * @Description: (用一句话描述该文件做什么)
+ * @date 2022/1/19 9:26 下午
+ */
+public class EchoClient {
+
+    public static void main(String[] args) {
+        EventLoopGroup group = new NioEventLoopGroup();
+        EchoClientHandler clientHandler = new EchoClientHandler();
+        try {
+            Bootstrap b = new Bootstrap();
+            b.group(group)
+                    .channel(NioSocketChannel.class)
+                    .option(ChannelOption.TCP_NODELAY, true)
+                    .handler(new ChannelInitializer<SocketChannel>() {
+                        @Override
+                        public void initChannel(SocketChannel ch) throws Exception {
+                            ChannelPipeline p = ch.pipeline();
+                            p.addLast(new LoggingHandler(LogLevel.INFO));
+                            p.addLast(clientHandler);
+                        }
+                    });
+            // 连接server端
+            ChannelFuture cf = b.connect("127.0.0.1", 8090).sync();
+            // 等待连接关闭
+            cf.channel().closeFuture().sync();
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            group.shutdownGracefully();
+        }
+
+    }
+}

springboot-netty-sample/src/main/java/com/ipman/netty/springboot/sample/echo/EchoClientHandler.java

@@ -0,0 +1,78 @@
+package com.ipman.netty.springboot.sample.echo;
+
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.ChannelHandler.Sharable;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelInboundHandlerAdapter;
+
+import java.nio.charset.StandardCharsets;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * Created by ipipman on 2022/1/19.
+ *
+ * @version V1.0
+ * @Package com.ipman.netty.springboot.sample.echo
+ * @Description: (用一句话描述该文件做什么)
+ * @date 2022/1/19 9:26 下午
+ */
+@Sharable
+public class EchoClientHandler extends ChannelInboundHandlerAdapter {
+
+    private final ByteBuf firstMsg;
+
+    public EchoClientHandler() {
+        firstMsg = Unpooled.wrappedBuffer("Hello Codeing".getBytes(StandardCharsets.UTF_8));
+    }
+
+    /**
+     * 通道活跃时
+     *
+     * @param ctx
+     * @throws Exception
+     */
+    @Override
+    public void channelActive(ChannelHandlerContext ctx) throws Exception {
+        // 第一次传输
+        ctx.writeAndFlush(firstMsg);
+    }
+
+    /**
+     * 读取数据时
+     *
+     * @param ctx
+     * @param msg
+     * @throws Exception
+     */
+    @Override
+    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+        ctx.write(msg);
+    }
+
+    /**
+     * 读取完毕时
+     *
+     * @param ctx
+     * @throws Exception
+     */
+    @Override
+    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
+        // 延迟3秒
+        TimeUnit.SECONDS.sleep(3);
+        ctx.flush();
+    }
+
+    /**
+     * 捕获到异常时
+     *
+     * @param ctx
+     * @param cause
+     * @throws Exception
+     */
+    @Override
+    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+        cause.printStackTrace();
+        ctx.close();
+    }
+}

springboot-netty-sample/src/main/java/com/ipman/netty/springboot/sample/echo/EchoServer.java

@@ -0,0 +1,52 @@
+package com.ipman.netty.springboot.sample.echo;
+
+import io.netty.bootstrap.ServerBootstrap;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.ChannelPipeline;
+import io.netty.channel.EventLoopGroup;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioServerSocketChannel;
+import io.netty.handler.logging.LogLevel;
+import io.netty.handler.logging.LoggingHandler;
+
+/**
+ * Created by ipipman on 2022/1/19.
+ *
+ * @version V1.0
+ * @Package com.ipman.netty.springboot.sample.http
+ * @Description: (用一句话描述该文件做什么)
+ * @date 2022/1/19 9:09 下午
+ */
+public class EchoServer {
+
+    public static void main(String[] args) {
+        // 创建Server端
+        EventLoopGroup workGroup = new NioEventLoopGroup();
+        final EchoServerHandler serverHandler = new EchoServerHandler();
+        try {
+            ServerBootstrap b = new ServerBootstrap();
+            b.group(workGroup)
+                    .channel(NioServerSocketChannel.class)
+                    .handler(new LoggingHandler(LogLevel.INFO))
+                    .childHandler(new ChannelInitializer<SocketChannel>() {
+                        @Override
+                        public void initChannel(SocketChannel ch) throws Exception {
+                            ChannelPipeline p = ch.pipeline();
+                            p.addLast(new LoggingHandler(LogLevel.INFO));
+                            p.addLast(serverHandler);
+                        }
+                    });
+            // 绑定端口
+            ChannelFuture f = b.bind(8090).sync();
+            // 等待连接关闭
+            f.channel().closeFuture().sync();
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        } finally {
+            // 关闭所有线程
+            workGroup.shutdownGracefully();
+        }
+    }
+}

springboot-netty-sample/src/main/java/com/ipman/netty/springboot/sample/echo/EchoServerHandler.java

@@ -0,0 +1,54 @@
+package com.ipman.netty.springboot.sample.echo;
+
+import io.netty.channel.ChannelHandler.Sharable;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelInboundHandlerAdapter;
+
+/**
+ * Created by ipipman on 2022/1/19.
+ *
+ * @version V1.0
+ * @Package com.ipman.netty.springboot.sample.http
+ * @Description: (用一句话描述该文件做什么)
+ * @date 2022/1/19 9:11 下午
+ */
+@Sharable
+public class EchoServerHandler extends ChannelInboundHandlerAdapter {
+
+
+    /**
+     * 读取
+     *
+     * @param ctx
+     * @param msg
+     * @throws Exception
+     */
+    @Override
+    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+        ctx.write(msg);
+    }
+
+    /**
+     * 读取完毕时
+     *
+     * @param ctx
+     * @throws Exception
+     */
+    @Override
+    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
+        ctx.flush();
+    }
+
+    /**
+     * 抓住异常
+     *
+     * @param ctx
+     * @param cause
+     * @throws Exception
+     */
+    @Override
+    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+        cause.printStackTrace();
+        ctx.close();
+    }
+}