学习笔记LiveData

学习下LiveData
目录

  1. 如何使用
  2. 源码解析
  3. 粘性事件

1、使用

LiveData是Google的提供标准化开发的组件之一
主要就是在页面中传递数据在Activity的Fragment中,一个Fragment改变了数据,可以通知到另一个Fragment
当屏幕旋转时候,会自动通知组件推送最后一次数据
并且可以感知生命周期,帮开发者避免一些因Fragment销毁而导致的空指针问题
用法其实很简单

//定一个MutableLiveData
val name = MutableLiveData<String>()

//在需要的地方进行订阅
userBean.observe(this,{ it->
  //显示数据
})

//在需要的地方 发送数据
name.value = "数据改变了"

通常会放在ViewModel中,贴一下部分代码

//定义一个ViewModel
class UserViewModel :ViewModel() {

    val name = MutableLiveData<String>()

    fun setName(str: String) {
        name.value = str
    }
}
//定义2个Fragment 在同一个Activity上
//FragmentA
class FragmentA : Fragment() {
    //定义ViewModel
    private lateinit var model: UserViewModel

    override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
        super.onViewCreated(view, savedInstanceState)
        model = ViewModelProvider(requireActivity()).get(UserViewModel::class.java)
        //忽略xml界面,设置按钮点击事件
        btn.setOnClickListener {
            model.setName("abc")
        }
    }
}
//FragmentB
class FragmentB : Fragment() {
    //定义ViewModel
    private lateinit var model: UserViewModel

    override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
        super.onViewCreated(view, savedInstanceState)
        model = ViewModelProvider(requireActivity()).get(UserViewModel::class.java)
        //忽略xml,这里进行订阅数据有变化时候 执行onChanged方法
        model.name.observe(requireActivity(),object:Observer<String>{
            override fun onChanged(t: String?) {
                tv_name.text = t
            }
        })

    }
}

当点击按钮的时候,setName 执行赋值方法通知订阅 执行 onChanged方法。
第一次看到会比较奇怪,为什么两个对象通过 ViewModelProvider 赋值,之后订阅就能执行了?
这两个Fragment的model肯定是同一个对象,可以用 toString 打印

System.out: com.demo.viewmodel.UserViewModel@d2f5b55
System.out: com.demo.viewmodel.UserViewModel@d2f5b55

确实同一个对象。至于回调 onChanged,这是观察者模式,这里不赘述了。
前面说了可以感知生命周期,这时候可以把屏幕旋转一下试试,看看值还在不在
用就这么简单

2、分析

(1)observe怎么感知生命周期
(2)怎么回调onChanged的

(1)、感知生命周期
//用的是MutableLiveData  继承了  抽象类 LiveDate
public class MutableLiveData<T> extends LiveData<T>
public abstract class LiveData<T> {

  public void observe(@NonNull LifecycleOwner owner, @NonNull Observer<? super T> observer) {

      LifecycleBoundObserver wrapper = new LifecycleBoundObserver(owner, observer);
      ObserverWrapper existing = mObservers.putIfAbsent(observer, wrapper);

      owner.getLifecycle().addObserver(wrapper);
  }

}

删了一些判断的代码
这代码很少,new了 LifecycleBoundObserver 对象塞入了owner 也就是 activity对象,observer也就是观察者对象,里面是onChanged
然后把这个wrapper,put到了mObservers
这个mObservers是SafeIterableMap,看上去是个Map其实是 用Map的Key-Value,封装成了一个LinkedList
最后把wrapper对象,传到了activity里面,其实这里就已经将两者进行了绑定
再稍微深入一点点

//FragmentActivity
public class FragmentActivity extends ComponentActivity implements
        ActivityCompat.OnRequestPermissionsResultCallback,
        ActivityCompat.RequestPermissionsRequestCodeValidator {

    //new了一个对象
    final LifecycleRegistry mFragmentLifecycleRegistry = new LifecycleRegistry(this);

}

owner.getLifecycle().addObserver(wrapper);

//订阅的observer 会在这里被添加
//LifecycleRegistry
public class LifecycleRegistry extends Lifecycle {
  @Override
  public void addObserver(@NonNull LifecycleObserver observer) {
    //这里对 observer 进行了一些包装
    //塞入一个mObserverMap对象中
    //这个对象是FastSafeIterableMap本质也是一个Key-Value的LinkList
    while(){
        //循环分发 事件
        statefulObserver.dispatchEvent(lifecycleOwner, upEvent(statefulObserver.mState));
    }
  }
}

