状态管理概览

状态管理概览

状态管理构建块概览

介绍

Using state management, your application can store data as key/value pairs in the supported state stores.

当使用状态管理时，你的应用程序可以利用一些自己构建会很复杂，容易出错的功能，比如:

分布式并发和数据一致性
批量CRUD 操作

你的应用程序可以使用Dapr的状态管理API，使用状态存储组件保存和读取键/值对，如下图所示。例如，通过使用HTTP POST可以保存键/值对，通过使用HTTP GET可以读取一个键并返回它的值。

特性

可插拔状态存储

Dapr数据存储被建模为组件，可以在不修改你的服务代码的情况下进行替换。 See supported state stores to see the list.

可配置的状态存储行为

Dapr允许开发人员在对于状态的操作请求中附加额外的元数据，这些元数据用以描述期望如何处理该请求。你可以附加以下：

并发要求
一致性要求

默认情况下，您的应用程序应该假设数据存储是最终一致的，并使用last-write-wins并发模式。

Not all stores are created equal. 为了保证应用程序的可移植性，你可以了解下存储引擎的功能，使你的代码适应不同的存储引擎。

并发（Concurrency）

Dapr支持使用ETags的乐观并发控制（OCC）。当一个发送请求操作状态时，Dapr会给返回的状态附加一个ETag属性。当用户代码试图更新或删除一个状态时，它应该通过更新的请求体或删除的If-Match头附加ETag。只有当提供的ETag与状态存储中的ETag匹配时，写操作才能成功。

Dapr之所以选择OCC，是因为在不少应用中，数据更新冲突都是很少的，因为客户端是按业务上下文自然分割的，可以对不同的数据进行操作。然而，如果你的应用选择使用ETags，请求可能会因为不匹配的ETags而被拒绝。建议你在使用ETags时，使用重试策略来补偿这种冲突。

如果您的应用程序在书面请求中省略了ETags，Dapr会在处理请求时跳过ETags校验。这与ETags的last-write-wins模式相比，基本上可以实现first-write-wins模式。

Note on ETags

对于原生不支持ETags的存储引擎，要求相应的Dapr状态存储实现能够模拟ETags，并在处理状态时遵循Dapr状态管理API规范。由于Dapr状态存储实现在技术上是底层数据存储引擎的客户端，所以这种模拟应该直接使用存储引擎提供的并发控制机制。

Read the API reference to learn how to set concurrency options.

一致性

Dapr同时支持强一致性和最终一致性，其中最终一致性为默认行为。

当使用强一致性时，Dapr会等待所有副本（或指定的quorums）确认后才会确认写入请求。当最终使用一致性时，Dapr 将在基本数据存储接受写入请求后立即返回，即使这是单个副本。

Read the API reference to learn how to set consistency options.

批量操作

Dapr 支持两种类型的批量操作 - bulk 或 multi。您可以将几个相同类型的请求分组成批量(或批次)。 Dapr将请求作为单个请求批量提交给基础数据存储。换句话说，批量（bulk）操作不是事务性的。另一方面，您可以将不同类型的请求分组为多操作，作为原子事务处理。

Read the API reference to learn how use bulk and multi options.

Actor 状态

事务性状态存储可用于存储 Actor 状态。指定 Actor 要使用哪个状态存储，在状态存储组件的元数据部分中指定属性 actorStateStore as true Actor 状态与事务状态库中的具体计划一起储存，这样可以进行一致的查询。 Actor 状态与事务状态库中的具体计划一起储存，这样可以进行一致的查询。 Read the API reference to learn more about state stores for actors and the actors API reference

直接查询状态存储

Dapr保存和检索状态值，而不进行任何转换。 You can query and aggregate state directly from the underlying state store.

例如，要在 Redis 中获取与 app ID“myApp”相关的所有状态 key，可以使用:

KEYS "myApp*"

查询 Actor 状态

如果数据存储支持 SQL 查询，您可以使用 SQL 查询 Actor 的状态。例如使用：

SELECT * FROM StateTable WHERE Id='<app-id>||<actor-type>||<actor-id>||<key>'

您还可以跨 Actor 实例执行聚合查询，避免 Actor 框架常见的基于回合的并发性限制。例如，要计算所有温度计Actor的平均温度，使用:

SELECT AVG(value) FROM StateTable WHERE Id LIKE '<app-id>||<thermometer>||*||temperature'

Note on direct queries

对状态存储的直接查询不受 Dapr 并发控制，毕竟您没有通过 Dapr 运行时调用。您看到的是提交数据的快照，对于跨多个 Actor 的只读查询是可以接受的，当然写操作应该通过 Dapr 状态管理或 Actor api 来执行。

状态管理 API

The API for state management can be found in the state management API reference which describes how to retrieve, save and delete state values by providing keys.