前言
最近在学习 Google 推出的框架Jetpack,虽然目前网上的资料已经很多了,但为了加深印象和边动手练习跟着学习,所以站在了下面的巨人的肩膀上,并根据当前最新的API 和编写实际Demo,记录下一些学习笔记,大部分是参考巨人们的,整理和休整,加入自己理解和更新吧,学习领略了Android Jetpack组件的一点魅力
目前学习笔记系列为:
- Android Jetpack 之 Lifecycles ---入门使用
- Android Jetpack 之 LiveData---入门使用
- Android Jetpack 之 Room ---入门使用
- Android Jetpack 之 WorkManger---入门使用
- ....待续
日常鸣谢巨人
正题
LiveData 简介
- LiveData是一个具有生命周期感知特性的可观察的数据保持类,使用LiveData保存数据时,在每次订阅或数据更新时会自动回调设置的观察者从而更新数据,真正的实现了数据驱动的效果
- LiveData的创建基本会在ViewModel中,从而使数据在界面销毁时继续保持
- LiveData 认为观察者的生命周期处于STARTED状态或RESUMED状态下,表示观察者处于活动状态,LiveData只通知活跃的观察者更新数据
- 注册一个实现该LifecycleOwner 接口的对象配对的观察者,当相应Lifecycle对象的状态改变为DESTROYED时需移除观察者
LiveData 的简单使用
依赖添加
def lifecycle_version = "2.0.0"
implementation "androidx.lifecycle:lifecycle-viewmodel-ktx:$lifecycle_version"
implementation 'android.arch.lifecycle:extensions:1.1.1'
创建一个LiveData实例来保存某种类型的数据
class TestViewModel : ViewModel() {
var mCurrent: MutableLiveData<String>? = null
get() {
if (field == null) {
field = MutableLiveData()
}
return field
}
}
确保存储LiveData对象是在ViewModel中而不 是Activity 或 Fragment 中
创建一个定义onChanged()方法的Observer对象,在数据变化时回调
// 创建观察者对象
val nameObservable = Observer<String> {
ld_tv.text = it // onChange() 方法中的操作
}
使用observe() 方法将观察者对象附加到LiveData对象,这将观察对象向LiveData对象订阅,以便通知其更改
// 创建viewModel 对象
mModel = ViewModelProviders.of(this).get(TestViewModel::class.java)
// mCurrent 订阅观察
mModel.mCurrent!!.observe(this,nameObservable)
- 第一个参数传递的this就是LifecycleOwner 的实例,LiveData会根据Owner的声明周期自动作相应的处理
- observe()将nameObservable作参数调用后,如果LiveData数据有值,onChange()立即调用获取最新值
- 可以使用observeForever(Observer)方法注册一个没有关联的生命周期所有者对象的观察者,在这种情况下,观察者被认为总是活动的,因此总是通知修改,可以删除这些观察员调用removeObserver(Observer) 方法
LiveData允许UI控制器观察员订阅更新
//设置点击事件,修改LiveData中的数据
ld_btn.setOnClickListener{
mModel.mCurrent!!.value = "AAAAAA"
}
当LiveData对象保存的数据发生变化时,UI会自动响应更新
观察者在从非活动状态变为活动状态时也会收到更新
运行结果
点击按钮后改变LiveData的数据,界面的TextView也随之改变
扩展LiveData
package andjun.com.mykt2019.java.livedata
import android.arch.lifecycle.LiveData
import android.content.Context
import android.location.Location
import android.location.LocationListener
import android.location.LocationManager
import android.os.Bundle
import androidx.annotation.MainThread
/**
* author : AndJun
* time : 2019/3/12
* desc :
*/
class MyLocationLiveData(context: Context) : LiveData<Location>() {
private var locationManager: LocationManager? = null
init {
locationManager = context.getSystemService(
Context.LOCATION_SERVICE) as LocationManager
}
@MainThread
companion object {
private var sInstance: MyLocationLiveData? = null
fun getInstance(context: Context): MyLocationLiveData? {
if (sInstance == null) {
sInstance = MyLocationLiveData(context.applicationContext)
}
return sInstance
}
}
private var listener: LocationListener = object : LocationListener {
override fun onLocationChanged(location: Location?) {
}
override fun onStatusChanged(provider: String?, status: Int, extras: Bundle?) {
setValue(location)
}
override fun onProviderEnabled(provider: String?) {
}
override fun onProviderDisabled(provider: String?) {
}
}
override fun onActive() {
locationManager!!.requestLocationUpdates(LocationManager.GPS_PROVIDER, 0.toLong(), 0.toFloat(), listener)
}
override fun onInactive() {
locationManager!!.removeUpdates(listener)
}
}
-
onActive() :当LiveData对象具有活动观察者时调用该方法
-** onInactive()** :当LiveData对象没有任何活动观察者时调用该方法 - setValue(T) :方法更新LiveData实例的值,并通知任何活动的观察者有关更改的信息
-
postValue(T value)
: 其实是在非主线程中更新数据,其实他传递的Runnable中也是调用了setValue()方法,其余的操作只是通过ArchTaskExecutor和DefaultTaskExecutor将操作切换到主线程
调用流程如下:
setValue(T value) --> dispatchingValue(null) --> considerNotify(iterator.next().getValue()) --> observer.mObserver.onChanged((T) mData)
所以 这里就去到了 Observer 观察者的回调中,去更新具体操作
上面代码使用单例提供LocationLiveData可以在Activity和Fragment之间实现共享,在onActive和onInactive中完成监听的注册和取消,当位置改变时回调Listener并调用setValue()设置LiveData的值,从而自动更新观察者中的数据
使用扩展LIveData
扩展的LiveData使用和正常使用一样,observe()方法将Fragmrnt(它是一个实例LifecycleOwner)作为第一个参数传递,使观察者绑定到Fragment的生命周期,如果Lifecycle对象未处于活动状态,则即使值发生更改,也不会调用观察者,在之后Lifecycle的对象被Destroy后,观察者被自动删除
简易源码分析
- 加观察者observe方法开始
observe(@NonNull LifecycleOwner owner, @NonNull Observer<T> observer)
- 从参数中看到了LifecycleOwner,看到 从参数中看到了LifecycleOwner 应该会想到这里的作用是处理生命周期改变(可以参考Lifecy 使用,源码分析),在observe方法中执行了以下逻辑
在observe中首先判断了当前Lifecycler的状态,当Destroy时即观察者不处于活跃状态,不用接收数据
创建LifecycleBoundObserver实例保存传入的LifecycleOwner和Observer,并保存在mObservers
添加LifecycleOwner的观察者,响应生命周期的变化
- 在 observe 方法中的,ObserverWrapper 和 LifecycleBoundObserver
ObserverWrapper
void activeStateChanged(boolean newActive) {
if (newActive == mActive) {
return;
}
mActive = newActive;
boolean wasInactive = LiveData.this.mActiveCount == 0;
LiveData.this.mActiveCount += mActive ? 1 : -1;
if (wasInactive && mActive) {
onActive(); // 当Owner为活跃状态时回调onActive()
}
if (LiveData.this.mActiveCount == 0 && !mActive) {
onInactive(); // 当Owner未活跃状态时回调onInactive()
}
if (mActive) {
dispatchingValue(this);
}
}
LifecycleBoundObserver
// 实现GenericLifecycleObserver 当生命周期改变时回调onStateChanged
@Override
public void onStateChanged(LifecycleOwner source, Lifecycle.Event event) {
if (mOwner.getLifecycle().getCurrentState() == DESTROYED) {
removeObserver(mObserver); // DESTROYED时移除观察者
return;
}
activeStateChanged(shouldBeActive());
}
@Override
void detachObserver() {
mOwner.getLifecycle().removeObserver(this);
}
ObserverWrapper 在Owner活跃状态改变时回调onActive和onInactive方法,LifecycleBoundObserver主要利用Lifecycler的生命周期观察者GenericLifecycleObserver,前面设置了owner.getLifecycle().addObserver(wrapper)后,当生命周期改变时会回调onStateChange()方法,在生命周期为Destroy时移除Observer
小结
LiveData 整个过程就是两部分
- 一是使用LifeCycleOwner感知声明周期的变化
- 第二就是储存并遍历Observer,在数据改变时回调所有的观察者