DataStore —— SharedPreferences 的替代者？-阿里云开发者社区

DataStore —— SharedPreferences 的替代者？

2022-05-11 261

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： DataStore —— SharedPreferences 的替代者？

什么是 DataStore ？

那么，什么是 DataStore 呢？

DataStore provides a safe and durable way to store small amounts of data, such as preferences and application state. It does not support partial updates: if any field is modified, the whole object will be serialized and persisted to disk. If you want partial updates, consider the Room API (SQLite).

DataStore provides ACID guarantees. It is thread-safe, and non-blocking. In particular, it addresses these design shortcomings of the SharedPreferences API。

这个我可以翻译一下。

DataStore 提供了一种存储轻量数据的安全稳定的方案，例如配置文件，应用状态等。它不支持局部更新：如果任何一个成员变量被修改了，整个对象都将被序列化并持久化到磁盘。对于局部修改，请考虑使用 Room 。

DataStore 保证原子性，一致性，隔离性，持久性。它是线程安全，且非阻塞的。尤其是，它解决了 SharedPreferences API 的设计缺陷。

好家伙，看起来这就是 SharedPreferences 的替代品了。

上代码

简单看一下代码实现。

DataStore 是一个接口。

interface DataStore<T> {
    val dataFlow: Flow<T>
    suspend fun updateData(transform: suspend (t: T) -> T): T
    interface Serializer<T> {
        fun readFrom(input: InputStream): T
        fun writeTo(t: T, output: OutputStream)
        val defaultValue: T
    }
    // TODO(b/151635324): Add initializers.
    // TODO(b/151635324): Add exception handlers.
    // TODO(b/151635324): Consider adding snapshot API.
}
复制代码

没错，是基于协程和 Flow 实现的。

dataFlow 是一个 Flow 对象
updateData() 用于更新对象
Serializer 接口，提供序列化和持久化能力

目前源码中仅仅提供了一个实现类：SingleProcessDataStore 。从名字就可以看出来，不支持多进程。看一下其中几个关键方法。

class SingleProcessDataStore<T>(
    private val produceFile: () -> File,
    private val serializer: DataStore.Serializer<T>,
    private val scope: CoroutineScope = CoroutineScope(Dispatchers.IO + SupervisorJob())
) : DataStore<T> {
    ......
    private suspend fun readData(): T {
        // TODO(b/151635324): consider caching produceFile result.
        val file = produceFile()
        try {
            FileInputStream(file).use { stream ->
                return serializer.readFrom(stream)
            }
        } catch (ex: FileNotFoundException) {
            if (file.exists()) {
                throw ex
            }
            return serializer.defaultValue
        }
    }
    private fun writeData(newData: T) {
        // TODO(b/151635324): consider caching produceFile result.
        val file = produceFile()
        file.mkdirs()
        val scratchFile = File(file.absolutePath + SCRATCH_SUFFIX)
        try {
            FileOutputStream(scratchFile).use { stream ->
                serializer.writeTo(newData, stream)
                stream.fd.sync()
                // TODO(b/151635324): fsync the directory, otherwise a badly timed crash could
                //  result in reverting to a przuihouevious state.
            }
            scratchFile.renameTo(file)
        } catch (ex: IOException) {
            if (scratchFile.exists()) {
                scratchFile.delete()
            }
            throw ex
        }
    }
    ......
}
复制代码