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内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！

赞 (0)

相关推荐

  • Java设计模式之责任链模式的概念、实现以及netty中的责任链模式

    本文先介绍了责任链模式的概念及简单实现.再贴了netty中对责任链的实现.最后总结了一点点思考. 1.概念相关 1.1.概念 责任链模式为请求创建了一个接收者对象的链,每个接收者都包含对另一个接收者的引用.如果一个对象不能处理该请求,那么它会把相同的请求传给下一个接收者,沿着这条链传递请求,直到有对象处理它为止. 1.2.解决了什么: 客户只需要将请求发送到职责链上即可,无须关心请求的处理细节和请求的传递,所以职责链将请求的发送者和请求的处理者解耦了. 1.3.场景: 1.有多个对象可以处理同一

  • 简单了解Java Netty Reactor三种线程模型

    1. Reactor三种线程模型 1.1. 单线程模型 Reactor单线程模型,指的是所有的IO操作都在同一个NIO线程上面完成,NIO线程的职责如下: 1)作为NIO服务端,接收客户端的TCP连接: 2)作为NIO客户端,向服务端发起TCP连接: 3)读取通信对端的请求或者应答消息: 4)向通信对端发送消息请求或者应答消息. Reactor单线程模型示意图如下所示: Reactor单线程模型 由于Reactor模式使用的是异步非阻塞IO,所有的IO操作都不会导致阻塞,理论上一个线程可以独立处

  • Java Netty HTTP服务实现过程解析

    超文本传输协议(HTTP,HyperText Transfer Protocol)是互联网上应用最为广泛的一种网络协议. 在后端开发中接触HTTP协议的比较多,目前大部分都是基于Servlet容器实现的Http服务,往往有一些核心子系统对性能的要求非常高,这个时候我们可以考虑采用NIO的网络模型来实现HTTP服务,以此提高性能和吞吐量,Netty除了开发网络应用非常方便,还内置了HTTP相关的编解码器,让用户可以很方便的开发出高性能的HTTP协议的服务,Spring Webflux默认是使用的N

  • Java实战之用springboot+netty实现简单的一对一聊天

    Java实战之用springboot+netty实现简单的一对一聊天

    一.引入pom <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4

  • Java NIO框架Netty简单使用的示例

    之前写了一篇文章:Java 网络IO编程总结(BIO.NIO.AIO均含完整实例代码),介绍了如何使用Java原生IO支持进行网络编程,本文介绍一种更为简单的方式,即Java NIO框架. Netty是业界最流行的NIO框架之一,具有良好的健壮性.功能.性能.可定制性和可扩展性.同时,它提供的十分简单的API,大大简化了我们的网络编程. 同Java IO介绍的文章一样,本文所展示的例子,实现了一个相同的功能. 1.服务端 Server: package com.anxpp.io.calculat

  • 利用Java搭建个简单的Netty通信实例教程

    前言 看过dubbo源码的同学应该都清楚,使用dubbo协议的底层通信是使用的netty进行交互,而最近看了dubbo的Netty部分后,自己写了个简单的Netty通信例子. 准备 工程截图 模块详解 rpc-common rpc-common作为各个模块都需使用的模块,工程中出现的是一些通信时请求的参数以及返回的参数,还有一些序列化的工具. rpc-client rpc-client中目前只是单单的一个NettyClient启动类. rpc-server rpc-client中目前也只是单单的

  • JAVA Netty实现聊天室+私聊功能的示例代码

    功能介绍 使用Netty框架实现聊天室功能,服务器可监控客户端上下限状态,消息转发.同时实现了点对点私聊功能.技术点我都在代码中做了备注,这里不再重复写了.希望能给想学习netty的同学一点参考. 服务器代码 服务器入口代码 package nio.test.netty.groupChat; import io.netty.bootstrap.ServerBootstrap; import io.netty.channel.ChannelFuture; import io.netty.chann

  • java基于netty NIO的简单聊天室的实现

    一.为何要使用netty开发 由于之前已经用Java中的socket写过一版简单的聊天室,这里就不再对聊天室的具体架构进行细致的介绍了,主要关注于使用netty框架重构后带来的改变.对聊天室不了解的同学可以先看下我的博客(<JAVA简单聊天室的实现>) 本篇博客所使用的netty版本为4.1.36,完整工程已上传到Github(https://github.com/Alexlingl/Chatroom),其中lib文件夹下有相应的netty jar包和source包,自行导入即可. 1.为何要

  • Java Netty实现心跳机制过程解析

    netty心跳机制示例,使用Netty实现心跳机制,使用netty4,IdleStateHandler 实现.Netty心跳机制,netty心跳检测,netty,心跳 本文假设你已经了解了Netty的使用,或者至少写过netty的helloworld,知道了netty的基本使用.我们知道使用netty的时候,大多数的东西都与Handler有关,我们的业务逻辑基本都是在Handler中实现的.Netty中自带了一个IdleStateHandler 可以用来实现心跳检测. 心跳检测的逻辑 本文中我们

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

    一.简介 Java的底层API逐渐复杂,而开发者面对的开发场景需求也在逐渐增大.如果直接针对底层API进行编程,无疑是耗时耗力的.这时就催生了极多的编程框架,这些框架隐藏了API实现的复杂细节,以最简洁的方式给开发人员提供功能的实现接口.Netty就是一款针对于网络链接的框架,他的出现让服务器开发人员更加的集中关注于更多逻辑的实现,而不为了实现更好更多更稳定的链接而头疼.Netty的核心功能基于NIO实现. 二.Netty的应用场景 几乎适用于所有的长短链接场景,由于Java应用的广泛性,几乎所

  • 游戏服务器中的Netty应用以及源码剖析

    游戏服务器中的Netty应用以及源码剖析

    目录 一.Reactor模式和Netty线程模型 1. BIO模型 2. NIO模型 3. Reacor模型 ①. 单Reacor单线程模型 ②. 单Reactor多线程模型 ③. 主从Reactor多线程模型 ④. 部分源码分析 二.select/poll和epoll 1.概念 2.jdk提供selector 3.Netty提供的Epoll封装 4.Netty相关类图 5.配置Netty为EpollEventLoop 三.Netty相关参数 1.SO_KEEPALIVE 2.SO_REUSEA

  • Java 自旋锁（spinlock）相关知识总结

    一.前言 谈到『自旋锁』,可能大家会说,这有啥好讲的,不就是等待资源的线程"原地打转"嘛.嗯,字面理解的意思很到位,但能深入具体点吗?自旋锁的设计真就这么简单? 本文或者说本系列的目的,都是让大家不要停留在表面,而是深入分析,做到: 灵活使用 掌握原理 优缺点 二.锁的优化:自旋锁 当多个线程想同时访问同一个资源时,就存在资源冲突,这时,大家最直接想到的就是加锁来互斥访问,加锁会有这么几个问题: 等待资源的线程进入睡眠,发生用户态向内核态的切换,有一定的性能开销: 占用资源的线程很快就

  • Java并发工具类Exchanger的相关知识总结

    Java并发工具类Exchanger的相关知识总结

    一.Exchanger的理解 Exchanger 属于java.util.concurrent包: Exchanger 是 JDK 1.5 开始提供的一个用于两个工作线程之间交换数据的封装工具类; 一个线程在完成一定的事务后想与另一个线程交换数据,则第一个先拿出数据的线程会一直等待第二个线程,直到第二个线程拿着数据到来时才能彼此交换对应数据. 二.Exchanger类中常用方法 public Exchanger() 无参构造方法.表示创建一个新的交换器. public V exchange(V

  • 详解Java中的数组与字符串相关知识

    Java数组的定义和使用 如果希望保存一组有相同类型的数据,可以使用数组. 数组的定义和内存分配 Java 中定义数组的语法有两种: type arrayName[]; type[] arrayName; type 为Java中的任意数据类型,包括基本类型和组合类型,arrayName为数组名,必须是一个合法的标识符,[ ] 指明该变量是一个数组类型变量.例如: int demoArray[]; int[] demoArray; 这两种形式没有区别,使用效果完全一样,读者可根据自己的编程习惯选择

  • 不看后悔!揭秘游戏服务器开发

    不看后悔!揭秘游戏服务器开发

    目录 前言 1.常见游戏模块 2.开发语言与项目构建发布 3.JAVA游戏服务器,需要掌握的技术 4.总结 前言 <摩尔庄园>前段时间上线, 持续超出市场预期,相信也有不错的收益.游戏好玩,所有玩家看到了前端,但是做一款游戏,离不开后台游戏服务器的支持,服务器都要做什么,服务器的架构是什么,需要哪些技术,一系列的问题有没有思考过?下面讲下作为做服务器开发中需要做的事. 1.常见游戏模块 游戏玩法 游戏开发中常见的玩法模块,一般的游戏都会包含这些玩法 新手引导.任务系统.背包系统.装备系统.副本

  • Java非阻塞I/O模型之NIO相关知识总结

    组件说明 (1)Channel:NIO模型中的管道,管道是链接建立和通信的重要组件,我们可以理解管道是一个容器环境,我们所有的I/O的建立读取都可以在这个容器中进行 (2)Selector:NIO中的选择器,NIO是由事件驱动的,当有链接事件或者读取事件发生时,这个事件可以注册到这个选择器上,并且最终被我们检测到. (3)SelectionKey:我们可以在Selector中进行检测是否有SelectionKey产生,并且根据这个SelectionKey中的信息判断时什么事件发生了. 代码说明

  • Java泛型机制与反射原理相关知识总结

    Java泛型机制与反射原理相关知识总结

    一.泛型的概念 1.1 基础案例 泛型在Java中的应用非常广泛,最常见则是在集合容器中,先看下基础用法: public class Generic01 { public static void main(String[] args) { Map<Integer,String> map = new HashMap<>() ; map.put(88,"hello") ; // map.put("99","world") ;

  • 总结一下Java回调机制的相关知识

    一.回调 回调分为同步回调和异步回调, 假如以买彩票的场景来模拟, 我买彩票, 调用彩票网,给我返回的结果确定是否中奖,同步回调就是,我买了彩票之后, 需要等待彩票网给我返回的结果, 这个时候我不能做其他事情, 我必须等待这个结果, 这就叫同步回调, 同步, 就意味着等待, 我不能去做其他事情, 必须等待, 异步回调就是, 我买了彩票之后, 可以去做其他事情, 然后当彩票网有了结果和消息, 再给我返回消息, 其中最明显的方式就是在得到彩票结果的函数之中, 添加一个其他的方法, 如果我的其他方法可

  • java中数组的相关知识小结(推荐)

    java中数组的相关知识小结(推荐)

    1. 2.数组的命名方法 1)int[]ages=new int[5]; 2) int[]ages; ages=new int[5]; 3)int[]ags={1,2,3,4,5}; 4)int[]ags; ags=new int{1,2,3,4}; 或者 int[]ags=new int{1,2,3,4}; 3.java不支持不同类型的重名数组 4.java中数组的循环赋值 package dierge; public class Shuzu { public static void main

随机推荐