共计 2488 个字符,预计需要花费 7 分钟才能阅读完成。
导读 | 今天带大家来学习 Java 游戏服务器的相关知识, 文中对 Netty 作了非常详细的介绍, 对正在学习 java 的小伙伴们有很好的帮助, 需要的朋友可以参考下 |
Java 的底层 API 逐渐复杂,而开发者面对的开发场景需求也在逐渐增大。如果直接针对底层 API 进行编程,无疑是耗时耗力的。这时就催生了极多的编程框架,这些框架隐藏了 API 实现的复杂细节,以最简洁的方式给开发人员提供功能的实现接口。Netty 就是一款针对于网络链接的框架,他的出现让服务器开发人员更加的集中关注于更多逻辑的实现,而不为了实现更好更多更稳定的链接而头疼。Netty 的核心功能基于 NIO 实现。
几乎适用于所有的长短链接场景,由于 Java 应用的广泛性,几乎所有的互联网公司或多或少的都会使用到。博主从事游戏开发,可以说几乎所有短链接游戏服务器都是使用 Netty 开发,实效性要求比较高也有热修复需求的服务器一般不会使用 Java,目前采用更多的是 C +Lua 的组合方式。Java 不可以热修复是很多长链服务器不考虑 java 的一个重要原因。
NIO 文章中强调了,这种模型的主要特地拿就是异步和事件驱动性,异步是服务器不需要一直等待链接输入直到链接关闭。而是可以在某个特定的时候去相应链接的输入,而特定的时候就是另一个事件驱动性,链接发生变化时,会产生一个事件,而 NIO 模型检测到这个事件之后,会去相应这个事件的处理事件。
1.Channel:
Channel 时 Java-NIO 的一个基本构造,它代表到一个实体的开放链接,如读操作和写操作,在 NIO 模型中也可以被理解成一个入站或者出站的数据载体,可以被关闭或者关闭。
2. 回调 ChannelHandler:
一个回调就是一个方法,Netty 提供了两个子类,ChannelInboundHandlerAdapter 以及 ChannelOutboundHandlerAdapter , 这两个子类分别可以应用于数据进站和出站时期,各种阶段的回调,比如入站时 Active 方法,表明链接刚刚被建立起,代码如下:
public class ConnectHandler extend ChannelInboundHandlerAdapter{
@override
public void ChannelActive(ChannelHandlerContext ctx){
// 数据入站回调子类被建立时调用,也就是链接建立时调用
System.out.println("远程客户端 :"+ ctx.channel().remoteAddress() + '建立链接');
}
}
不了解 Netty 的读者看到这里可能会有点疑惑,这个类应该怎么用。这里简单的解释一下:这种类会在 Netty 创建的时候注册进服务中,然后在数据进站、出站的不同阶段,调用这个类中不同的回调函数,以处理不同的开发需求。可以关注一下读者其他的文章
3.Future:
jdk-Future:Java 中提供了 Future 的实现,这种 Futrue 可以看作是一个异步操作结果的占位符。我们可以通过这个 Future 查询到这个异步操作的结果,并进行一些处理。比如在操作失败的时候抛出异常。但是 jdk 内置的 Future 的查询只能在某个时刻手动去查询结果,或者直接阻塞这个异步操作,直到异步完成操作之后可以查询 Future 的成功或者失败。
ChannelFuture:Netty 内部提供的 Future 实现类,很多异步操作在执行的时候都会返回一个 ChannelFuture 对象,我们可以针对这个 ChannelFuture 对象设置一些回调函数,比如重写 operationComplete() 方法,这样这个异步事件在完成的时候会自动调用这个方法,并且执行我们自己的处理逻辑。
接下来可以看一下 ChannelFuture 的应用实例,检测 Netty 服务器链接远程地址是否成功:
Channel channel = "";
// 链接地址 192.168.100.113 的 7000 端口
InetSocketAddress socketAddress = new InetSocketAddress("192.168.100.113",7000);
// 管道绑定地址并返回一个 ChannelFuture
ChannelFuture channelFuture = channel.connect(socketAddress);
// 给 ChannelFuture 设置完成回调,判断这个操作是否完成
channelFuture.addListener(new ChannelFutureListener(){
@override
public void operationComplete(ChannelFuture future){if(future.isSucess()){
// 创建一个字符串,并指定所使用的字符集,下面这种写法是 Netty 中经常遇到的
ByteBuf buffer = Unpooled.copiedBuffer("Hello",Charset.defaultCharset());
// 发送信息并且返回一个新的 writeFuture,依旧可以根据这个 writeFuture 处理一些逻辑
ChannelFuture writeFuture = future.channel().writeAndFlush(buffer);
}else{
// 链接失败则答应出失败的消息
Throwable cause = future.cause();
cause.printStackTrace();}
}
})
Netty 以一种异步事件驱动以及回调的方式,能帮我们快速完善服务器处理数据的进出,以及各个流程细节中的处理逻辑。极大的精简了服务器开发人员在,链接处理,数据出入方面的开发工作。是一个及其易用且稳定的网络开发框架。
到此这篇关于 Java 游戏服务器系列之 Netty 相关知识总结的文章就介绍到这了
![post-qrcode](https://www.xgss.net/wp-content/uploads/2023/07/二维码-微信公众号256x256.jpg)