Add files via upload

Author: java-ml

NettyDome/NettyDome.iml

@@ -0,0 +1,2 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module type="JAVA_MODULE" version="4" />

NettyDome/pom.xml

@@ -0,0 +1,21 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>0</groupId>
+    <artifactId>1</artifactId>
+    <version>1.0-SNAPSHOT</version>
+    <dependencies>
+        <!-- https://mvnrepository.com/artifact/io.netty/netty-all -->
+        <dependency>
+            <groupId>io.netty</groupId>
+            <artifactId>netty-all</artifactId>
+            <version>4.1.42.Final</version>
+        </dependency>
+    </dependencies>
+
+
+
+</project>

NettyDome/src/main/java/cn/hebeuit/Client.java

@@ -0,0 +1,53 @@
+package cn.hebeuit;
+
+import io.netty.bootstrap.Bootstrap;
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+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.util.CharsetUtil;
+
+public class Client {
+    public static void main(String[] args) {
+        EventLoopGroup eventExecutors=new NioEventLoopGroup();
+        Bootstrap bootstrap=new Bootstrap();
+        bootstrap.group(eventExecutors)
+                .channel(NioSocketChannel.class)
+                .handler(new ChannelInitializer<SocketChannel>() {
+                    protected void initChannel(SocketChannel serverChannel) throws Exception {
+                        serverChannel.pipeline().addLast(
+                                new ChannelInboundHandlerAdapter(){
+                                    @Override
+                                    public void channelActive(ChannelHandlerContext ctx) throws Exception {
+                                        System.out.println(ctx);
+                                        ctx.writeAndFlush(Unpooled.copiedBuffer("hello", CharsetUtil.UTF_8));
+                                    }
+
+                                    @Override
+                                    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+                                        System.out.println("read:"+ctx);
+                                        ByteBuf buf=(ByteBuf)msg;
+                                        System.out.println(buf.toString(CharsetUtil.UTF_8));
+
+                                    }
+                                }
+                        );
+                    }
+                });
+        try {
+
+            ChannelFuture channelFuture= bootstrap.connect("127.0.0.1",6668).sync();
+            Thread.sleep(10000);
+            channelFuture.channel().writeAndFlush(Unpooled.copiedBuffer("hi", CharsetUtil.UTF_8));
+            channelFuture.channel().closeFuture().sync();
+        } catch (InterruptedException e) {
+            e.printStackTrace();
+        }finally {
+            eventExecutors.shutdownGracefully();
+
+        }
+
+    }
+}

NettyDome/src/main/java/cn/hebeuit/Server.java

@@ -0,0 +1,63 @@
+package cn.hebeuit;
+
+import io.netty.bootstrap.ServerBootstrap;
+import io.netty.buffer.ByteBuf;
+import io.netty.buffer.Unpooled;
+import io.netty.channel.*;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.socket.SocketChannel;
+import io.netty.channel.socket.nio.NioServerSocketChannel;
+import io.netty.util.CharsetUtil;
+
+
+public class Server {
+        public static void main(String[] args) {
+                var bossGroup=new NioEventLoopGroup();
+                EventLoopGroup workerGroup=new NioEventLoopGroup();
+                ServerBootstrap bootstrap=new ServerBootstrap();
+                bootstrap.group(bossGroup,workerGroup)
+                        .channel(NioServerSocketChannel.class)
+                        .option(ChannelOption.SO_BACKLOG,128)
+                        .childOption(ChannelOption.SO_KEEPALIVE,true)
+                        .childHandler(new ChannelInitializer<SocketChannel>() {
+                                @Override
+                                protected void initChannel(SocketChannel socketChannel) throws Exception {
+                                        socketChannel.pipeline().addLast(
+                                                new ChannelInboundHandlerAdapter(){
+                                                        @Override
+                                                        public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+                                                                System.out.println(ctx);
+                                                                ByteBuf buf=(ByteBuf)msg;
+                                                                String s = buf.toString(CharsetUtil.UTF_8);
+                                                                System.out.println(s);
+
+                                                                ctx.writeAndFlush(Unpooled.copiedBuffer(s,CharsetUtil.UTF_8));
+                                                        }
+
+                                                        @Override
+                                                        public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
+                                                                ctx.writeAndFlush(Unpooled.copiedBuffer("end",CharsetUtil.UTF_8));
+
+                                                        }
+
+                                                    @Override
+                                                    public void handlerRemoved(ChannelHandlerContext ctx) throws Exception {
+                                                        super.handlerRemoved(ctx);
+                                                        System.out.println("out :"+ctx);
+
+                                                    }
+                                                }
+                                        );
+                                }
+                        });
+                try {
+                        ChannelFuture cf=bootstrap.bind("127.0.0.1",6668).sync();
+                        cf.channel().closeFuture().sync();
+                } catch (Exception e) {
+                        e.printStackTrace();
+
+                }
+        }
+
+
+}