rxjavaflowable回收（rxjava flowable）

今天给各位分享rxjavaflowable回收的知识，其中也会对rxjava flowable进行解释，如果能碰巧解决你现在面临的问题，别忘了关注本站，现在开始吧！

本文目录一览：

1、安卓IPC跨进程通讯:AIDL+Retrofit——AndLinker的初步使用2、Reactive（响应式）编程3、Java11的新功能有哪些4、rxjava2 怎么将fromiterable在合并在一起5、RxLifecycle详细解析

安卓IPC跨进程通讯:AIDL+Retrofit——AndLinker的初步使用

需要用到安卓跨进程通讯，IPC (进程间通信) 的时候，AndLinker是一款Android上的IPC (进程间通信) 库，结合了 AIDL 和 Retrofit 的诸多特性，且可以与 RxJava 和 RxJava2 的Call Adapters无缝结合使用。

个人简单理解就是：简化AIDL流程的一个第三方库。使用时需要先了解一下AIDL、retrofit。

以普通Java接口代替AIDL接口

像 Retrofit 一样生成远程服务接口的IPC实现

支持的Call Adapters：Call， RxJava Observable， RxJava2 Observable Flowable

支持远程服务回调机制

支持AIDL的所有数据类型

支持AIDL的所有数据定向tag：in，out，inout

支持AIDL的oneway关键字

在服务端以及客户端的项目根目录的build.gradle中添加jcenter()仓库

在App的build.gradle中添加如下依赖

AndLinker支持AIDL所有数据类型：

Java语言中的所有原始类型 (如：int，long，char，boolean，等等)

String

CharSequence

Parcelable

List (List中的所有元素必须是此列表中支持的数据类型)

Map (Map中的所有元素必须是此列表中支持的数据类型)

接口里的方法就是按需求需创建。这里只举几个简单的示例。

Reactive（响应式）编程

Reactor 和Rxjava是Reactive Programming范例的一个具体实现，可以概括为：

作为反应式编程方向的第一步，Microsoft在.NET生态系统中创建了Reactive Extensions（Rx）库。然后RxJava在JVM上实现了响应式编程。随着时间的推移，通过Reactive Streams工作出现了Java的标准化，这一规范定义了JVM上的反应库的一组接口和交互规则。它的接口已经在父类Flow下集成到Java 9中。

另外Java 8还引入了Stream，它旨在有效地处理数据流（包括原始类型），这些数据流可以在没有延迟或很少延迟的情况下访问。它是基于拉的，只能使用一次，缺少与时间相关的操作，并且可以执行并行计算，但无法指定要使用的线程池。但是它还没有设计用于处理延迟操作，例如I / O操作。其所不支持的特性就是Reactor或RxJava等Reactive API的用武之地。

Reactor 或 Rxjava等反应性API也提供Java 8 Stream等运算符，但它们更适用于任何流序列（不仅仅是集合），并允许定义一个转换操作的管道，该管道将应用于通过它的数据，这要归功于方便的流畅API和使用lambdas。它们旨在处理同步或异步操作，并允许您缓冲，合并，连接或对数据应用各种转换。

首先考虑一下，为什么需要这样的异步反应式编程库？现代应用程序可以支持大量并发用户，即使现代硬件的功能不断提高，现代软件的性能仍然是一个关键问题。

人们可以通过两种方式来提高系统的能力：

通常，Java开发人员使用阻塞代码编写程序。这种做法很好，直到出现性能瓶颈，此时需要引入额外的线程。但是，资源利用率的这种扩展会很快引入争用和并发问题。

更糟糕的是，会导致浪费资源。一旦程序涉及一些延迟（特别是I / O，例如数据库请求或网络调用），资源就会被浪费，因为线程（或许多线程）现在处于空闲状态，等待数据。

所以并行化方法不是灵丹妙药，获得硬件的全部功能是必要的。

第二种方法，寻求现有资源的更高的使用率，可以解决资源浪费问题。通过编写异步，非阻塞代码，您可以使用相同的底层资源将执行切换到另一个活动任务，然后在异步处理完成后返回到当前线程进行继续处理。

但是如何在JVM上生成异步代码？ Java提供了两种异步编程模型：

