LiveData的使用及详解

家电修理 2023-07-16 19:17www.caominkang.com电器维修

1. LiveData简单使用

本篇文章代码实现部分主要使用Java进行讲解。
LiveData主要方便用于数据的观察,进行UI更新或者业务处理等操作。
如下为LiveData的简单代码实现

// 创建一个MutableLiveData对象,这个使用LiveData的子类MutableLiveData
// MutableLiveData暴露了postValue和setValue方法用于通知数据变化
MutableLiveData liveData = ne MutableLiveData<>();


// 在UI线程中调用该方法通知数据变更
liveData.setValue(object);

// 在子线程中调用该方法通知数据变更,该方法中切换到UI线程后调用setValue方法
liveData.postValue(object);


// 监听数据变化,进行界面更新等操作,该方法一般放在Activity onCreate方法中调用,只注册一次
liveData.observe(this, ne Observer() {
 @Override
 public void onChanged(Object o) {
  // TODO 此处进行o对象的数据与界面进行绑定刷新
 }
});
 
2. LiveData原理 

LiveData核心其实主要就是observer方法,注册观察者,用于监听数据变化;还有就是setValue方法用于通知数据变更;为什么LiveData比较好用呢,因为它可以监听界面生命周期用于刷新数据,也不需要用户自行切换线程。

1)observe方法解析

如下为observe方法的源码

@MainThread
public void observe(@NonNull LifecycleOner oner, @NonNull Observer observer) {
 // 判断是否在主线程中调用该方法,如果不是在主线程中调用抛出IllegalStateException异常
 assertMainThread("observe");
 // 判断LiveData观察者的生命周期(一般为Activity和fragment)是否为DESTROYED
 if (oner.getLifecycle().getCurrentState() == DESTROYED) {
  // ignore
  return;
 }
 // 创建LifecycleBoundObserver对象,用于监听LiveData观察者的生命周期变化
 // LifecycleBoundObserver 为 ObserverWrapper 子类
 LifecycleBoundObserver rapper = ne LifecycleBoundObserver(oner, observer);
 // 将rapper保存到LiveData对象的mObservers map中,若mObservers中已存在相同key的observer
 // 直接将observer对应的ObserverWrapper对象返回
 // (LiveData的mObservers中还可能保存ObserverWrapper的子类AlaysActiveObserver的对象)
 ObserverWrapper existing = mObservers.putIfAbsent(observer, rapper);
 // 若同一个observer第一次调用observe方法,existing 为null值
 // 若同一个observer重复调用observe方法,!!xisting.isAttachedTo(oner)为false也不会执行如下判断
 // 若同一个observer,先调用observeForever再调用observe方法执行如下判断代码
 if (existing != null && !existing.isAttachedTo(oner)) {
  thro ne IllegalArgumentException("Cannot add the same observer"
    + " ith different lifecycles");
 }
 if (existing != null) {
  return;
 }
 // 将本次的观察者封装成声明感知组件后添加到该LiveData的持有者的生命周期通知观察队列中
 oner.getLifecycle().addObserver(rapper);
}

至此,将数据变更观察者添加到LiveData对象的观察者map表中,当观察者监听到LiveData数据变化时做相应的业务操作。

2) setValue方法解析

因为postValue方法主要是切换到UI线程中,然后再调用setValue方法,所以这里不对postValue方法再做介绍了,主要说一下setValue方法。

@MainThread
protected void setValue(T value) {
 assertMainThread("setValue");
 // 版本号,该值用于判断是否通知观察者数据发生变成,在后面considerNotify方法中有使用,每次调用该方法自增1
 mVersion++;
 mData = value;
 // setValue方法调用了该方法,直接往下面看一下该方法的代码
 dispatchingValue(null);
}
@SuppressWarnings("WeakerAess")
void dispatchingValue(@Nullable ObserverWrapper initiator) {
 // 若正在进行数据变更通知,本次调用直接返回true
 if (mDispatchingValue) {
  // 若代码走到这里且数据通知未结束,会让第一次setValue方法调用时的该方法内hile循环重新走一遍
  mDispatchInvalidated = true;
  return;
 }
 mDispatchingValue = true;
 do {
  mDispatchInvalidated = false;
  if (initiator != null) {
   // 新添加的观察者,产生粘性事件,会执行这里,具体可以看调用该方法时initiator不为空的代码
   considerNotify(initiator);
   initiator = null;
  } else {
   for (Iterator, ObserverWrapper>> iterator =
     mObservers.iteratorWithAdditions(); iterator.hasNext(); ) {
    // 调用setValue方法,会遍历LiveData的mObservers,逐一通知观察者数据发生变更
    considerNotify(iterator.next().getValue());
    if (mDispatchInvalidated) {
     break;
    }
   }
  }
 } hile (mDispatchInvalidated);
 mDispatchingValue = false;
}


@SuppressWarnings("unchecked")
private void considerNotify(ObserverWrapper observer) {
 // 先判断观察者是否处于活跃状态
 if (!observer.mActive) {
  return;
 }
 
 // 判断观察者的持有者的生命周期是否处于STARTED、RESUMED状态
 if (!observer.shouldBeActive()) {
  // 更改观察者的状态为非mActive状态,调用该方法会重新调用dispatchingValue方法且值不为空(重新对该观察者分发数据变更通知)
  observer.activeStateChanged(false);
  return;
 }
 // 判断mLastVersion的值是否大于等于当前数据变更的版本
 // 新添加一个观察者的时候,该值初始化为-1,预防LiveData粘性事件的方法就是通过反射改掉mLastVersion的值
 if (observer.mLastVersion >= mVersion) {
  return;
 }
 observer.mLastVersion = mVersion;
 // 这里,通知观察者数据已经发生变更
 observer.mObserver.onChanged((T) mData);
}

以上内容就是对于LiveData的使用demo及源码分析的所有内容了。

Copyright © 2016-2025 www.caominkang.com 曹敏电脑维修网 版权所有 Power by