阿里妹导读
随着云计算、大数据和物联网的发展，Netty的潜力将进一步释放。作者通过本文跟大家聊聊Netty是什么？为什么选Netty？以及它的运行原理。
官方介绍：> Netty is an asynchronous event-driven network application frameworkfor rapid development of maintainable high performance protocol servers & clients.
翻译：Netty是一个异步事件驱动的网络应用程序框架用于快速开发**可维护的高性能**协议服务器和客户端。
从这里可以看出Netty本质是网络应用程序框架，实现方式是异步和事件驱动，特点是高性能、易开发、可维护性高。
几乎所有我们叫得上名字的框架，底层用的都是Netty，包括RocketMQ、Elasticsearch、gRPC、Apache Dubbo、Spring5、HSF、 Zookeeper、Spark、Hadoop，这足以说明Netty一定是有它巨大的优势。优势总结如下：
接下来详细介绍一下这些优势在Netty中具体体现。
BIO: 同步阻塞式IO 打个比喻您打了专车，在您没有到之前司机就在出发地等您上车。您上车之后司机专门送您到目的地。在这个例子中您扮演着IO中的网络事件，司机扮演着处理网络事件的线程。整个过程中您如果没有任何事件发生司机一直都在等待这就是同步阻塞。
NIO:同步非阻塞IO 银行柜员在等待人办理银行业务，人们去银行后首先要到取号机上取号然后等待对应的柜台叫号。在这个例子中银行柜员扮演着selector，办理银行业务的人扮演者网络事件，而取号机扮演者register的作用，银行柜台就是channel。整个过程中当没有人来办业务时，柜员是可以去做其他事情这就是非阻塞。
AIO:异步非阻塞IO 您点外卖后就去忙其他的事情了，等骑手把外卖送达后打电话告诉您外卖放外卖柜子里了；您闲下来的时候去取外卖。在这个例子里您扮演着处理网络事件线的程，外卖是网络事件；在这个过程中您可以在外卖还没有送来的时候做些其他的事情，等外卖送达后只是向您发送了一个外卖送达的事件。这就是异步和非阻塞。
通过网络服务端代码的编写来让我们直观感受一下他们的区别：
BIOServer
public class Server {
//定义一个循环接收客户端的Socket连接请求。初始化一个线程池对象
private static ExecutorService poolHandler = new ThreadPoolExecutor(5, 5,
120, TimeUnit.SECONDS, new ArrayBlockingQueue<>(10));
public static void main(String[] args) {
try {
// 注册端口
ServerSocket ss = new ServerSocket(9999);
while (true) {
Socket socket = ss.accept();
// 把Socket封装成一个任务对象交给线程池处理
Runnable target = new ServerRunnable(socket);
poolHandler.execute(target);
}
} catch (IOException e) {
e.printStackTrace();
}
}
public static class ServerRunnable implements Runnable {
private Socket socket;
public ServerRunnable(Socket socket) {
this.socket = socket;
}
@Override
public void run() {
// 处理接收的客户端Socket通信需求
try {
InputStream is = socket.getInputStream();
BufferedReader br = new BufferedReader(new InputStreamReader(is));
String msg;
while ((msg = br.readLine()) != null) {
//处理数据的粘包拆包
//对完整的数据包进行解码操作
//得到客户端消息
//触发各种统计类事件如心跳检测 信息统计
//处理客户端的消息
//得到响应消息
//对响应消息进行编码
}
} catch (IOException e) {
e.printStackTrace();
//处理网络断开事件
//处理其他异常事件
}
}
}
}NIOServer
public class Server {
public static void main(String[] args) throws IOException {
//获取ServerSocketChannel
ServerSocketChannel ssChannel = ServerSocketChannel.open();
//设置非阻塞模式
ssChannel.configureBlocking(false);
//绑定端口
ssChannel.bind(new InetSocketAddress(9999));
//获取选择器
Selector selector = Selector.open();
//将ServerSocketChannel注册到选择器上，并且监听建立连接事件
ssChannel.register(selector, SelectionKey.OP_ACCEPT);
// 使用Selector选择器轮询已经就绪好的事件
while (selector.select() > 0) {
// 获取选择器就绪事件
Iterator<SelectionKey> it = selector.selectedKeys().iterator();
//遍历事件
while (it.hasNext()) {
SelectionKey sk = it.next();
//判断事件类型
if (sk.isAcceptable()) {
// 获取客户端channel
SocketChannel channel = ssChannel.accept();
//切换非阻塞模式
channel.configureBlocking(false);
//将该channel注册到选择器上
channel.register(selector, SelectionKey.OP_READ);
} else if (sk.isReadable()) {
//获取channel
SocketChannel sChannel = (SocketChannel) sk.channel();
//读取网络数据
ByteBuffer buf = ByteBuffer.allocate(1024);
int len = 0;
while ((len = sChannel.read(buf)) > 0) {
//处理数据的粘包拆包
//对完整的数据包进行解码操作
//得到客户端消息
//触发各种统计类事件如心跳检测 信息统计
}
}else if(sk.isWritable()){
//得到响应消息
//对响应消息进行编码
}
// 15.取消选择键SelectionKey
it.remove();
}
}
}
}用Netty进行网络编程时代码是这样的：
NettyServer
public class NettyServer {
public static void main(String[] args) throws Exception{
//设置接受网络连接线程池
NioEventLoopGroup bossGroup = new NioEventLoopGroup(1);
//设置处理网络除连接外所有事件线程的线程池
NioEventLoopGroup workerGroup = new NioEventLoopGroup();
ServerBootstrap serverBootstrap = new ServerBootstrap();
serverBootstrap.group(bossGroup,workerGroup)
.channel(NioServerSocketChannel.class)//设置Channel类型
.option(ChannelOption.SO_BACKLOG,1024)
.handler(new ChannelInitializer<ServerSocketChannel>() {
@Override
protected void initChannel(ServerSocketChannel ch) throws Exception {
//设置处理网络连接的Handler
ch.pipeline().addLast("serverBindHandler",
new NettyBindHandler(NettyTcpServer.this,serverStreamLifecycleListeners));
}
})
.childHandler(new ChannelInitializer<NioSocketChannel>() {
@Override
protected void initChannel(NioSocketChannel ch) throws Exception {
ch.pipeline()
.addLast("protocolHandler", new NettyProtocolHandler())//设置编解码器
.addLast("serverIdleHandler",
new IdleStateHandler(0, 0, serverIdleTimeInSeconds))//设置心跳检测
.addLast("serverHandler",new NettyServerStreamHandler(NettyTcpServer.this, false,
serverStreamLifecycleListeners,
serverStreamMessageListeners));//设置业务处理逻辑
}
});
ChannelFuture channelFuture = serverBootstrap.bind(9000).sync();
channelFuture.channel().closeFuture().sync();
}
}BIO和NIO编程在网络事件发生后都需要进行处理数据的粘包拆包、对完整的数据包进行解码、触发各种统计类事件、对响应消息进行编码、监听各种网络异常、需要对底层网络和通信协议有一定的了解。
用Netty编程时只需要设置Handler就能快速的进行业务开发而不用关心数据的读取及网络事件的分发处理.让开发者从底层网络通信中解放出来。从这些对比中我们可以看出Netty开发网络程序要求低，使用者无需太多关心和业务无关的信息。
多数情况下我们自定义的Handler会有多个，那么他们是怎么进行协调合作的呢？接下一起探索handler之间的协调合作。
通过上图我们可以知道我们定义的handler在Netty里是通过双向链表进行关联的。
介绍一下读网络事件发生后Handler事件流：
当服务端有数据需要写入时又会发生什么呢？
我们可以看出Netty通过控制InboundHandler节点的调用来决定读事件响应链路；通过控制OutboundHandler节点的调用来决定写事件调用链路。
Netty通过内置多种Handler让你在不了解底层网络、通信协议、编解码的背景下也可进行网络应用程序。它都内置有哪些Handler呢？
当你通过Netty发送或者接受一个消息的时候，就将会发生一次数据转换。入站消息会被解码，从字节转换为另一种格式（比如java对象）。如果是出站消息，它会被编码成字节。
大多数基于Netty通信底层都会使用TCP进行的通信。TCP在发送数据流的时一定会把整条数据流单独发送吗？答案是否定的。TCP在发送数据包的时会存在拆包和粘包问题。什么是TCP的粘包和拆包呢？
由于篇幅有限关于TCP拆包和粘包只是大致说明了一些。
Netty提供了三种解码器来解决TCP的拆包和粘包,他们分别是：
此外Netty还提供了N：
除了以上介绍的编解码Netty内部还有很多内置编解码器,当您使用Netty开发时如果有用到编解码的时候可以首先查询一下Netty内部是否有实现。
从Netty源码包上可以看出Netty基本上覆盖了主流协议的编解码实现，如HTTP、Protobuf、WebSocket、二进制等主流协议。
当需要监听网络连接是否长时间没有数据交换（如发送心跳包、关闭连接等）就可以使用内置的IdleStateHandler。IdleStateHandler接收三个参数：
当达到设定的空闲时间阈值时，IdleStateHandler会触发对应的IdleState事件，这些事件包括READ_IDLE、WRITE_IDLE和ALL_IDLE。你可以通过实现ChannelInboundHandler的channelIdle方法来监听这些事件，并在事件发生时执行相应的操作。
reactor单线程模型： 有一个线程负责处理所有的网络事件。
Reactor多线程模型：有一个线程单独处理建立网络事件，另外一个线程负责处理其他的网络事件。
主次Reactor多线程模型：有一个线程单独处理建立网络事件,把建立网络连接放到线程池中的某一个线程中，这个线程负责大量网络连接的其他请求.
从reactor线程模型上我们可以看出主次Reactor多线程模型可以快速对大量的网络事件进行响应,因此也会缩短网络事件处理时间.
我们可以看到Netty针对网络传输的各个节点都做到了尽可能的缩短时间，这也是Netty高性能的原因所在。
通过以上对Netty是什么，优势有哪些已经有了初步了解。那么它内部是怎么工作的呢？接下来让我们一起看一下它内部的原理。
上面这张图就是在官网首页的架构图，我们从上到下分析一下。
以上可看出Netty的功能、协议、传输方式都比较全，比较强大。
从图中可以Netty通过网络通信层、事件调度层、服务编排层协调合作来运行程序
网络通信层的职责是执行网络 I/O 的操作。当网络数据读取到内核缓冲区后，会触发各种网络事件。这些网络事件会分发给事件调度层进行处理。接下来分别看一下Netty服务端和客户端在网络通信层是怎么运行的：
事件调度层的职责是通过 Reactor 线程模型对各类事件进行聚合处理，通过 Selector 主循环线程集成多种事件(I/O 事件,信号事件,定时事件等)，实际的业务处理逻辑是交由服务编排层中相关的 Handler 完成。事件调度层主要由EventLoopGroup和EventLoop构成。
服务编排层的职责是通过组装各类handler来实现网络数据流的处理。它是 Netty 的核心处理链，用以实现网络事件的动态编排和有序传播。服务编排层的核心组件包括 ChannelHandler、ChannelHandlerContext、ChannelPipeline。
他们之间的关系如下图所示：
我们已经从宏观上了解了Netty，接下来我们从服务端的视角简要的看一下Netty整个的运行流程。
Netty以其高效、灵活和强大的特性，已经成为了Java平台上构建高性能网络应用的首选框架。Netty 的设计哲学不仅简化了复杂网络编程的挑战，还为企业级应用提供了坚实的基础。
随着云计算、大数据和物联网的发展，Netty的潜力将进一步释放。未来，我们可以预见Netty在微服务架构、实时数据传输和边缘计算等领域发挥更大的作用。
对于开发者而言，掌握Netty的精髓意味着拥有了一把解锁高并发、低延迟网络解决方案的金钥匙。
因此，无论你是初学者还是经验丰富的工程师，投入时间学习和精通Netty都是一项值得的投资。
本文由微信公众号阿里云开发者原创，哈喽比特收录。
文章来源：https://mp.weixin.qq.com/s/52iS3RxIO_to29IG_JoOpw
京东创始人刘强东和其妻子章泽天最近成为了互联网舆论关注的焦点。有关他们“移民美国”和在美国购买豪宅的传言在互联网上广泛传播。然而，京东官方通过微博发言人发布的消息澄清了这些传言，称这些言论纯属虚假信息和蓄意捏造。
日前，据博主“@超能数码君老周”爆料，国内三大运营商中国移动、中国电信和中国联通预计将集体采购百万台规模的华为Mate60系列手机。
据报道，荷兰半导体设备公司ASML正看到美国对华遏制政策的负面影响。阿斯麦（ASML）CEO彼得·温宁克在一档电视节目中分享了他对中国大陆问题以及该公司面临的出口管制和保护主义的看法。彼得曾在多个场合表达了他对出口管制以及中荷经济关系的担忧。
今年早些时候，抖音悄然上线了一款名为“青桃”的 App，Slogan 为“看见你的热爱”，根据应用介绍可知，“青桃”是一个属于年轻人的兴趣知识视频平台，由抖音官方出品的中长视频关联版本，整体风格有些类似B站。
日前，威马汽车首席数据官梅松林转发了一份“世界各国地区拥车率排行榜”，同时，他发文表示：中国汽车普及率低于非洲国家尼日利亚，每百户家庭仅17户有车。意大利世界排名第一，每十户中九户有车。
近日，一项新的研究发现，维生素 C 和 E 等抗氧化剂会激活一种机制，刺激癌症肿瘤中新血管的生长，帮助它们生长和扩散。
据媒体援引消息人士报道，苹果公司正在测试使用3D打印技术来生产其智能手表的钢质底盘。消息传出后，3D系统一度大涨超10%，不过截至周三收盘，该股涨幅回落至2%以内。
9月2日，坐拥千万粉丝的网红主播“秀才”账号被封禁，在社交媒体平台上引发热议。平台相关负责人表示，“秀才”账号违反平台相关规定，已封禁。据知情人士透露，秀才近期被举报存在违法行为，这可能是他被封禁的部分原因。据悉，“秀才”年龄39岁，是安徽省亳州市蒙城县人，抖音网红，粉丝数量超1200万。他曾被称为“中老年...
9月3日消息，亚马逊的一些股东，包括持有该公司股票的一家养老基金，日前对亚马逊、其创始人贝索斯和其董事会提起诉讼，指控他们在为 Project Kuiper 卫星星座项目购买发射服务时“违反了信义义务”。
据消息，为推广自家应用，苹果现推出了一个名为“Apps by Apple”的网站，展示了苹果为旗下产品（如 iPhone、iPad、Apple Watch、Mac 和 Apple TV）开发的各种应用程序。
特斯拉本周在美国大幅下调Model S和X售价，引发了该公司一些最坚定支持者的不满。知名特斯拉多头、未来基金（Future Fund）管理合伙人加里·布莱克发帖称，降价是一种“短期麻醉剂”，会让潜在客户等待进一步降价。
据外媒9月2日报道，荷兰半导体设备制造商阿斯麦称，尽管荷兰政府颁布的半导体设备出口管制新规9月正式生效，但该公司已获得在2023年底以前向中国运送受限制芯片制造机器的许可。
近日，根据美国证券交易委员会的文件显示，苹果卫星服务提供商 Globalstar 近期向马斯克旗下的 SpaceX 支付 6400 万美元（约 4.65 亿元人民币）。用于在 2023-2025 年期间，发射卫星，进一步扩展苹果 iPhone 系列的 SOS 卫星服务。
据报道，马斯克旗下社交平台𝕏（推特）日前调整了隐私政策，允许 𝕏 使用用户发布的信息来训练其人工智能（AI）模型。新的隐私政策将于 9 月 29 日生效。新政策规定，𝕏可能会使用所收集到的平台信息和公开可用的信息，来帮助训练 𝕏 的机器学习或人工智能模型。
9月2日，荣耀CEO赵明在采访中谈及华为手机回归时表示，替老同事们高兴，觉得手机行业，由于华为的回归，让竞争充满了更多的可能性和更多的魅力，对行业来说也是件好事。
《自然》30日发表的一篇论文报道了一个名为Swift的人工智能（AI）系统，该系统驾驶无人机的能力可在真实世界中一对一冠军赛里战胜人类对手。
近日，非营利组织纽约真菌学会（NYMS）发出警告，表示亚马逊为代表的电商平台上，充斥着各种AI生成的蘑菇觅食科普书籍，其中存在诸多错误。
社交媒体平台𝕏（原推特）新隐私政策提到：“在您同意的情况下，我们可能出于安全、安保和身份识别目的收集和使用您的生物识别信息。”
2023年德国柏林消费电子展上，各大企业都带来了最新的理念和产品，而高端化、本土化的中国产品正在不断吸引欧洲等国际市场的目光。
罗永浩日前在直播中吐槽苹果即将推出的 iPhone 新品，具体内容为：“以我对我‘子公司’的了解，我认为 iPhone 15 跟 iPhone 14 不会有什么区别的，除了序（列）号变了，这个‘不要脸’的东西，这个‘臭厨子’。