但是上面两种方法都有局限性。首先多个callback难以组合在一起，很快导致代码难以阅读以及难以维护（称为“Callback Hell”）:

考虑下面一个例子：在用户的UI上展示用户喜欢的top 5个商品的详细信息，如果不存在的话则调用推荐服务获取5个；这个功能的实现需要三个服务支持：一个是获取用户喜欢的商品的ID的接口（userService.getFavorites），第二个是获取商品详情信息接口（favoriteService.getDetails），第三个是推荐商品与商品详情的服务（suggestionService.getSuggestions），基于callback模式实现上面功能代码如下：

如上为了实现该功能，我们写了很多代码，使用了大量callback,这些代码比较晦涩难懂,并且存在代码重复，下面我们使用Reactor来实现等价的功能：

future相比callback要好一些，但尽管CompletableFuture在Java 8上进行了改进，但它们仍然表现不佳。一起编排多个future是可行但是不容易的，它们不支持延迟计算（比如rxjava中的defer操作）和高级错误处理，例如下面例子。考虑另外一个例子：首先我们获取一个id列表，然后根据id分别获取对应的name和统计数据，然后组合每个id对应的name和统计数据为一个新的数据，最后输出所有组合对的值，下面我们使用CompletableFuture来实现这个功能，以便保证整个过程是异步的，并且每个id对应的处理是并发的：

Reactor本身提供了更多的开箱即用的操作符，使用Reactor来实现上面功能代码如下:

如上代码使用reactor方式编写的代码相比使用CompletableFuture实现相同功能来说，更简洁，更通俗易懂。

可组合性，指的是编排多个异步任务的能力，使用先前任务的结果作为后续任务的输入或以fork-join方式执行多个任务。

编排任务的能力与代码的可读性和可维护性紧密相关。随着异步过程层数量和复杂性的增加，能够编写和读取代码变得越来越困难。正如我们所看到的，callback模型很简单，但其主要缺点之一是，对于复杂的处理，您需要从回调执行回调，本身嵌套在另一个回调中，依此类推。那个混乱被称为Callback Hell，正如你可以猜到的（或者从经验中得知），这样的代码很难回归并推理。

Reactor提供了丰富的组合选项，其中代码反映了抽象过程的组织，并且所有内容通常都保持在同一级别（嵌套最小化）。

原材料可以经历各种转换和其他中间步骤，或者是将中间元素聚集在一起形成较大装配线的一部分。如果在装配线中某一点出现堵塞，受影响的工作站可向上游发出信号以限制原材料的向下流动。

虽然Reactive Streams规范根本没有指定运算符，但Reactor或者rxjava等反应库的最佳附加值之一是它们提供的丰富的运算符。这些涉及很多方面，从简单的转换和过滤到复杂的编排和错误处理。

在Reactor中，当您编写Publisher链时，默认情况下数据不会启动。相反，您可以创建异步过程的抽象描述（这可以帮助重用和组合）。

上游传播信号也用于实现背压，我们在装配线中将其描述为当工作站比上游工作站处理速度慢时向上游线路发送的反馈信号。

这将推模型转换为推拉式混合模式，如果上游生产了很多元素，则下游可以从上游拉出n个元素。但是如果元素没有准备好，就会在上游生产出元素后推数据到下游。

Java11的新功能有哪些

Java 11 JDK中已计划的新功能

目前来看，JDK 11已有九个已经确认的新功能，而且还有更多新功能仍在考虑之中。计划的新功能包括：

