Android Flux 架构
2018-07-05 本文已影响0人
怀念々小時候
Android Flux 框架
github地址：https://github.com/tianwei0828/FluxDemo 欢迎大家star
参考facebook https://facebook.github.io/flux/ 提出的flux设计理念，将单向数据流动的思想应用在Android App框架中，采用kotlin语言并结合主流开源框架(1、Rxkotlin 2、Retrofit 3、Okhttp 4、EventBus 5、rxbinding等)打造出Android Flux框架。
一、框架对比
1、MVC
各层职责：
V：一般采用XML文件进行界面的描述
C：Android的控制层的重任通常落在了众多的Activity的肩上,控制V层和M层通信以此来达到分离视图显示和业务逻辑层
M：针对业务模型，建立的数据结构和相关的类，与View无关，而与业务相关的。对数据库的操作、对网络等的操作都应该在Model里面处理
优点：
1、易于理解
2、开发速度快
缺点：
1、XML作为V层，不能动态改变，这就需要Activity承担部分V层逻辑
2、Activity不仅仅承担C层，而且承担了V层的逻辑
3、随着界面及其逻辑的复杂度不断提升，Activity类的职责不断增加，以致变得庞大臃肿
4、V层和M层是相互可知的，这意味着两层之间存在耦合
2、MVP
image
各层职责：
V：XML+Activity+Fragment等
P：作为V层与M层交互的中间纽带，处理与用户交互的业务逻辑
M：同上
优点：
1、Activity承担的更多的是V层职责，相比于MVC，将C层的逻辑从Activity抽离到P层，使得Activity不再臃肿
2、M层与V层完全分离，我们可以修改V层而不影响M层
3、逻辑放在P层中，可以脱离用户接口来测试这些逻辑（单元测试）
4、我们可以将一个P用于多个V，而不需要改变P的逻辑。这个特性非常的有用，因为V的变化总是比M的变化频繁
缺点：
1、P层与V层是通过接口进行交互的，接口粒度不好控制。粒度太小，就会存在大量接口的情况，使代码太过碎片化；粒度太大，解耦效果不好
2、V层与P层还是有一定的耦合度。一旦V层某个UI元素更改，那么对应的接口就必须得改，数据如何映射到UI上、事件监听接口这些都需要转变，牵一发而动全身
3、复杂的业务同时也可能会导致P层太大，代码臃肿的问题依然不能解决
3、MVC与MVP的区别
1、MVP中V与M解耦
2、MVP中V与P是交互是通过接口来实现的
3、通常V与P是一对一的，但复杂的V可能绑定多个P来处理逻辑。而C是基于行为的，并且可以被多个V共享，C可以负责决定显示哪个V
4、MVVM
各层职责：
V：XML+Activity+Fragment等
VM：ViewModel的缩写，可以理解成是V的数据模型和P的合体
M：同上
优点：
1、DataBinding可以实现双向的交互，这就使得V和VM之间的耦合程度进一步降低，关注点分离更为彻底，同时减轻了Activity的压力
2、提高可维护性。解决了MVP大量的手动V和M同步的问题，提供双向绑定机制。提高了代码的可维护性
缺点：
1、去除了P层，会导致V层依然过重
2、xml的可读性非常差
3、数据绑定的声明是指令式地写在V的模版当中的，这些内容是没办法去打断点debug的
5、MVI
image
工作流程：
1、用户事件出发intents方法，intents方法将intent流merge
2、调用VM的processIntents，然后将intents转发到PublishSubject中
3、在VM中将intents转化成action
4、在VM中根据不同的action执行不同的task，task返回对应的result
5、在VM中通过reducer将result转换成VS((ViewState))
6、在V中订阅VM中的事件代理，并执行render方法，根据不同的VS做相应的UI展示
各层职责：
V：Activity+Fragment，发射intents到VM，订阅VM从而实现V的更新
I：V的intent，如点击事件进行的下一步操作，是一个class
M：准确的说，应该是VM(ViewModel)，订阅V的intents，处理intents然后发射VS(ViewState)
优点：
1、数据单向流动
2、充分利用RxJava响应式编程的优点
缺点：
1、学习成本高，需要熟练掌握ReactiveX的操作符
2、VM承担的任务太多，太过臃肿
3、V要承担部分RxJava生命周期的管理
二、facebook flux结构以及数据流
image
1、Action
在flux框架中，都是以事件也就是我们这里谈到的action为驱动，不论是用户的点击事件还是我们接收到某一个系统广播所需做的响应
2、Dispatcher
事件的分发器，它将事件分发到注册在其中的每一个store
3、Store
接收事件分发器发来的action，并响应对应的action，将结果发射出去
4、View
负责展示UI以及响应用户事件并发送相应action
三、Android flux结构以及数据流
image
facebook flux框架是为RN设计的，应用在安卓上我做了一些调整
1、增加Repository，其作用是为某一个业务提供其所需要的全部数据功能，且将RxJava的生命周期统一管理
2、增加Model，其作用不言而喻，以流的形式提供各种数据
四、fluxlib目录结构
image
1、actions
Action：事件class
BaseActionType：通用的事件类型
ActionCreater：Action的创建器，根据ActionType以及data即可创建Action的实例
示例：ActionCreater.createAction(BaseActionType.REGISTER,store)//创建将store注册到Dispatcher的Action
2、bus
Bus：对EventBus的定制化封装
3、component
3.1、activities
Activity：定义Activity的接口
BaseActivity：基类Activity，主要处理生命周期相关以及加载View的事情
3.2、repository
Repository：定义Repository的接口
BaseRepository：主要管理Model生命周期
SystemNetRepository：系统网络变化的Repository
3.3、stores
Store：定义Store的接口
BaseStore：实现注册和注销时的行为以及发射事件的通用方法
SystemNetStore：系统网络变化的Store，在网络发生变化时，发射相应的事件，BaseView会监听这些事件
3.3、views
View：定义View的接口
BaseView：进行View的填充以及针对Activity生命周期所做的通用事务以及类似于显示toast这类通用View事务
4、datas
Datas.kt：数据类
5、dispatcher
Dispatcher：维护store的注册表以及分发Action给所有注册的store
6、events
BaseDataEvent：带有数据Event的基类
BaseEmptyEvent：无数据Event的基类
CommonDataEvents.kt：通用数据类
NetConnectedEvent：网络连接Event
NoNetConnectedEvent：网络断开的Event
7、views
ConfirmDialog：自定义通用确认Dialog
LoadingDialog：自定义loading dialog
8、BaseApp
Application基类
五、如何使用
1、目录结构
image
2、以一个获取天气的Demo App来说明如何使用本框架
1、HomeActivity
class HomeActivity : AbstractActivity() {
private lateinit var homeStore: HomeStore
override fun initToolBar() {
//设置toolbar相关属性
toolBar.show()
toolBar.setTitle("当日天气")
toolBar.showBack()
}
override fun initView(savedInstanceState: Bundle?) {
super.initView(savedInstanceState)
//初始化HomeView
val homeView = HomeView(this)
addView(homeView)
}
override fun initData(savedInstanceState: Bundle?) {
//初始化HomeStore
homeStore = HomeStore()
//将homeStore注册到Dispatcher中
ActionCreator.createRegisterAction(homeStore)
}
override fun releaseResource() {
//页面销毁时，将homeStore从Dispatcher中注销
ActionCreator.createUnregisterAction(homeStore)
}
}
2、HomeView
class HomeView(activity: Activity) : BaseView(activity) {
override fun getViewLayoutId(): Int {
//加载布局
return R.layout.activity_home
}
private val btnGetWeatherInfo = realView.findViewById<Button>(R.id.btnGetWeatherInfo)
private val tvWeatherInfo = realView.findViewById<TextView>(R.id.tvWeatherInfo)
init {
//设置点击查询天气按钮的监听
RxView.clicksThrottle1s(btnGetWeatherInfo)
.subscribe {
//发送GET_WEATHER_INFO Action
ActionCreator.createAction(ActionType.GET_WEATHER_INFO, "上海")
showLoading()
}
}
private fun showWeatherInfo(weatherInfo: WeatherInfo) {
tvWeatherInfo.text = weatherInfo.toString()
}
//查询天气成功
@Subscribe(threadMode = ThreadMode.MAIN)
fun onWeatherInfoEvent(event: WeatherInfoEvent) {
Logger.e("onWeatherInfoEvent event: $event")
hideLoading()
showWeatherInfo(event.weatherInfo)
}
//查询天气失败
@Subscribe(threadMode = ThreadMode.MAIN)
fun onFluxExceptionEvent(event: FluxExceptionEvent) {
Logger.e("onFluxExceptionEvent event: $event")
hideLoading()
showToastShort(event.fluxException.userMessage)
}
}
3、HomeStore
class HomeStore : BaseStore() {
private var homeRepository: HomeRepository? = null
override fun register() {
super.register()
//初始化HomeRepository
homeRepository = HomeRepository()
}
override fun unregister() {
super.unregister()
//销毁HomeRepository
homeRepository!!.destroy()
homeRepository = null
}
override fun <T> onActionDispatch(type: Int, data: T?) {
when (type) {
//接收到GET_WEATHER_INFO Action后从homeRepository获取天气信息
ActionType.GET_WEATHER_INFO -> {
homeRepository!!.getWeatherInfo(data as String, object : WeatherInfoCallback {
override fun onSuccess(weatherInfo: WeatherInfo) {
//获取天气信息成功，发射天气信息
postDataEvent(WeatherInfoEvent(weatherInfo))
}
override fun onError(fluxException: FluxException) {
//获取天气信息失败，发射失败信息
postDataEvent(FluxExceptionEvent(fluxException))
}
})
}
}
}
}
4、HomeRepository
class HomeRepository : BaseRepository() {
//初始化天气的Model
private val weather = Weather()
fun getWeatherInfo(city: String, weatherInfoCallback: WeatherInfoCallback) {
//调用model的方法，进行网络请求
weather.getWeatherInfo(city)
.subscribe(object : FluxDemoSingleObserver<WeatherInfo>() {
override fun onSubscribe(d: Disposable) {
super.onSubscribe(d)
add(d)
}
override fun onSuccess(t: WeatherInfo) {
weatherInfoCallback.onSuccess(t)
}
override fun onError(e: RxException) {
weatherInfoCallback.onError(FluxException(e.msg, "获取天气信息失败,请重试", e.code))
}
})
}
}
5、Weather
//获取天气的Model
class Weather {
//获取天气信息的Single流
fun getWeatherInfo(city: String): Single<WeatherInfo> {
return HttpRequest.create(WeatherApi::class.java)
.getWeatherInfo(city)
.compose(RxJavaUtil.applySingleMainSchedulers())
.compose(NetRxJavaUtil.applySingleFeedTransformer())
}
}
