比如在调用线程里面异步打日志，为了不让日志打印阻塞调用线程，会把日志设置为异步方式。如图 所示的日志异步化打印，使用一个内存队列把日志打印异步化，然后使用单一消费线程异步处理内存队列中的日志事件，执行具体的日志落盘操作（本质是一个多生产单消费模型），在这种情况下，调用线程把日志任务放入队列后会继续执行其他操作，而不再关心日志任务具体是什么时候入盘的。
相信大家对Okhttp的责任链模式应该已经很熟悉了，今天给大家普及另外一种有意思的玩法。
通常Java开发人员喜欢使用同步代码编写程序,因为这种请求(request)/响应(response)的方式比较简单，并且比较符合编程人员的思维习惯;这种做法很好，直到系统出现性能瓶颈；在同步编程方式时由于每个线程同时只能发起一个请求并同步等待返回，所以为了提高系统性能，此时我们就需要引入更多的线程来实现并行化处理；但是多线程下对共享资源进行访问时，不可避免会引入资源争用和并发问题；另外操作系统层面对线程的个数是有限制的，不可能通过无限的增加线程数来提供系统性能；最后使用同步阻塞的编程方式还会导致浪费资源，比如发起网络IO请求时候，调用线程就会处于同步阻塞等待响应结果的状态，而这时候调用线程明明可以去做其他事情，等网络IO响应结果返回后在对结果进行处理。
代码下载地址：https://github.com/f641385712/netflix-learning
我从去年开始使用 RxJava ，到现在一年多了。今年加入了 Flipboard 后，看到 Flipboard 的 Android 项目也在使用 RxJava ，并且使用的场景越来越多 。而最近这几个月，我也发现国内越来越多的人开始提及 RxJava 。有人说『RxJava 真是太好用了』，有人说『RxJava 真是太难用了』，另外更多的人表示：我真的百度了也谷歌了，但我还是想问： RxJava 到底是什么？
我是从小公司跳出来的，最终入职OPPO，说实话这段时间的经历让我深深地感受到，我们为跳槽做的一些临时抱佛脚的提升跟那些大佬的沉淀比起来太渺小了。我们都知道找资料学习、刷面试题，但也许只能应付这一次的面试，后面还是会技术发愁，那些短时间背下来的东西迟早会忘掉，大家还是做好长期提升自己的准备，好好沉淀的东西最后才是属于自己的。
链接：https://juejin.im/post/5d3374cee51d4556bb4cd469
第一次接触RxJava是在前不久，一个新Android项目的启动，在评估时选择了RxJava。RxJava是一个基于事件订阅的异步执行的一个类库。听起来有点复杂，其实是要你使用过一次，就会大概明白它是怎么回事了！为是什么一个Android项目启动会联系到RxJava呢？因为在RxJava使用起来得到广泛的认可，又是基于Java语言的。自然会有善于组织和总结的开发者联想到Android！没错，RxAndroid就这样在RxJava的基础上，针对Android开发的一个库。今天我们主要是来讲解一下RxJava，在接下来的几篇博客中我会陆续带大家来认识RxAndroid，Retrofit框架的使用，这些都是目前比较火的一些技术框架！
在上两篇介绍中我们把RxJava的基本概念和基本原理说明了。它为什么会大行其道，主要是因为它在线程切换，代码逻辑简洁度有非常好的体验。 如果你还不了解RxJava的特点的话，可以参考这两篇文章 五分钟带你感受RxJava的优雅 零基础理解RxJava和响应式编程
Promise 和 Observables 都能够帮助我们在JavaScript 中使用异步功能。Promise 是以异步方式解析值，例如 HTTP 调用。当异步操作完成或失败时，它只处理单个事件。
说到Redis的通信，我们都知道Redis基于RESP(Redis Serialization Protocol)协议来通信，并且通信方式是停等模型，也就说一次通信独占一个连接直到client读取到返回结果之后才能释放该连接让其他线程使用。
1.RxJava概述 ReactiveX与RxJava 在讲到RxJava之前我们首先要了解什么是ReactiveX，因为RxJava是ReactiveX的一种Java实现。 ReactiveX是Reactive Extensions的缩写，一般简写为Rx，微软给的定义是，Rx是一个函数库，让开发者可以利用可观察序列和LINQ风格查询操作符来编写异步和基于事件的程序，开发者可以用Observables表示异步数据流，用LINQ操作符查询异步数据流， 用Schedulers参数化异步数据流的并发处理，Rx可
这是一篇译文，原文出处(http://alexsderkach.io/comparing-java-8-rxjava-reactor/)。其实很久以前我就看完了这篇文章，只不过个人对响应式编程研究的不够深入，羞于下笔翻译，在加上这类译文加了原创还有争议性，所以一直没有动力。恰逢今天交流群里两个大佬对响应式编程的话题辩得不可开交，趁印象还算深刻，借机把这篇文章翻译一下。说道辩论的点，不妨也在这里抛出来：
Google 为了帮助 Android 开发者更快更好地开发 App，推出了一系列组件，这些组件被打包成了一个整体，称作 Android Jetpack，它包含的组件如下图所示：
距离上一次更新关于RxJava也有一段时间了，其实这篇文章我早就想写，碍于一直没来得及总结（懒）。所以一直没有成文，今天就来总结一下我RxJava遇到的坑，或者说我为什么不在推荐使用RxJava。
本文转载自我的好基友老梁老司机，一文带你领略AAC的魅力。 Google 为了帮助 Android 开发者更快更好地开发 App，推出了一系列组件，这些组件被打包成了一个整体，称作 Android Jetpack，它包含的组件如下图所示：
链接 : https://juejin.im/post/5cd04b6e51882540e53fdfa2
Android工程引入RxJava-android 请引入Rxandroid库： compile 'io.reactivex:rxandroid:1.2.1' 一简介 1.1 Rx结构 响应式编程的主要组成部分是observable, operator和susbscriber,一般响应式编程的信息流如下所示： Observable -> Operator 1 -> Operator 2 -> Operator 3 -> Subscriber 也就是说，observable是事件的生产者，subscriber是事件最终的消费者。 因为subscriber通常在主线程中执行，因此设计上要求其代码尽可能简单，只对事件进行响应，而修改事件的工作全部由operator执行。 在响应式编程中，应该牢记以下两点：everything is a stream（一切皆流）don't break the chain（不要打断链式结构） 1.2 最简单的模式 如果我们不需要修改事件，就不需要在observable和subscriber中插入operator。这时的Rx结构如下： Obsevable -> Subscriber 这看起来很像设计模式中的观察者模式，他们最重要的区别之一在于在没有subscriber之前，observable不会产生事件。
很早前就看了RxJava，当时就觉得好牛掰，但是公司项目一直没有用起来，知识不用就会忘，前段时间突然要写RxJava，发现已经不会写了。所以今天再回头整理一下RxJava的头绪，一方面给其它想了解RxJava的人提供参考，另一方面也是给自己将来再遗忘时回来翻阅。
业务当中写Android异步任务一直是一项挑战，以往的回调和线程管理方式比较复杂和繁琐，造成代码难以维护和阅读。在前端领域中JavaScript其实也面临同样的问题，Promise 就是它的比较主流的一种解法。在尝试使用Promise之前我们也针对Android现有的一些异步做了详细的对比。
前言 最近经常看到RxJava这个字眼，也看到很多人在博客中推荐使用RxJava。好奇的我怎么能错过，于是Google了一下，说RxJava好用的和说RxJava难用的都有，于是自己也亲自尝试了一下（感觉不容易上手）。写博客记录下学习的过程，一方面作为巩固，另一方面希望能帮助到初学者。 （第一篇只介绍了RxJava的基本用法，暂时还无法看出RxJava的优势。切莫着急，随着慢慢深入就能体会到RxJava带来的方便了） 参考：给 Android 开发者的 RxJava 详解 （本文部分内容引用自该博客）
前言 上一篇的示例代码中大家一定发现了Observable这个类。从纯Java的观点看，Observable类源自于经典的观察者模式。RxJava的异步实现正是基于观察者模式来实现的，而且是一种扩展的观察者模式。 观察者模式 观察者模式基于Subject这个概念，Subject是一种特殊对象，又叫做主题或者被观察者。当它改变时那些由它保存的一系列对象将会得到通知，而这一系列对象被称作Observer(观察者)。它们会对外暴漏了一个通知方法(比方说update之类的)，当Subject状态发生变化时会调用
RxJava的编程思想已经在Android开发者中变得越来越流行。有个不好的点就是上手不太容易，尤其是大部分人之前都是使用命令式编程语言。
RxJava发展到现在已经在2016年推出了第二代。可能你听说过很多人讲起RxJava，但是很少在实际项目开发中用到它。 原因很简单，RxJava虽然很好用，但是它有一定的学习成本。很多人只是知道这么个东西，但是没有真正的去学习和推动RxJava。毕竟会觉得即使没有RxJava也一样能写好代码。 其实它的学习成本和带来的收益对比的话，是非常值得花点时间去学的。当你切换到Rx编程思维之后，会发现很多以前难以处理的问题在响应式编程下都变得易如反掌。 而很多公司没有推进RxJava的原因，主要在于船大难掉头。笔者见过一个上亿日活的项目，至今还在用ant构建。可想而知还有许多新技术受限于项目的历史原因没法应用。 另一个推动RxJava困难的原因在于开发团队水平层次不齐。如果你的团队里有成员连并发和线程都搞不清楚的话，RxJava可能只能带来负面效果。
今天，我将为大家带来 Rxjava的的基本使用 & 实际应用案例教学，即常见开发应用场景实现 ，并结合常用相关框架如Retrofit等，希望大家会喜欢。
内部类和内部匿名类会导致内存泄漏，所以很多时候异步代码写的很多。之后一直在想，异步代码到底应该怎么写。怎么才是规范的写法。怎么才是简洁的写法。
前言 Rxjava由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点，深受各大 Android开发者的欢迎。 如果还不了解RxJava，请看文章：Android：这是一篇 清晰 & 易懂的Rx
概述 RxJava是一个在 Java VM 上使用可观测的序列来组成异步的、基于事件的程序的库。更重要的是：使用RxJava在代码逻辑上会非常简洁明了，尤其是在复杂的逻辑上。告别迷之缩进。 RxAnd
在很多软件编程任务中，或多或少你都会期望你写的代码能按照编写的顺序，一次一个的顺序执行和完成。但是在ReactiveX中，很多指令可能是并行执行的，之后他们的执行结果才会被观察者捕获，顺序是不确定的。为达到这个目的，你定义一种获取和变换数据的机制，而不是调用一个方法。在这种机制下，存在一个可观察对象(Observable)，观察者(Observer)订阅(Subscribe)它，当数据就绪时，之前定义的机制就会分发数据给一直处于等待状态的观察者哨兵。
顾名思义，Scheduler是一种用来对RxJava流操作进行调度的类，从Scheduler的工厂方法可以获取现有调度器的实现，如下：
这篇文章是我介绍Eclipse Vert.x系列的第五篇文章。在上一篇文章中，我们看到了Vert.x如何与数据库交互。我们使用Future对象来驯服Vert.x的异步特性。在这篇文章中，我们将看到另一种管理异步代码的方式：反应式编程。我们将看到Vert.x如何与Reactive eXtensions结合来为您提供巨大的能量。
Retrofit2 是目前Android开发主流的网络库，RxJava2也是目前开发者使用的比较多用来更优雅实现异步的库，因为最近业务需求有用到这两个库，就简单分享下它的一个实际使用场景—上传文件 [TOC] 集成RxJava2和Retrofit2 // Rx compile rootProject.ext.dependencies["rxjava"] compile rootProject.ext.dependencies["rxandroid"] compile root
Reactor 项目始于 2012 年。 经过长时间的内部孵化，于 2013 年发布 Reactor 1.x 版本。 Reactor 1 在各种架构下都能成功部署，包括开源的(如 Meltdown)和商业的(如 Pivotal RTI)。2014年，通过与一些新兴的响应式数据流规范合作，重新设计并于 2015 年 4 月发布 Reactor 2.0 版本。
在 Android 应用开发中，异步编程是不可避免的，而 Kotlin Flow 是一个强大的库，能够使异步操作更加优雅和易于管理。本文将深入探讨 Kotlin Flow 的使用方法，同时也会解析其背后的实现原理，帮助你更好地理解这一技术。
RxJava的被观察者在使用操作符时可以利用线程调度器--Scheduler来切换线程，例如
每个Android开发者，都是爱RxJava的,简洁线程切换和多网络请求合并，再配合Retrofit,简直是APP开发的福音。不知不觉，RxJava一路走来，已经更新到第三大版本了。不像RxJava 2对RxJava 1那么残忍，RxJava 3对RxJava 2的兼容性还是挺好的，目前并没有做出很大的更改。RxJava2到2020年12月31号不再提供支持，错误的会同时在2.x和3.x修复，但新功能只会在3.x上添加。
Gradle 项目中 , 在 build.gradle 构建脚本中 , 添加如下依赖 ;
前言 提升开发效率，降低维护成本一直是开发团队永恒不变的宗旨。近一年来国内的技术圈子中越来越多的开始提及Rx，经过一段时间的学习和探索之后我也深深的感受到了RxJava的魅力。它能帮助我们简化代码逻辑，提升代码可读性。这对于开发效率的提升、后期维护成本的降低帮助都是巨大的。个人预测RxJava一定是2016年的一个大趋势，所以也有打算将它引入到公司现有的项目中来，写这一系列的文章主要也是为了团队内部做技术分享。 由于我本人是个Android程序猿，因此这一系列文章中的场景都是基于Android平台的。如
最近在Android编程领域，RxJava这个框架的技术热度相当的高。团队对使用RxJava改进目前的项目代码也表示很有兴趣，所以我特地和团队伙伴一起对这套框架做了一下调研。现在就把目前对RxJava的一些理解和粗浅的分析做一下分享，欢迎大家拍砖。 1.什么是RxJava 要了解什么是RxJava，先需要了解一下它的理念来源：ReactiveX。 ReactiveX是Reactive Extensions的缩写，一般简写为Rx，最初是LINQ的一个扩展，由微软的架构师Erik Meijer领导的团队开发
ReactiveX 响应式编程库，这是一个程序库，通过使用可观察的事件序列来构成异步和事件驱动的程序。
我们在日常开发中经常用多线程优化性能，其实不过就是将串行操作变成并行操作。如果仔细观察，你还会发现在串行转换成并行的过程中，一定会涉及到异步化，例如下面的示例代码，现在是串行的，为了提升性能，我们得把它们并行化，那具体实施起来该怎么做呢？
在Android开发中，协程（Coroutines）作为一种异步编程的解决方案，已经成为开发者关注的热点之一。本文将从面试官的角度，围绕Android协程展开一系列高级疑难的面试问题，深入解析相关知识点，旨在帮助读者更好地理解和应对复杂的协程场景。
关于RxJava可以说的很多，但是要想了解RxJava的核心，只有从操作符去切入。
总的来说，EventBus是一款针对Android优化的发布/订阅事件总线，主要功能是替代Intent,Handler,BroadCast在Fragment，Activity，Service，线程之间传递消息。而Rxjava则是一种基于异步数据流的处理方案。如果一个订阅者需要注册多个事件的时候，Rxjava需要一个个单独的注册，而EventBus则可以实现一个订阅者订阅多个事件，和一个事件对应多个订阅者。
熟悉RxJava的同学，当我们开启一个异步任务时，通常需要在Activity/Fragment销毁时，及时关闭异步任务，否则就会有内存泄漏的。
前言 提升开发效率，降低维护成本一直是开发团队永恒不变的宗旨。近一年来国内的技术圈子中越来越多的开始提及Rx，经过一段时间的学习和探索之后我也深深的感受到了RxJava的魅力。它能帮助我们简化代码逻辑，提升代码可读性。这对于开发效率的提升、后期维护成本的降低帮助都是巨大的。个人预测RxJava一定是2016年的一个大趋势，所以也有打算将它引入到公司现有的项目中来，写这一系列的文章主要也是为了团队内部做技术分享。 由于我本人是个Android程序猿，因此这一系列文章中的场景都是基于Android平台的。
各自的职责：Retrofit 负责请求的数据和请求的结果，使用接口的方式呈现；OkHttp 负责请求的过程；RxJava 负责异步，各种线程之间的切换。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