HTTP客户端（标准），这个功能于JDK 9中引入并在JDK 10中得到了更新，现在终于转正了。该API通过CompleteableFutures提供非阻塞请求和响应语义，可以联合使用以触发相应的动作。自从JDK 9和10中引入该功能后，JDK 11完全重写了该功能，现在其实现完全是异步的。RX Flow的概念也得到了实现，这样就无需为了支持HTTP/2而创造许多概念了。现在，在用户层请求发布者和响应发布者与底层套接字之间追踪数据流更容易了。这降低了复杂性，并最大程度上提高了HTTP/1和HTTP/2之间的重用的可能性。Epsilon垃圾回收器，被称为“no-op”回收器，它仅负责内存分配，却没有实现任何实际的内存回收机制。Epsilon回收器可以用于性能测试、内存压力测试和虚拟机接口。它还可以用于短生命周期的任务。lambda参数的局部变量语法，可以消除隐含类型表达式中正式参数定义的语法与局部变量定义语法的不一致。这样就能在隐含类型的lambda表达式中定义正式参数时使用var了。Java的类文件格式将被扩展，以支持新的常量池，CONSTANT_Dynamic。其目标是降低开发新形式的可实现类文件约束带来的成本和干扰。采用Curve25519和Curve448加密的密钥交换比现有的Diffie-Hellman椭圆曲线密钥交换方式更有效、更安全。根据IETF的资料，Curve25519和Curve448两种椭圆曲线采用常量时间的实现方式，以及不会发生异常的数乘实现，能更好地抵抗各种旁路攻击，包括时序攻击、缓存攻击等。该提案的目标是为密钥交换方法提供一个API和实现，同时开发一个平台无关、纯Java的的实现。由于该提案采用了复杂且精密的模算数，因此还是有风险的。飞行记录仪（Flight Recorder）将提供低开销的数据收集框架，用来调试Java应用程序和HotSpot JVM。飞行记录仪是Oracle的商业版JDK的功能，但在JDK 11中，其代码将移动到公开代码库中，这样所有人都能使用该功能了。Iclouded将作为API，以事件的形式产生或消耗数据，同时提供缓存机制、二进制数据工具，同时支持配置和事件过滤。该提案还提议为OS、HotSpot和JDK库提供事件。更新platform API以支持Unicode版本10.0，从而使Java跟上潮流。预计以下的类将支持：lang包中的Character和Stringawt.font包中的NumericShapertext包中的Bidi、BreakIterator和Normalizer实现ChaCha20和Poly1305加密算法。ChaCha20是种相对较新的流加密算法，能代替旧的、不安全的R4流加密。ChaCha20将与Poly1305认证算法配对使用。ChaCha20和ChaCha20-Poly1305加密实现将通过crypto.CipherSpi API于SunJCE（Java加密扩展）中提供。增强Java启动器，使之能够运行单一文件的Java源代码，使得应用程序可以直接从源代码运行。单文件程序常见于小型工具，或开发者初学Java时使用。而且，单一源代码文件有可能会编译成多个类文件，这会增加打包开销。由于这些原因，在运行程序之前进行编译，已成为了不必要的步骤。Java JDK 11仍在开发中的新功能

Java 11的创建者们还在考虑几个对JDK 11的变更或新功能的提案：

给Java添加raw字符串字面值。这样可以更容易地以人类可阅读的形式书写字符序列，而无需特殊的Java标记。这样也能更容易地将非Java语法的字符串提供给Java使用，还能支持多行字符串，而无需使用特殊的标记。扩展switch语句，使之能作为语句或表达式使用。这样还能改进switch处理null值的方式。这些改动可以简化编程，同时为switch支持模式匹配做准备。嵌套的访问控制，对应于Java当前的嵌套类型。嵌套可以让逻辑上属于同一代码实体但被编译到不同的类文件中的类互相访问对方的私有成员，而无需让编译器插入扩大访问权限的方法。JDK 11删除的功能

Java EE和CORBA模块从Java SE9就成了不推荐使用（deprecated），并计划在未来的版本中删除。这个未来版本就是JDK 11。

Java SE 6于2006年12越发布，它为Java EE平台提供了整套的Web服务技术栈：JAX-WS（Java API for XML-based Web Services），JAXB（Java Architecture for XML Binding），JAF（JavaBeans Activation Framework），以及Common Annotations for Java。这些年来，Java EE版本在不断进化，这给Java SE造成了许多麻烦，例如加入与Java SE无关的技术，以及同时维护两个Java版本的困难变得更大。由于独立的Java EE版本由第三方网站提供，Oracle说Java SE或JDK中已经没有必要提供Java EE了。

当然，一些依赖于JDK中的Java EE API及工具的应用程序将无法编译或运行。将JDK 6、7或8移植到新版本时将会产生二进制不兼容和源代码不兼容。Oracle说，受到这些影响的开发者可以部署相应的Java EE版本。

