Reactive系统是反复被外界提示,持续的不断地对外部输出给与响应,类似命令行操作一样,有一个提示符等待你输入,只要输入无论对错总是给予响应。
RX-GDG是一个基于安卓的响应式编程的开源案例,文档见frp-android。
在安卓中每天我们经常遭遇网络 数据库和文件系统以及各种设备状态,用户输入等等,这些操作经常是依赖的比如Network -> DB -> UI,这种工作不能在UI线程中进行,因为线程的上下文切换成本是昂贵的。
基于函数的响应式编程FRP改变我们传统思路,比如迭代思考,从一个数组中获取数据传统思路如下:
for (Integer number : numbers) { // Do some work }
|
而使用FRP,我们对这个数字进行观察,等它有数据通知我们后,我们再采取行动,如下: Observable.from(numbers) .subscribe({ num -> // Do some work })
|
这种观察者API类似安卓的动画API:
view.animate() .x(10) .y(10) .duration(1000) .start();
|
FRP可以进行操作组合。
下面是不使用FRP,纯粹的回调函数嵌套,回调地狱:
apiService.login({ apiService.getUserData({ dbService.saveUserData({ uiThread.updateUI({ }) }) }) });
|
使用FRP以后解决回调嵌套地狱了: apiService.login() //Background thread .getUserData() //Background thread .saveUserData() //Background thread .subscribe(Subscriber { //UI thread void onComplete(){} void onError(Exception e){} void onNext(Object o){} });
|
更完整的源码点击标题进入GitHub项目