大家好,玩转我是开始老三,之前里,玩转我们讨论了Java的开始三种IO模型,提到了网络通信框架Netty,玩转它简化和优化了NIO的开始使用,这期,玩转我们正式开始走近Netty。
首先当然是NIO的使用,本身比较复杂,而且还存在一些问题。
除此之外,如果在项目的开发中,要实现稳定的网络通信,就得考虑网络的闪断、客户端的重复接入、客户端的安全认证、消息的编解码、半包读写……
所以,巧了,恰好有这么一个成熟稳定、性能强大、开箱即用的网络框架摆在我们面前,相比较Java NIO,Netty更加出色:
我们有什么理由拒绝这么一款优秀的网络通信框架呢?代码怎么写不是写喽!
Netty官方是这么定义Netty的:
Netty 是一个异步事件驱动的网络应用程序框架,用于快速开发可维护的高性能协议服务器和客户端。
组成图-来源官方
Netty 由 JBoss 社区开发维护的,它的社区相对比较活跃:
官方目前最新的版本是5.x,,但是很不幸,已经被社区放弃开发维护,属于废弃版本,最新的稳定版本是4.x 。
一般使用,推荐4.x,Netty 4.x对3.x不做兼容,我们后续的学习也基于Netty 4.x版本。
作为最流行的网络通信框架,大量的公司选择它作为底层网络通信框架,包括不限于:
使用Netty的公司
我们可能自己没有直接用过Netty,但其实熟悉的很多开源中间件,都用到了Netty,比如:
用到Netty的优秀产品非常多,大家感兴趣可以看看:https://netty.io/wiki/related-projects.html。
气氛衬托到这,不写个Demo也过不去,还是从"Hello World"开始,我们领略一下Netty的风采。
创建Maven项目
<dependency> <groupId>io.netty</groupId> <artifactId>netty-all</artifactId> <version>4.1.92.Final</version> </dependency>
/** * <p>Date: 2023/5/14 10:29</p> * <p>Author: fighter3</p> * <p>Description: Netty服务端Demo</p> */public class NettyServer{ // 服务器监听的端口号 private int port; public NettyServer(int port) { this.port = port; } /** * 启动Netty服务器 * @throws InterruptedException */ public void run() throws InterruptedException { // 创建boss线程组和worker线程组 // bossGroup 用于监听客户端的连接请求,将连接请求发送给 workerGroup 进行处理 NioEventLoopGroup bossGroup = new NioEventLoopGroup(); // workerGroup 用于处理客户端连接的数据读写 NioEventLoopGroup workerGroup = new NioEventLoopGroup(); try { // 创建 ServerBootstrap 对象,用于启动 Netty 服务器 ServerBootstrap serverBootstrap = new ServerBootstrap(); // 绑定线程池事件组 serverBootstrap.group(bossGroup, workerGroup) .channel(NioServerSocketChannel.class) // 通道初始化回调函数,在启动的时候可以自动调用 .childHandler(new ChannelInitializer<SocketChannel>() { @Override public void initChannel(SocketChannel ch) throws Exception { ChannelPipeline pipeline = ch.pipeline(); // 添加消息处理器 pipeline.addLast(new NettyServerHandler()); } }); // 绑定端口,开始接收客户端请求 ChannelFuture channelFuture = serverBootstrap.bind(port).sync(); System.out.println("Netty服务器监听端口:"+port); // 等待服务端监听端口关闭 channelFuture.channel().closeFuture().sync(); } finally { //释放线程组资源 bossGroup.shutdownGracefully(); workerGroup.shutdownGracefully(); } } public static void main(String[] args) throws InterruptedException { // 创建服务器对象,监听端口号为 8888 NettyServer server = new NettyServer(8888); System.out.println("============Netty服务器启动...============="); // 启动服务器 server.run(); System.out.println("============Netty服务器停止...============="); }}
/** * <p>Date: 2023/5/14 10:30</p> * <p>Author: fighter3</p> * <p>Description: Netty服务器消息处理器</p> */public class NettyServerHandler extends ChannelInboundHandlerAdapter { /** * 当客户端上线的时候会触发这个方法 * @param ctx * @throws Exception */ @Override public void channelActive(ChannelHandlerContext ctx) throws Exception { String message="你好,靓仔!"; ByteBuf hello = Unpooled.copiedBuffer(message, CharsetUtil.UTF_8); // 发送消息 ctx.writeAndFlush(hello); } /** *当 Channel 中有来自客户端的数据时就会触发这个方法 */ @Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { ByteBuf buf = (ByteBuf) msg; System.out.println("客户端发来的消息:" + buf.toString(CharsetUtil.UTF_8)); // 接收消息并打印输出 } /** * 当有异常时触发这个方法 */ @Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { cause.printStackTrace(); ctx.close(); }}
/** * <p>Date: 2023/5/14 10:32</p> * <p>Author: fighter3</p> * <p>Description: Netty客户端Demo</p> */public class NettyClient { // 服务器 IP private String host; // 服务器监听的端口号 private int port; public NettyClient(String host, int port) { this.host = host; this.port = port; } /** * 启动 Netty 客户端 */ public void run() throws InterruptedException { // 创建事件循环组 NioEventLoopGroup group = new NioEventLoopGroup(); try { // 创建 Bootstrap 对象 Bootstrap bootstrap = new Bootstrap(); // 配置 Bootstrap 对象 // 设置线程组 bootstrap.group(group) // 设置客户端通信的通道类型为NIO类型 .channel(NioSocketChannel.class) .handler(new ChannelInitializer<SocketChannel>() { // 通道初始化回调函数,在启动的时候可以自动调用 @Override public void initChannel(SocketChannel ch) throws Exception { // 添加消息处理器 ch.pipeline().addLast(new NettyClientHandler()); } }); // 连接服务器,异步等待连接成功 ChannelFuture channelFuture = bootstrap.connect(host, port).sync(); System.out.println("===========Netty客户端连接服务端========="); // 等待客户端连接关闭 channelFuture.channel().closeFuture().sync(); } finally { //释放资源 group.shutdownGracefully(); } } public static void main(String[] args) throws InterruptedException { // 创建客户端对象,并连接到服务器 NettyClient client = new NettyClient("127.0.0.1", 8888); // 启动客户端,开始发送消息 client.run(); }}
/** * <p>Date: 2023/5/14 10:33</p> * <p>Author: fighter3</p> * <p>Description: Netty客户端处理器</p> */public class NettyClientHandler extends ChannelInboundHandlerAdapter { /** * 当 Channel 准备就绪时就会触发这个方法 */ @Override public void channelActive(ChannelHandlerContext ctx) throws Exception { String message="大佬,带带我!"; ByteBuf hello = Unpooled.copiedBuffer(message, CharsetUtil.UTF_8); // 发送消息 ctx.writeAndFlush(hello); } /** * 当 Channel 中有来自服务器的数据时就会触发这个方法 */ @Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { ByteBuf buf = (ByteBuf) msg; System.out.println("服务端发来的消息:" + buf.toString(CharsetUtil.UTF_8)); // 接收消息并打印输出 } /** * 发生异常就会触发这个方法 */ @Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { cause.printStackTrace(); ctx.close(); }}
============Netty服务器启动...=============Netty服务器监听端口:8888客户端发来的消息:大佬,带带我!
===========Netty客户端连接服务端=========服务端发来的消息:你好,靓仔!
好了,一个简单的Netty入门Demo就写完了,Netty是一个双工通信的网络框架,可以看到,服务端和客户端,流程基本上一致,主要包括这么几个步骤:
服务器&客户端初始化启动流程
虽然这个Demo比较简单,但其实已经用到了Netty里几个比较关键的组件:
Netty的重要组件
后续,我们还会和这些组件打更多的交道。
好了,那么这期内容就到这了,这期里我们初步了解了Netty,包括什么是Netty、Netty现状、Netty的应用,还写了一个简单的Demo。下一期,我们继续深入了解Netty,敬请期待。
[1].https://netty.io/
[2].《Netty权威指南》
[3]. 《Netty核心原理剖析与RPC实践》
责任编辑:武晓燕 来源: 三分恶 Netty网络通信(责任编辑:综合)
新筑股份(002480.SZ):拟开展融资性售后回租业务 租赁期限3年
Gartner:中国企业追求AI实战性 云厂商正引领这一方向
Google One来了,OneDrive和Dropbox害怕吗?
长江存储推出3D NAND架构Xtacking,I/O接口速度高达3Gbps
王子新材(002735.SZ)拟收购中电华瑞49%股权 2月25日起复牌