[pravega-021] pravega源码分析--Controller子项目--关于netty[01]

2024-06-11 09:08

本文主要是介绍[pravega-021] pravega源码分析--Controller子项目--关于netty[01],希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

0.nett 教程 《netty in action》2016年版本。和 《netty in action》浓缩版本 https://github.com/waylau/essential-netty-in-action


1. netty的概念和家狗

1.1 单进程bio服务。从bio讲起,blocking io,同一时间,处理一个链接。

1.2 多线程bio服务。每个线程,从头到尾处理一个链接。效率比单进程bio快。但是,在每个线程内,也等数据输入输出,浪费时间。其次,每个线程都需要分配内存,不同os的线程从64KB到1MB不等,占用内存资源。第三,即使jvm支持大量线程,context-switching上下文切换能支持的连接有上限,也就是1万个链接,关于上下文切换参考https://www.cnblogs.com/szlbm/p/5505707.html。由此,导致了著名的 十万并发 问题。

非阻塞io,也就是nio,是jdk1.4发布的。nio模式下,进程建立多个sokcket,每个socket都有读写,每个socket的读写都会通知到一个selector,当selector发现有新的读写事件完成了,就会让一个线程或者一个线程池去处理新读写事件对应的socket。多个socket的读写-->一个selector-->一个处理线程或者一个处理线程池。好处:多个sockcet的读写不再占用等待资源;工作线程数量少了节省内存和上下文切换;工作线程或者工作线程池可以复用做其他任务。

多线程任务的io的处理和分发,需要细致的处理。netty就是解决这个问题。


1.3 netty:异步,事件驱动。

1.4 netty的核心组件:Channels, Callbacks, Futures, Events and Handlers。Channel是nio的基本组件,连接到硬件比如file和socket,以便进行读写。Callbacks:回调函数,它通常是提供给另一个函数的引用,后者完成某个动作或者到某个时间会调用回调函数。Future,也是一种通知某个事件完成的方式,futures是异步调用函数的返回值站位符,从futures可以获取异步调用的结果,用人话来说,如果异步调用一个函数,这个函数有return返回值,那么返回值在future里返回给调用方(注意future的实现源码)。jdk提供Future接口,需要手工检查是否完成以及阻塞,不够方便,netty设计了更好用的ChannelFuture。

 

1.5 一个使用jdk future的例子

