RxJava反应式编程
张卫滨 译
出版时间：2019年12月
页数：306
如今，移动App驱动着我们的生活，程序的异步性和响应式至关重要。反应式编程技术能够帮助我们编写易于扩展、性能良好且可靠性强的代码。在这本注重实战的图书中，Java开发人员首先将会学习如何以反应式的方式看待问题，然后再借助这一令人兴奋的编程范式的优秀特性构建程序。
本书包含了一些使用RxJava的具体样例，用来解决Android设备和服务器端的实际性能问题。你将会学到RxJava如何借助并行和并发解决当前的问题。本书还特别收录了2.0版本的基本情况。
● 编写对多个异步源输入进行响应的程序，避免陷入“回调地狱”
● 理解如何以反应式的方式解决问题
● 处理Observable生产数据太快的问题
● 探索调试和测试反应式程序的策略
● 在程序中高效利用并行和并发
● 学习如何迁移至RxJava 2.0版本
本书包含了一些使用RxJava的具体样例，用来解决Android设备和服务器端的实际性能问题。你将会学到RxJava如何借助并行和并发解决当前的问题。本书还特别收录了2.0版本的基本情况。
● 编写对多个异步源输入进行响应的程序，避免陷入“回调地狱”
● 理解如何以反应式的方式解决问题
● 处理Observable生产数据太快的问题
● 探索调试和测试反应式程序的策略
● 在程序中高效利用并行和并发
● 学习如何迁移至RxJava 2.0版本
- 本书赞誉
- 译者序
- 序
- 前言
- 第 1 章 使用RxJava实现反应式编程
- 1.1 反应式编程与RxJava
- 1.2 何时需要反应式编程
- 1.3 RxJava是如何运行的
- 1.3.1 推送与拉取
- 1.3.2 异步与同步
- 1.3.3 并发与并行
- 1.3.4 延迟执行与立即执行
- 1.3.5 双重性
- 1.3.6 基数
- 1.4 阻塞I O与非阻塞I O
- 1.5 反应式抽象
- 第2章 Reactive Extensions
- 2.1 剖析rx.Observable
- 2.2 订阅来自Observable的通知
- 2.3 使用Subscription和Subscriber控制监听器
- 2.4 创建Observable
- 2.4.1 掌握Observable.create()
- 2.4.2 无穷流
- 2.4.3 计时：timer() 和interval()
- 2.4.4 hot和cold类型的Observable
- 2.5 用例：从回调API到Observable流
- 2.6 rx.subjects.Subject
- 2.7 ConnectableObservable
- 2.7.1 使用publish().refCount()实现单次订阅
- 2.7.2 ConnectableObservable 的生命周期
- 2.8 小结
- 第3章 操作符与转换
- 3.1 核心的操作符：映射和过滤
- 3.1.1 使用map()进行一对一转换
- 3.1.2 使用flatMap()进行包装
- 3.1.3 使用delay()操作符延迟事件
- 3.1.4 flatMap()之后的事件顺序
- 3.1.5 使用concatMap()保证顺序
- 3.2 多个Observable
- 3.2.1 使用merge()将多个Observable合并为一个
- 3.2.2 使用zip()和zipWith()进行成对地组合
- 3.2.3 流之间不同步的情况：combineLatest()、withLatestFrom()和amb()
- 3.3 高级操作符：collect()、reduce()、scan()、distinct()和groupBy()
- 3.3.1 使用Scan和Reduce扫描整个序列
- 3.3.2 使用可变的累加器进行缩减：collect()
- 3.3.3 使用single()断言的Observable只有一个条目
- 3.3.4 使用distinct()和distinctUntilChanged()丢弃重复条目
- 3.4 使用skip()、takeWhile()等进行切片和切块
- 3.4.1 组合流的方式：concat()、merge()和switchOnNext()
- 3.4.2 使用groupBy()实现基于标准的切块流
- 3.4.3 下一步要学习什么
- 3.5 编写自定义的操作符
- 3.5.1 借助compose()重用操作符
- 3.5.2 使用lift()实现高级操作符
- 3.6 小结
- 第4章 将反应式编程应用于已有应用程序
- 4.1 从集合到Observable
- 4.2 BlockingObservable：脱离反应式的世界
- 4.3 拥抱延迟执行
- 4.4 组合Observable
- 4.5 命令式并发
- 4.6 flatMap()作为异步链接操作符
- 4.7 使用Stream代替回调
- 4.8 定期轮询以获取变更
- 4.9 RxJava的多线程
- 4.9.1 调度器是什么
- 4.9.2 使用subscribeOn()进行声明式订阅
- 4.9.3 subscribeOn()的并发性和行为
- 4.9.4 使用groupBy()进行批量请求
- 4.9.5 使用observeOn()声明并发
- 4.9.6 调度器的其他用途
- 4.10 小结
- 第5章 实现完整的反应式应用程序
- 5.1 解决C10k问题
- 5.1.1 传统的基于线程的HTTP服务器
- 5.1.2 借助Netty和RxNetty实现非阻塞的HTTP服务器
- 5.1.3 阻塞式和反应式服务器的基准测试
- 5.1.4 反应式HTTP服务器之旅
- 5.2 HTTP客户端代码
- 5.3 关系数据库访问
- 5.4 CompletableFuture与Stream
- 5.4.1 CompletableFuture概述
- 5.4.2 与CompletableFuture进行交互
- 5.5 Observable与Single
- 5.5.1 创建和消费Single
- 5.5.2 使用zip、merge和concat组合响应
- 5.5.3 与Observable和CompletableFuture的交互
- 5.5.4 何时使用Single
- 5.6 小结
- 第6章 流控制和回压
- 6.1 流控制
- 6.1.1 定期采样和节流
- 6.1.2 将事件缓冲至列表中
- 6.1.3 窗口移动
- 6.1.4 借助debounce()跳过陈旧的事件
- 6.2 回压
- 6.2.1 RxJava中的回压
- 6.2.2 内置的回压
- 6.2.3 Producer与缺失回压场景
- 6.2.4 按照请求返回指定数量的数据
- 6.3 小结
- 第7章 测试和排错
- 7.1 错误处理
- 7.1.1 我的异常在哪里
- 7.1.2 替代声明式的try-catch
- 7.1.3 事件没有发生导致的超时
- 7.1.4 失败之后的重试
- 7.2 测试和调试
- 7.2.1 虚拟时间
- 7.2.2 单元测试中的调度器
- 7.3 单元测试
- 7.4 监控和调试
- 7.4.1 doOn...()回调
- 7.4.2 测量和监控
- 7.5 小结
- 第8章 案例学习
- 8.1 使用RxJava进行Android开发
- 8.1.1 避免Activity中的内存泄漏
- 8.1.2 Retrofit对RxJava的原生支持
- 8.1.3 Android中的调度器
- 8.1.4 将UI事件作为流
- 8.2 使用Hystrix管理失败
- 8.2.1 使用Hystrix的第一步
- 8.2.2 使用HystrixObservableCommand的非阻塞命令
- 8.2.3 舱壁模式和快速失败
- 8.2.4 批处理和合并命令
- 8.2.5 监控和仪表盘
- 8.3 查询NoSQL数据库
- 8.3.1 Couchbase客户端API
- 8.3.2 MongoDB客户端API
- 8.4 Camel集成
- 8.4.1 通过Camel来消费文件
- 8.4.2 接收来自Kafka的消息
- 8.5 Java 8的Stream和CompletableFuture
- 8.5.1 并行流的用途
- 8.5.2 选择恰当的并发抽象
- 8.5.3 何时使用Observable
- 8.6 内存耗费和泄漏
- 8.7 小结
- 第9章 未来的方向
- 9.1 反应式流
- 9.2 Observable和Flowable
- 9.3 性能
- 9.4 迁移
- 附录A HTTP服务器的更多样例
- 附录B Observable操作符的决策树
- 附录C RxJava 1.0至RxJava 2.0的迁移指南
书名：RxJava反应式编程
译者：张卫滨 译
国内出版社：人民邮电出版社
出版时间：2019年12月
页数：306
书号：978-7-115-52400-3
原版书书名：Reactive Programming with RxJava
原版书出版商：O'Reilly Media
购买选项
|
© 2024，奥莱利技术咨询(北京)有限公司。版权所有。 传真: +86-10-88097463 京ICP备05003502号 |
|