Java游戏服务器系列之Netty相关知识总结

一、简介

java的底层api逐渐复杂，而开发者面对的开发场景需求也在逐渐增大。如果直接针对底层api进行编程，无疑是耗时耗力的。这时就催生了极多的编程框架，这些框架隐藏了api实现的复杂细节，以最简洁的方式给开发人员提供功能的实现接口。netty就是一款针对于网络链接的框架，他的出现让服务器开发人员更加的集中关注于更多逻辑的实现，而不为了实现更好更多更稳定的链接而头疼。netty的核心功能基于nio 实现。

二、netty的应用场景

几乎适用于所有的长短链接场景，由于java应用的广泛性，几乎所有的互联网公司或多或少的都会使用到。博主从事游戏开发，可以说几乎所有短链接游戏服务器都是使用netty开发，实效性要求比较高也有热修复需求的服务器一般不会使用java，目前采用更多的是c+lua的组合方式。java不可以热修复是很多长链服务器不考虑java 的一个重要原因。

三、异步和事件驱动性

nio 文章中强调了，这种模型的主要特地拿就是异步和事件驱动性，异步是服务器不需要一直等待链接输入直到链接关闭。而是可以在某个特定的时候去相应链接的输入，而特定的时候就是另一个事件驱动性，链接发生变化时，会产生一个事件，而nio模型检测到这个事件之后，会去相应这个事件的处理事件。

四、netty核心组件

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相关知识总结的文章就介绍到这了,更多相关java netty内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持！