1.5.1 Main.java

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;/*** 本例运行,1秒后输出* taks1 run ok* null* 5秒后输出* sleep over* 42*/public class Main {public static void main(String args[]){ExecutorService executor = Executors.newCachedThreadPool();//Runnable没有返回值//无返回值的RunnableRunnable task1 = new Runnable() {@Overridepublic void run() {try{Thread.sleep(1000);}catch (Exception e){}System.out.println("taks1 run ok");}};//Callable有返回值Callable<Integer> task2 = new Callable() {@Overridepublic Integer call() {try {Thread.sleep(5000);}catch (Exception e){}System.out.println("sleep over");return 42;}};Future<?> future1 = executor.submit(task1);Future<Integer> future2 = executor.submit(task2);try{System.out.println(future1.get());System.out.println(future2.get());}catch (Exception e){}System.exit(0);}
}

1.5.2 build.gradle

group 'com.brian.demo.netty'
version '1.0-SNAPSHOT'apply plugin: 'java'sourceCompatibility = 1.8repositories {mavenCentral()
}dependencies {compile group: 'io.netty', name: 'netty-all', version: '4.1.5.Final'compile group: 'io.netty', name: 'netty-transport-rxtx', version: '4.1.5.Final'testCompile group: 'junit', name: 'junit', version: '4.12'
}

1.5.3  jdk 1.7实现了nio.2,跟1.4的nio不同,api和实现都不同。共同的地方,都使用ByteBuffer作为数据容器。ByteBuffer可以在堆上分配内存,也可以在堆外分配。如果在堆外分配内存,那么数据传输不经过channel,更快,代价就是创建和释放成本更高。ByteBuffer可以在各实例之间实现零拷贝数据共享。

1.5.4 nio的问题:nio2支持7以上,不支持6及以下; nio的ByteBuffer不可扩展不能实现ByteBuffer数组; nio的channel的读写有内存泄漏;  epoll的bug导致cpu占用100%。netty解决这些问题。

1.6 netty的ChannelFuture,建立连接的返回值,可以注册若干个ChannelFutureListener监听,监听有回调函数,比如operationComplete函数,操作完成后会回调,这样监听器可以判断完成的操作是成功还是错误,如果是错误,可以检查返回结果的Throwable接口获取错误信息。用了ChannelFutureListener,就不需要手工判断操作是否完成。(异步调用链的全程,要么是轮询,要么是回调)

 

 

 

这篇关于[pravega-021] pravega源码分析--Controller子项目--关于netty[01]的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1050734

相关文章

MyBatis-Plus中Service接口的lambdaUpdate用法及实例分析

《MyBatis-Plus中Service接口的lambdaUpdate用法及实例分析》本文将详细讲解MyBatis-Plus中的lambdaUpdate用法,并提供丰富的案例来帮助读者更好地理解和应... 目录深入探索MyBATis-Plus中Service接口的lambdaUpdate用法及示例案例背景

MyBatis-Plus中静态工具Db的多种用法及实例分析

《MyBatis-Plus中静态工具Db的多种用法及实例分析》本文将详细讲解MyBatis-Plus中静态工具Db的各种用法,并结合具体案例进行演示和说明,具有很好的参考价值,希望对大家有所帮助,如有... 目录MyBATis-Plus中静态工具Db的多种用法及实例案例背景使用静态工具Db进行数据库操作插入

Go使用pprof进行CPU,内存和阻塞情况分析

《Go使用pprof进行CPU,内存和阻塞情况分析》Go语言提供了强大的pprof工具,用于分析CPU、内存、Goroutine阻塞等性能问题,帮助开发者优化程序,提高运行效率,下面我们就来深入了解下... 目录1. pprof 介绍2. 快速上手:启用 pprof3. CPU Profiling:分析 C

MySQL表锁、页面锁和行锁的作用及其优缺点对比分析

《MySQL表锁、页面锁和行锁的作用及其优缺点对比分析》MySQL中的表锁、页面锁和行锁各有特点,适用于不同的场景,表锁锁定整个表,适用于批量操作和MyISAM存储引擎,页面锁锁定数据页,适用于旧版本... 目录1. 表锁(Table Lock)2. 页面锁(Page Lock)3. 行锁(Row Lock

Springboot中分析SQL性能的两种方式详解

《Springboot中分析SQL性能的两种方式详解》文章介绍了SQL性能分析的两种方式:MyBatis-Plus性能分析插件和p6spy框架,MyBatis-Plus插件配置简单,适用于开发和测试环... 目录SQL性能分析的两种方式:功能介绍实现方式:实现步骤:SQL性能分析的两种方式:功能介绍记录

最长公共子序列问题的深度分析与Java实现方式

《最长公共子序列问题的深度分析与Java实现方式》本文详细介绍了最长公共子序列(LCS)问题,包括其概念、暴力解法、动态规划解法,并提供了Java代码实现,暴力解法虽然简单,但在大数据处理中效率较低,... 目录最长公共子序列问题概述问题理解与示例分析暴力解法思路与示例代码动态规划解法DP 表的构建与意义动

C#使用DeepSeek API实现自然语言处理,文本分类和情感分析

《C#使用DeepSeekAPI实现自然语言处理,文本分类和情感分析》在C#中使用DeepSeekAPI可以实现多种功能,例如自然语言处理、文本分类、情感分析等,本文主要为大家介绍了具体实现步骤,... 目录准备工作文本生成文本分类问答系统代码生成翻译功能文本摘要文本校对图像描述生成总结在C#中使用Deep

Go中sync.Once源码的深度讲解

《Go中sync.Once源码的深度讲解》sync.Once是Go语言标准库中的一个同步原语,用于确保某个操作只执行一次,本文将从源码出发为大家详细介绍一下sync.Once的具体使用,x希望对大家有... 目录概念简单示例源码解读总结概念sync.Once是Go语言标准库中的一个同步原语,用于确保某个操

Redis主从/哨兵机制原理分析

《Redis主从/哨兵机制原理分析》本文介绍了Redis的主从复制和哨兵机制,主从复制实现了数据的热备份和负载均衡,而哨兵机制可以监控Redis集群,实现自动故障转移,哨兵机制通过监控、下线、选举和故... 目录一、主从复制1.1 什么是主从复制1.2 主从复制的作用1.3 主从复制原理1.3.1 全量复制

Redis主从复制的原理分析

《Redis主从复制的原理分析》Redis主从复制通过将数据镜像到多个从节点,实现高可用性和扩展性,主从复制包括初次全量同步和增量同步两个阶段,为优化复制性能,可以采用AOF持久化、调整复制超时时间、... 目录Redis主从复制的原理主从复制概述配置主从复制数据同步过程复制一致性与延迟故障转移机制监控与维