所以当 model.name.observe(requireActivity(),object:Observer<String>{..}订阅的时候执行了LifecycleRegistryaddObserver方法,包装对象,塞入链表。
ok这时,在ComponentActivitymLifecycleRegistry对象 管理所有的订阅。
现在已经绑定好了,然后感知生命周期,生命周期无非就onCreate...onDestroy。
前面也说了为防止空指针,直接看onDestroy()

protected void onDestroy() {
    super.onDestroy();
    mFragments.dispatchDestroy();
    //里面 修改了状态、同步状态
    mFragmentLifecycleRegistry.handleLifecycleEvent(Lifecycle.Event.ON_DESTROY);
}
//不仅仅是destory做了处理
protected void onPause() {
    super.onPause();
    mResumed = false;
    mFragments.dispatchPause();
    mFragmentLifecycleRegistry.handleLifecycleEvent(Lifecycle.Event.ON_PAUSE);
}
@Override
   protected void onSaveInstanceState(@NonNull Bundle outState) {
       super.onSaveInstanceState(outState);
       markFragmentsCreated();
       mFragmentLifecycleRegistry.handleLifecycleEvent(Lifecycle.Event.ON_STOP);
}

总结一下
observe和activity绑定,放入了activity链表中,这个链表由activity管理,根据activity的生命周期,修改里面的状态

(2)、回调onChanged
LifecycleBoundObserver wrapper = new LifecycleBoundObserver(owner, observer);
owner.getLifecycle().addObserver(wrapper);

//刚才说了订阅会调用addObserver(..)
//这里的observer 就是LifecycleBoundObserver对象
public void addObserver(@NonNull LifecycleObserver observer) {
    ObserverWithState statefulObserver = new ObserverWithState(observer, initialState);
    while(){
          statefulObserver.dispatchEvent(lifecycleOwner, upEvent(statefulObserver.mState));
    }
}
statefulObserver.dispatchEvent 调用了
   -> mLifecycleObserver.onStateChanged(owner, event);
      ->LifecycleBoundObserver的onStateChanged()   这里已经是LiveData了
        ->activeStateChanged
          ->最终dispatchingValue(@Nullable ObserverWrapper initiator) 分发

这个链比较长,可以点击源码走一圈
dispatchingValue(ObserverWrapper initiator) 这里面就是正真的观察者了,
for循环去走onChanged()方法

3、粘性事件

EventBus的粘性事件,在ActivityA发射了粘性时间,打开ActivityB之后会执行粘性事件
在这里也是一样的道理。
根据刚才的源码,订阅后会进行一次分发,为什么订阅后就会分发?这要根据Google对这个组件的“定义”了
我理解的“定义”是 存活的数据 LiveData ,也就是在Activity、Fragment生命周期内被分发,也就是说Activity、Fragment活着,这数据也得活着。
所以当你屏幕旋转Activity被销毁,又初始化了,这些数据还要再次显示出来,所以产生了粘性事件。
从分发开始看

name.value = str

protected void setValue(T value) {
    assertMainThread("setValue");
    mVersion++;
    mData = value;
    dispatchingValue(null);
}
//分发
void dispatchingValue(@Nullable ObserverWrapper initiator) {
    do {
        if (initiator != null) {
        } else {
            for (Iterator<Map.Entry<Observer<? super T>, ObserverWrapper>> iterator =
                    mObservers.iteratorWithAdditions(); iterator.hasNext(); ) {
                considerNotify(iterator.next().getValue());
                if (mDispatchInvalidated) {
                    break;
                }
            }
        }
    } while (mDispatchInvalidated);
}
//观察者for循环去通知
private void considerNotify(ObserverWrapper observer) {
    if (!observer.shouldBeActive()) {
        observer.activeStateChanged(false);
        return;
    }
    if (observer.mLastVersion >= mVersion) {
        return;
    }
    observer.mLastVersion = mVersion;
    observer.mObserver.onChanged((T) mData);
}

这里会发现有个版本号
ObserverWrapper中 mLastVersion 默认-1
在 LiveData 初始化之后 mVersion 为 0 , 每次 赋值后 mVersion++
发送数据后 会 mLastVersion = mVersion
再根据 if判断 observer.mLastVersion >= mVersion 如果为false就会调用 onChanged 方法。
所以粘性事件有次而来。
这看上去像是个Bug,追本溯源,这个组件的目的,并不是总线消息通信。而是“存活的数据”,当Activity、Fragment,旋转,销毁重建时会及时得到最后一次数据。

学艺不精,如果内容有错误请及时联系我,我及时改正

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 212,884评论 6 492
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,755评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 158,369评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,799评论 1 285
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,910评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,096评论 1 291
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,159评论 3 411
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,917评论 0 268
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,360评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,673评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,814评论 1 341
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,509评论 4 334
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,156评论 3 317
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,882评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,123评论 1 267
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,641评论 2 362
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,728评论 2 351

推荐阅读更多精彩内容