DaprClient 使用

使用 DaprClient 的基本提示和建议

生命周期管理

DaprClient 能够以TCP 套接口的形式访问网络资源,与 Dapr sidecar 通信。 DaprClient 实现 IDisposable 以支持主动的资源清理。

为了获得最佳性能,请创建一个DaprClient的单一长期实例,并在整个应用程序中提供对该共享实例的访问权限。 DaprClient 实例是线程安全的并且允许共享的。

避免每个操作创建一个 DaprClient 并在操作完成后释放它。

配置 DaprClient

在调用.Build()创建客户端之前,可以通过调用DaprClientBuilder类的方法来配置DaprClient。 每个DaprClient对象的设置都是独立的,并且在调用.Build()后无法更改。

  1. var daprClient = new DaprClientBuilder()
  2. .UseJsonSerializerSettings( ... ) // Configure JSON serializer
  3. .Build();

DaprClientBuilder包含以下设置:

  • Dapr sidecar 的 HTTP 终结点。
  • Dapr sidecar 的 gRPC 终结点。
  • 用于配置 JSON 序列化的 JsonSerializerOptions 对象
  • 用于配置 gRPC 的 GrpcChannelOptions 对象
  • 用于验证请求到 sidecar 的 API 令牌

SDK 将读取以下环境变量来配置默认值:

  • DAPR_HTTP_PORT: 用于查找 Dapr sidecar 的 HTTP 终结点
  • DAPR_GRPC_PORT: 用于查找 Dapr sidecar 的 gRPC 终结点
  • DAPR_API_TOKEN: 用于设置 API 令牌

配置 gRPC 通道选项

Dapr 使用CancellationToken来取消,依赖于 gRPC 通道选项的配置。 如果您需要自己配置这些选项,请确保启用 ThrowOperationCanceledOnCancellation 设置

  1. var daprClient = new DaprClientBuilder()
  2. .UseGrpcChannelOptions(new GrpcChannelOptions { ...

使用 DaprClient 取消

DaprClient 上执行异步操作的API接受一个可选的CancellationToken参数。 这遵循了可取消操作的标准.NET习惯用法。 请注意,当取消发生时,并不能保证远程端点停止处理请求,只能保证客户端已经停止等待完成。

当一个操作被取消时,它将抛出一个 OperationCancelledException

了解 DaprClient JSON 序列化

DaprClient 上的许多方法使用 System.Text.Json 序列化器执行JSON序列化。 接受应用程序数据类型作为参数的方法将对其进行JSON序列化,除非文档另有明确说明。

如果你有高级需求,值得阅读 System.Text.Json 文档 Dapr .NET SDK 没有提供独特的序列化行为或自定义 - 它依赖于底层的序列化器将数据转换为应用程序的 .NET 类型。 Dapr .NET SDK 没有提供独特的序列化行为或自定义 - 它依赖于底层的序列化器将数据转换为应用程序的 .NET 类型。

DaprClient被配置为使用来自 JsonSerializerDefaults.Web 配置的序列化器配置对象。 这意味着 DaprClient 将使用 camelCase 来命名属性,允许读取引号 ("10.99"),并将不区分大小写地绑定属性。 这些设置与 ASP.NET Core 和 System.Text.Json.Http API 所使用的设置相同,并被设计为遵循可互操作的 Web 惯例。

System.Text.Json截至.NET 5.0,并没有很好地支持所有内置的F#语言功能。 如果你使用的是F#,你可能会想要使用一个添加了F#功能支持的转换器包,比如 FSharp.SystemTextJson

JSON序列化的简单指南

如果您使用一个映射到JSON类型系统的特性集,您使用JSON序列化和 DaprClient 的体验将会很顺畅。 这些都是一般准则,在可以应用的地方会简化你的代码。

  • 避免继承和多态性
  • 不要试图用循环引用来序列化数据。
  • 不要将复杂或昂贵的逻辑放在构造函数或属性访问器中
  • 使用.NET类型,干净利落地映射到JSON类型(数字类型,字符串,DateTime
  • 为顶层消息、事件或状态值创建自己的类,以便您可以在未来添加属性
  • 使用 get/set 属性设计类型,或者使用JSON支持的模式来设计不可变类型。

多态性和序列化

DaprClient 使用的 System.Text.Json 序列化器在执行序列化时使用声明的值类型。

本节将在示例中使用 DaprClient.SaveStateAsync<TValue>(...) ,但该建议适用于SDK暴露的任何 Dapr 构建块。

  1. public class Widget
  2. {
  3. public string Color { get; set; }
  4. }
  5. ...
  6. public class Widget
  7. {
  8. public string Color { get; set; }
  9. }
  10. ...
  11. // Storing a Widget value as JSON in the state store
  12. widget widget = new Widget() { Color = "Green", };
  13. await client.SaveStateAsync("mystatestore", "mykey", widget);

在上面的例子中,类型参数 TValue 的类型参数是从 widget 变量的类型推断出来的。 这一点很重要,因为 System.Text.Json 序列化器将根据 declared type 的值来执行序列化。 结果是将存储JSON值 { "color": "Green" }

考虑一下当你尝试使用 Widget 的派生类型时会发生什么。

  1. 在这个例子中,我们使用的是 <code>SuperWidget</code> ,但变量的声明类型是 <code>Widget</code>。
  2. 由于JSON序列化器的行为是由声明的类型决定的,所以它只看到一个简单的 <code>Widget</code>,并将保存<code>{ "color": "Green" }</code>,而不是<code>{ "color": "Green", "hasSelfCleaningFeature": true }</code>。

,但变量的声明类型是 Widget。

由于JSON序列化器的行为是由声明的类型决定的,所以它只看到一个简单的 Widget,并将保存{ “color”: “Green” },而不是{ “color”: “Green”, “hasSelfCleaningFeature”: true }。

在这个例子中,我们使用的是 SuperWidget ,但变量的声明类型是 Widget。 由于JSON序列化器的行为是由声明的类型决定的,所以它只看到一个简单的 Widget,并将保存{ "color": "Green" },而不是{ "color": "Green", "hasSelfCleaningFeature": true }

如果你想让 SuperWidget 的属性被序列化,那么最好的选择是用 object 覆盖类型参数。 这将导致序列器包含所有数据,因为它对类型一无所知。

  1. Widget widget = new SuperWidget() { Color = "Green", HasSelfCleaningFeature = true, };
  2. await client.SaveStateAsync<object>("mystatestore", "mykey", widget);

错误处理

DaprClient 上的方法会在遇到失败时抛出 DaprException 或子类。

  1. try
  2. {
  3. var widget = new Widget() { Color = "Green", };
  4. await client.SaveStateAsync("mystatestore", "mykey", widget);
  5. }
  6. catch (DaprException ex)
  7. {
  8. // handle the exception, log, retry, etc.
  9. }

最常见的失败情况将与以下方面有关:

  • Dapr组件配置不正确
  • 暂时性故障,如网络问题
  • 无效数据,如未能反序列化JSON

在任何这些情况下,你都可以通过 .InnerException 属性检查更多的异常细节。