当前位置: 首页 > news >正文

Netty核心组件介绍

Netty是一款用于创建高性能网络应用程序的高级框架。Netty的核心组件如下:

  • Channel
  • 回调
  • Future
  • 事件和ChannelHander

Channel

channel是Java NIO的一个基本构造。可以把Channel看作是传入或传出数据的载体。它可以被打开或关闭,连接或断开连接。

回调

Netty在内部使用了回调来处理事件:当一个回调被触发时,相关的事件可以被一个ChannelHandler的实现处理。
如:

public class ContentHandler extends ChannelInboundHandlerAdapter {public void channelActive(ChannelHandlerContext ctx) throws Exception {System.out.println("client " + ctx.channel().remoteAddress() + " connected");}
}

Future

Future提供了另一种在操作完成时通知应用程序的方式。这个对象可以看作是一个异步操作的结果的占位符,它将在未来的某个时刻完成,并提供对其结果的访问。
JDK预置了java.util.concurrent.Future,但是其所提供的实现只允许手动检查对应的操作是否已经完成,或者一直阻塞直到它完成。Netty提供了它自己的实现——ChannelFuture,用于在执行异步操作的时候用。每个Netty的io操作都将返回一个ChannelFuture,也就是说它们都不会阻塞。Netty是完全异步和事件驱动的。
使用方法如下:

	Channel channel = ... ;ChannelFuture future = channel.connect(new InetSocketAddress("192.168.0.1", 25));future.addListener(new ChannelFutureListener() {public void operationComplete(ChannelFuture future) {if(future.isSuccess()) {ByteBuf buffer = Unpooled.copiedBuffef("Hello", Charset.defaultCharset());ChannelFuture wf = future.channel().writeAndFlush(buffer);} else {future.cause().printStackTrace();	}}});

事件和ChannelHandler

Netty使用不同的事件来通知我们状态的改变或操作的状态。这使得我们能够根据已经发生的事件来触发适当的动作。Netty是一个网络编程框架,所以事件是按照它们与入站或出站数据流的相关性进行分类的。可能由入站数据或者相关的状态更改而触发的事件包括:

  • 连接已被激活或连接失活

  • 数据读取

  • 用户事件

  • 错误事件
    出站事件是未来将会触发的某个动作的操作结果,这些动作包括:

  • 打开或关闭到远程节点的连接

  • 将数据写到或冲刷到套接字

每个事件都可以被分发给ChannelHandler类中的某个用户实现的方法。下图展示了一个事件是如何被一个这样的ChannelHandler链处理的。
在这里插入图片描述
你可以认为每个ChannelHandler的实例都类似于一种为了响应特定事件而被执行的回调。

合在一起

Future、回调和ChannelHandler

Netty的异步编程模型是建立在Future和回调的概念之上的,而将事件派发到ChannelHandler的方法则发生在更深的层次上。结合在一起,这些元素就提供了一个处理环境,使你的应用程序逻辑可以独立于任何网络操作相关的顾虑而独立地演变。这也是Netty的设计方式的一个关键目标。
拦截操作以及高速地转换入站数据和出站数据,都只需要你提供回调或利用操作返回的Future。这使得链接操作变得既简单又高效,并且促进了可重用的通用代码的编写。

选择器、事件和EventLoop

Netty通过触发事件将Selector从应用程序中抽象出来,消除了所有将需要手动编写的派发代码。在内部,为每个Channel分配一个EventLoop,用以处理所有事件,包括:

  • 注册感兴趣的事件
  • 将事件派发给ChannelHandler
  • 安排进一步的动作

EventLoop本身只由一个线程驱动,其处理了一个Channel的io事件,并且在该EventLoop的整个生命周期内都不会改变。这个简单而强大的设计消除了你所有可能有的在ChannelHandler实现中需要进行同步的任何顾虑,因此你可以专注于提供正确的逻辑,用来在有感兴趣的数据要处理的时候执行。

http://www.lryc.cn/news/346095.html

相关文章:

  • 代码审计平台sonarqube的安装及使用
  • C++ 使用nlohmann/json.hpp库读写json字符串
  • 3GPP官网下载协议步骤
  • 【JAVA】Git 的基本概念和使用方式
  • C++多态实现原理详解
  • [数据集][目标检测]交通灯检测数据集VOC+YOLO格式2600张1类别
  • 关于测试用例
  • 一起长锈:3 类型安全的Rust宏(从Java与C++转Rust之旅)
  • 《金融研究》:普惠金融改革试验区DID工具变量数据(2012-2023年)
  • Prompt|Kimi高阶技巧,99%的人都不知道
  • 采购管理软件:采购自动化提高效率的5种方式
  • Android App开机启动
  • 服务器直连电脑(盒子直连电脑)电脑需要设置为固定ip才能访问盒子
  • 【设计模式】之代理模式(两种)
  • 【工具篇】-什么是.NET
  • OmniReader Pro mac激活版:智慧阅读新选择,开启高效学习之旅
  • Stable Diffusion学习记录
  • 安装openssh-server,提供远程ssh
  • 华纳云:选择数据库服务器你需要注意的5个原则
  • Linux动态库与静态库解析
  • 后端的一些科普文章
  • 【Android学习】日期和时间选择对话框
  • 在Linux上使用Selenium驱动Chrome浏览器无头模式
  • Feign 第一次调用为什么会很慢?
  • Spring Framework-简介
  • Linux——PHP8.0编译安装和yum安装
  • 【通义千问系列】Qwen-Agent 从入门到精通【持续更新中……】
  • 1081:分苹果
  • Linux—-vim基础使用
  • 《ESP8266通信指南》12-Lua 固件烧录