前言： 又是一段时间没有更新了，今天看下写csdn已经一年了。记录知识，分享与人。
1、Flow Vs LIveData：对于LiveData来说，是为了解决Android-App开发以来一直存在的架构设计混乱的问题，谷歌推出了Jetpack-MVVM的全家桶解决方案。作为整个解决方案的核心-LiveData，以其生命周期安全，内存安全等优点，甚至有逐步取代EventBus，RxJava作为Android端状态分发组件的趋势。而 Flow的诞生是为了取代LiveData？，有兴趣的朋友们可以查看此篇博客关注二者的差异和优缺点。
2、Flow：首先我们看下一个简单的列子【来自官方文档】来学习一下如何使用。
simple(): Flow
for (i in 1..3) {
delay(100) // 假装我们在这⾥做了⼀些有⽤的事情
emit(i) // 发送下⼀个值
}
main() = runBlocking
// 启动并发的协程以验证主线程并未阻塞
launch {
for (k in 1..3) {
println("I'm not blocked $k")
delay(100)
}
}
// 收集这个流
simple().collect { value -> println(value) }
这段代码在不阻塞主线程的情况下每等待 100 毫秒打印⼀个数字。在主线程中运⾏⼀个单独的协程每 100 毫秒打印⼀次 “I’m not blocked” 已经经过了验证。
I'm not blocked 1
1
I'm not blocked 2
2
I'm not blocked 3
3
这是最简单、最基本的使用，其实在我们开发任务中往往需要更加复杂的设计，当然Kotlin也是提供相应的Flow的更多的实现类，比如：SharedFlow、StateFlow，而StateFlow 是 SharedFlow 的一个特殊变种，StateFlow 与 LiveData 是最接近的，推出就是为了替换LiveData的，有以下特性：
1.它始终是有值的，StateFlow需要一个初始值，而LiveData不需要。value空安全
2.它的值是唯一的。
3.它允许被多个观察者共用 (因此是共享的数据流)。
4.它永远只会把最新的值重现给订阅者，这与活跃观察者的数量是无关的。
5、StateFlow当value重复时，不会回调collect
3、使用MutableStateFlow实现消息通知
3.1 首先引入协程依赖：
// 协程
implementation 'org.jetbrains.kotlinx:kotlinx-coroutines-android:1.4.1'
3.2 编写NotifyFlowUtil工具类
object NotifyFlowUtil {
private const val TAG = "NotifyFlowUtil"
private val notifyFlow = MutableStateFlow(false)
private val flowScope = CoroutineScope(SupervisorJob() + Dispatchers.Main.immediate)
fun setNotifyFlow(value: Boolean) {
Log.i(TAG, "setNotifyFlow: $value")
notifyFlow.value = value
}
fun getNotifyFlow(callback: (Boolean) -> Unit) {
flowScope.launch {
notifyFlow.collect {
Log.i(TAG, "getNotifyFlow: $it")
callback(it)
}
}
}
}
3.3 结果展示
// 注册接收方，等待接收
NotifyFlowUtil.getNotifyFlow {
Log.i(TAG, "getNotifyFlow result is $it")
}
// 开启一个新的协程来设置值
MainScope().launch {
NotifyFlowUtil.setNotifyFlow(true)
delay(1000)
NotifyFlowUtil.setNotifyFlow(false)
delay(1000)
}
println("Hello,") // 协程已在等待时主线程还在继续
Thread.sleep(2000L) // 阻塞主线程 2 秒钟来保证 JVM 存活
结果打印如下，初始值为false，当设置为true时，我们会随机收集到一个 true值，如果此时继续发 true时是不会继续接收的（重复的不再接收），最后设置fasle且接收了false。
总结 1.Flow 支持线程切换,LiveData不支持线程切换，所有数据转换都将在主线程上完成 2.Flow 入门的门槛较低，没有那么多傻傻分不清楚的操作符,而RxJava又有些过于麻烦了，同时需要自己处理生命周期，在生命周期结束时取消订阅 3.简单的数据转换与操作符，如 map,flowOn切换线程，transform 等等 4.冷数据流，不消费则不生产数据,这一点与LiveData不同：LiveData的发送端并不依赖于接收端。 5.属于kotlin协程的一部分，可以很好的与协程基础设施结合
参考文章：https://www.shareintelli.com/3343/；https://blog.51cto.com/zhaoyanjun/4842091?b=totalstatistic （如果错误，欢迎批评指正，请大佬轻喷）
相关文章
您阅读本篇文章共花了：
发表评论