CORBA来自于二十世纪九十年代，Oracle说，现在用CORBA开发现代Java应用程序已经没有意义了，维护CORBA的成本已经超过了保留它带来的好处。

但是删除CORBA将使得那些依赖于JDK提供部分CORBA API的CORBA实现无法运行。目前还没有第三方CORBA版本，也不确定是否会有第三方愿意接手CORBA API的维护工作。

JavaFX已经被移除，因此已经与Java JDK每年两次的更新无关。

rxjava2 怎么将fromiterable在合并在一起

假设我的 Flowable 发射的是一个列表，接收者要把列表内容依次输出。根据上一篇blog的内容，你可以会写出这样的代码:

ListInteger list = new ArrayList()

RxLifecycle详细解析

RxLifecycle 目的：解决 RxJava 使用中的内存泄漏问题。

例如，当使用 RxJava 订阅并执行耗时任务后，当 Activity 被 finish 时，如果耗时任务还未完成，没有及时取消订阅，就会导致 Activity 无法被回收，从而引发内存泄漏。

为了解决这个问题，就产生了 RxLifecycle ，让 RxJava 变得有生命周期感知，使得其能及时取消订阅，避免出现内存泄漏问题。

首先来介绍下 RxLifecycle 的使用。

Activity/Fragment 需要继承 RxAppCompatActivity/RxFragment ，主要支持如下几种容器类：

以 Activity 为例，主要有如下两种方法：

针对 Fragment 也有同样的两种方法，只是方法名会有所不同。

下面详细介绍这两种方法的区别：

该方法指定在哪个生命周期方法调用时取消订阅。

其中 ActivityEvent 是一个枚举类，对应于 Activity 的生命周期。

具体使用示例：

指定在生命周期 onDestory() 时，取消订阅。

在某个生命周期进行绑定，在对应的生命周期进行订阅解除。

具体使用示例：

在 onResume() 进行绑定订阅，则在 onPause() 进行解除订阅，生命周期是两两对应的。

首先来了解一下 compose 操作符。

如上所示，两种绑定生命周期的方式，都是通过 compose 操作符进行实现的。

compose 一般情况下可以配合 Transformer 使用，以实现将一种类型的 Observable 转换成另一种类型的 Observable ，保证调用的链式结构。

那么接下来看该操作符在 RxLifecycle 中的应用，从 bindToLifecycle 和 bindUntilEvent 入手。

RxAppCompatActivity 中有一个关键对象 BehaviorSubject

BehaviorSubject 会发送离订阅最近的上一个值，没有上一个值的时候会发送默认值。如下图：

所以 lifecycleSubject 会根据绑定订阅的时期，不断发送接下来的生命周期事件 ActivityEvent 。

接下来继续看源码， bindToLifecycle 和 bindUntilEvent 都返回了一个 LifecycleTransformer 对象，那么 LifecycleTransformer 到底有什么用？

LifecycleTransformer 实现了各种 Transformer 接口，能够将一个 Observable/Flowable/Single/Completable/Maybe 对象转换成另一个 Observable/Flowable/Single/Completable/Maybe 对象。正好配合上文的 compose 操作符，使用在链式调用中。

接下来到了关键了， LifecycleTransformer 到底把原来的 Observable 对象转换成了什么样子？

这就需要了解 takeUntil 操作符了！

理解了该操作符的作用，那么你可能就明白了， RxLifecycle 就是通过监听第二个 Observable 发射的数据，来解除订阅。

那么这第二个 Observable 是谁？

不就是在创建 LifecycleTransformer 的时候传入构造函数中的嘛，那就来寻找一下什么时候创建的该对象即可。

从头开始捋一捋：

该方法返回了 LifecycleTransformer 对象，继续向下追溯。

继续追踪，马上接近真相。

在该方法中创建了该对象，并传入了一个 Observable 对象，通过上面方法即可知道该对象就是 BehaviorSubject 对象。

那么该对象在什么时候发送第一次数据呢？

这就要看上面的 takeUntilEvent 方法了。

关键在这一句 lifecycleEvent.equals(event) ，只有当 BehaviorSubject 发送的 ActivityEvent 的值等于解除绑定的生命周期时，才会发送第一次数据。那么当发送第一次数据时，根据上面的分析就会解除订阅的绑定。