From 2b54588dbf606e0267c8d251082569186637eb0f Mon Sep 17 00:00:00 2001 From: Bunny <1319900154@qq.com> Date: Thu, 23 May 2024 23:01:51 +0800 Subject: [PATCH] =?UTF-8?q?feat(=E6=96=B0=E5=A2=9E):=20:rocket:=20netty?= =?UTF-8?q?=E7=9A=84=20NioEventLoopGroup=20=E7=9A=84=E5=AE=A2=E6=88=B7?= =?UTF-8?q?=E7=AB=AF=E5=92=8C=E6=9C=8D=E5=8A=A1=E7=AB=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../netty/demo2/EventLoopIoThreadServer.java | 34 +++++++++++++++++++ 1 file changed, 34 insertions(+) create mode 100644 netty/service/src/main/java/cn/bunny/service/netty/demo2/EventLoopIoThreadServer.java diff --git a/netty/service/src/main/java/cn/bunny/service/netty/demo2/EventLoopIoThreadServer.java b/netty/service/src/main/java/cn/bunny/service/netty/demo2/EventLoopIoThreadServer.java new file mode 100644 index 0000000..236cca9 --- /dev/null +++ b/netty/service/src/main/java/cn/bunny/service/netty/demo2/EventLoopIoThreadServer.java @@ -0,0 +1,34 @@ +package cn.bunny.service.netty.demo2; + +import io.netty.bootstrap.ServerBootstrap; +import io.netty.buffer.ByteBuf; +import io.netty.channel.ChannelHandlerContext; +import io.netty.channel.ChannelInboundHandlerAdapter; +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 lombok.extern.slf4j.Slf4j; + +import java.nio.charset.Charset; + +@Slf4j +public class EventLoopIoThreadServer { + public static void main(String[] args) { + new ServerBootstrap() + .group(new NioEventLoopGroup(), new NioEventLoopGroup(2)) + .channel(NioServerSocketChannel.class) + .childHandler(new ChannelInitializer() { + @Override + protected void initChannel(NioSocketChannel nioSocketChannel) throws Exception { + nioSocketChannel.pipeline().addLast(new ChannelInboundHandlerAdapter() { + @Override + public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { + ByteBuf buf = (ByteBuf) msg; + log.debug(buf.toString(Charset.defaultCharset())); + } + }); + } + }).bind(8080); + } +}