Reactive Programming: ReactiveX

[hhstore]

related:

• Design Pattern #160 : 设计模式
• System Design #161 : 系统架构设计

[hhstore]

ReactiveX:

• Reactive Programming(响应式编程/反应式编程)
• ReactiveX是一个库，用于通过使用可观察序列来编写异步和基于事件的程序。
• 扩展观察者模式
• 微软 2012年开源.
• https://mcxiaoke.gitbooks.io/rxdocs/content/Intro.html
• 解决问题:

使用与数组集合方式
组合操作: 异步事件流
摆脱复杂的回调地狱
提高代码可读性, 降低出错性.

Rx(.NET): 微软

• http://wiki.jikexueyuan.com/project/rxjava//chapter1/microsoft_reactive_extensions.html
• 函数响应式编程是一个来自90年代后期受微软的一名计算机科学家Erik Meijer启发的思想，用来设计和开发微软的Rx库。
• Rx 是微软.NET的一个响应式扩展。
• Rx借助可观测的序列提供一种简单的方式来创建异步的，基于事件驱动的程序。
• 开发者可以使用Observables模拟异步数据流，使用LINQ语法查询Observables，并且很容易管理调度器的并发。

RxJava: Netflix开源

• https://zhuanlan.zhihu.com/p/20687178
• https://wiki.jikexueyuan.com/project/rxjava//chapter1/landing_in_the_java_world_-_netflix_rxjava.html
• Rx是微软.Net的一个响应式扩展，Rx借助可观测的序列提供一种简单的方式来创建异步的，基于事件驱动的程序。
• 2012年 Netflix 为了应对不断增长的业务需求开始将.NET Rx迁移到JVM上面。
• 并于13年二月份正式向外展示了RxJava。
• 从语义的角度来看，RxJava就是.NET Rx。
• 从语法的角度来看，Netflix考虑到了对应每个Rx方法,保留了Java代码规范和基本的模式。

RxGo:

• https://github.com/ReactiveX/RxGo

RxJs:

• https://rxjs-cn.github.io/learn-rxjs-operators/about/
• 操作符理解
• https://github.com/btroncone/learn-rxjs

项目:

• http://reactivex.io/
• https://github.com/ReactiveX
• RxJava: https://github.com/ReactiveX/RxJava
• RxJs: https://github.com/ReactiveX/rxjs
• RxGo: https://github.com/ReactiveX/RxGo
• RxPy: https://github.com/ReactiveX/RxPY

awesome:

• 中文: https://github.com/lzyzsd/Awesome-RxJava
• https://github.com/eleventigers/awesome-rxjava
• https://github.com/riiid/awesome-rx
• https://github.com/ichpuchtli/awesome-rxjs
• https://github.com/lucamezzalira/awesome-reactive-programming
• https://github.com/xgrommx/awesome-reactive-programming

教程:

• 官方: http://reactivex.io/tutorials.html
• 中文文档: https://mcxiaoke.gitbooks.io/rxdocs/content/

[hhstore]

观察者模式:

• https://www.runoob.com/design-pattern/observer-pattern.html

• https://juejin.im/post/5a14e9edf265da4312808d86

• 观察者模式:
  

• 发布/订阅模式:
  

• 对比:
  

[hhstore]

RxGo:

• https://github.com/ReactiveX/RxGo
• golang 实现

v2 版本分支:

• v2分支: https://github.com/ReactiveX/RxGo/tree/v2
• v2开发进度(里程碑): https://github.com/ReactiveX/RxGo/milestone/1
• 更改实现, 改 channel 为 interface 实现
• 增加大量算子.
• RxGo v2 ReactiveX/RxGo#99

教程:

• https://github.com/ReactiveX/RxGo/wiki

[hhstore]

ReactiveX 中文文档:

• https://mcxiaoke.gitbooks.io/rxdocs/content/

可观察对象(Observable):

• https://mcxiaoke.gitbooks.io/rxdocs/content/Observables.html

操作符(Operators):

• https://mcxiaoke.gitbooks.io/rxdocs/content/Operators.html

调度器(Scheduler):

• https://mcxiaoke.gitbooks.io/rxdocs/content/Scheduler.html

Subject( 桥梁/代理):

• https://mcxiaoke.gitbooks.io/rxdocs/content/Subject.html

[hhstore]

ReactiveX 理念:

• http://reactivex.io/intro.html
• 优点:

可观测的(observable):

• http://reactivex.io/documentation/observable.html

操作符(operators):

• http://reactivex.io/documentation/operators.html

[hhstore]

tips:

• map适用于一对一转换，当然也可以配合flatmap进行适用
• flatmap适用于一对多，多对多的场景

distinct(): 去重复

• http://wiki.jikexueyuan.com/project/rxjava//chapter4/once_and_only_once.html

filter():

• http://wiki.jikexueyuan.com/project/rxjava//chapter4/filtering_a_sequence.html

merge:

• http://wiki.jikexueyuan.com/project/rxjava//chapter6/merge.html
• 多输入, 单输出

[hhstore]

示例代码: