byte协议服务端

CPU-Code · CPU-Code · commit 78357195c238 · 2021-08-19T15:21:10.000+08:00
diff --git a/netty/netty-first/src/main/java/com/cpucode/netty/customize/protocol/server/Server.java b/netty/netty-first/src/main/java/com/cpucode/netty/customize/protocol/server/Server.java
@@ -0,0 +1,67 @@
+package com.cpucode.netty.customize.protocol.server;
+
+import com.cpucode.netty.customize.protocol.SmartCarDecoder;
+import com.cpucode.netty.customize.protocol.SmartCarEncoder;
+import io.netty.bootstrap.ServerBootstrap;
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.ChannelInitializer;
+import io.netty.channel.ChannelOption;
+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;
+
+/**
+ * @author : cpucode
+ * @date : 2021/8/19 13:10
+ * @github : https://github.com/CPU-Code
+ * @csdn : https://blog.csdn.net/qq_44226094
+ */
+public class Server {
+    public Server() {
+    }
+
+    public void bind(int port) throws Exception {
+        // 配置NIO线程组
+        EventLoopGroup bossGroup = new NioEventLoopGroup();
+        EventLoopGroup workerGroup = new NioEventLoopGroup();
+        try {
+            // 服务器辅助启动类配置
+            ServerBootstrap b = new ServerBootstrap();
+            b.group(bossGroup, workerGroup)
+                    .channel(NioServerSocketChannel.class)
+                    .handler(new LoggingHandler(LogLevel.INFO))
+                    .childHandler(new ChildChannelHandler())//
+                    .option(ChannelOption.SO_BACKLOG, 1024) // 设置tcp缓冲区 // (5)
+                    .childOption(ChannelOption.SO_KEEPALIVE, true); // (6)
+            // 绑定端口 同步等待绑定成功
+            ChannelFuture f = b.bind(port).sync(); // (7)
+            // 等到服务端监听端口关闭
+            f.channel().closeFuture().sync();
+        } finally {
+            // 优雅释放线程资源
+            workerGroup.shutdownGracefully();
+            bossGroup.shutdownGracefully();
+        }
+    }
+
+    /**
+     * 网络事件处理器
+     */
+    private class ChildChannelHandler extends ChannelInitializer<SocketChannel> {
+        @Override
+        protected void initChannel(SocketChannel ch) throws Exception {
+            // 添加自定义协议的编解码工具
+            ch.pipeline().addLast(new SmartCarEncoder());
+            ch.pipeline().addLast(new SmartCarDecoder());
+            // 处理网络IO
+            ch.pipeline().addLast(new ServerHandler());
+        }
+    }
+
+    public static void main(String[] args) throws Exception {
+        new Server().bind(9999);
+    }
+}
diff --git a/netty/netty-first/src/main/java/com/cpucode/netty/customize/protocol/server/ServerHandler.java b/netty/netty-first/src/main/java/com/cpucode/netty/customize/protocol/server/ServerHandler.java
@@ -0,0 +1,39 @@
+package com.cpucode.netty.customize.protocol.server;
+
+import com.cpucode.netty.customize.protocol.SmartCarProtocol;
+import io.netty.channel.ChannelHandlerAdapter;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.SimpleChannelInboundHandler;
+
+/**
+ * @author : cpucode
+ * @date : 2021/8/19 13:11
+ * @github : https://github.com/CPU-Code
+ * @csdn : https://blog.csdn.net/qq_44226094
+ */
+public class ServerHandler extends SimpleChannelInboundHandler<SmartCarProtocol> {
+
+    @Override
+    protected void channelRead0(ChannelHandlerContext channelHandlerContext,
+                                SmartCarProtocol smartCarProtocol) throws Exception {
+
+        System.out.println("Server接受的客户端的信息 :" + smartCarProtocol.toString());
+
+        // 会写数据给客户端
+        String str = "Hi I am Server ...";
+        SmartCarProtocol response = new SmartCarProtocol(str.getBytes().length, str.getBytes());
+        // 当服务端完成写操作后，关闭与客户端的连接
+        channelHandlerContext.writeAndFlush(response);
+        // .addListener(ChannelFutureListener.CLOSE);
+
+        // 当有写操作时，不需要手动释放msg的引用
+        // 当只有读操作时，才需要手动释放msg的引用
+    }
+
+    @Override
+    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause)
+            throws Exception {
+        // cause.printStackTrace();
+        ctx.close();
+    }
+}
