import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
public class NettyTomcat {
public static void main(String[] args) {
EventLoopGroup bossGroup = new NioEventLoopGroup();
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
ServerBootstrap b = new ServerBootstrap();
b.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class)
.childHandler(new ChannelInitializer<SocketChannel>() {
@Override
public void initChannel(SocketChannel ch) throws Exception {
ChannelPipeline p = ch.pipeline();
p.addLast(new ChannelInboundHandlerAdapter() {
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) {
// 接收到消息时的处理逻辑
ByteBuf in = (ByteBuf) msg;
System.out.println("Received data: " + in.toString(io.netty.util.CharsetUtil.UTF_8));
}
});
}
});
// 启动服务器并绑定到指定的端口
ChannelFuture f = b.bind(8080).sync();
// 等待服务器关闭
f.channel().closeFuture().sync();
} catch (Exception e) {
e.printStackTrace();
} finally {
// 关闭事件循环组
bossGroup.shutdownGracefully();
workerGroup.shutdownGracefully();
}
}
}这段代码使用Netty实现了一个简单的服务器，它监听8080端口，并将接收到的数据转换为字符串打印到控制台。这个例子展示了如何使用Netty快速地搭建一个网络应用程序的骨架，并且如何处理网络事件。