diff --git a/netty/service/src/main/java/cn/bunny/service/netty/demo1/StartClient01.java b/netty/service/src/main/java/cn/bunny/service/netty/demo1/StartClient01.java new file mode 100644 index 0000000..f1dc2ab --- /dev/null +++ b/netty/service/src/main/java/cn/bunny/service/netty/demo1/StartClient01.java @@ -0,0 +1,36 @@ +package cn.bunny.service.netty.demo1; + +import io.netty.bootstrap.Bootstrap; +import io.netty.channel.ChannelInitializer; +import io.netty.channel.nio.NioEventLoopGroup; +import io.netty.channel.socket.nio.NioServerSocketChannel; +import io.netty.channel.socket.nio.NioSocketChannel; +import io.netty.handler.codec.string.StringDecoder; + +import java.net.InetSocketAddress; + +public class StartClient01 { + /* + 客户端处理内容 + */ + public static void main(String[] args) throws InterruptedException { + // 启动类 + new Bootstrap() + // 添加 事件循环 + .group(new NioEventLoopGroup()) + // 选择客户端 channel 实现 + .channel(NioServerSocketChannel.class) + // 添加处理器 + .handler(new ChannelInitializer() { + // 连接后被调用 + @Override + protected void initChannel(NioSocketChannel nioSocketChannel) throws Exception { + nioSocketChannel.pipeline().addLast(new StringDecoder()); + } + }) + .connect(new InetSocketAddress("localhost", 8080)) + .sync() + .channel() + .writeAndFlush("你好啊啊啊"); + } +} diff --git a/netty/service/src/main/java/cn/bunny/service/netty/Start01.java b/netty/service/src/main/java/cn/bunny/service/netty/demo1/StartServer01.java similarity index 94% rename from netty/service/src/main/java/cn/bunny/service/netty/Start01.java rename to netty/service/src/main/java/cn/bunny/service/netty/demo1/StartServer01.java index 165169c..947e6af 100644 --- a/netty/service/src/main/java/cn/bunny/service/netty/Start01.java +++ b/netty/service/src/main/java/cn/bunny/service/netty/demo1/StartServer01.java @@ -1,4 +1,4 @@ -package cn.bunny.service.netty; +package cn.bunny.service.netty.demo1; import io.netty.bootstrap.ServerBootstrap; import io.netty.channel.ChannelHandlerContext; @@ -11,7 +11,10 @@ import io.netty.handler.codec.string.StringDecoder; import static java.lang.StringTemplate.STR; -public class Start01 { +public class StartServer01 { + /* + 服务器端处理内容 + */ public static void main(String[] args) { // 启动器 new ServerBootstrap()