IActorProxyFactory 接口

学习如何使用IActorProxyFactory接口创建actor客户端

Actor 类或者 ASP.NET Core 项目中,推荐使用 IActorProxyFactory 接口来创建 actor 客户端。

AddActors(...) 方法将通过 ASP.NET Core 依赖注入注册 actor 服务。

  • 在 actor 实例之外:IActorProxyFactory 实例可以通过依赖注入作为单例服务使用。
  • 在 actor 实例内部: IActorProxyFactory 实例可作为属性 (this.ProxyFactory) 使用。

下面是在 actor 内部创建代理的例子:

  1. public Task<MyData> GetDataAsync()
  2. {
  3. var proxy = this.ProxyFactory.CreateActorProxy<IOtherActor>(ActorId.CreateRandom(), "OtherActor");
  4. await proxy.DoSomethingGreat();
  5. return this.StateManager.GetStateAsync<MyData>("my_data");
  6. }

在本指南中,您将学习如何使用IActorProxyFactory

提示

对于一个非依赖注入的应用程序,你可以使用ActorProxy上的静态方法。 由于ActorProxy方法容易出错,在配置自定义设置时尽量避免使用它们。

识别一个 actor

所有在 IActorProxyFactory 上的API都需要一个actor类型和actor id来与一个actor进行通信。 对于强类型客户端,您还需要其中一个接口。

  • Actor类型在整个应用程序中唯一标识actor实现。
  • Actor id 唯一标识该类型的实例。

如果您没有一个演员 id 并且想要与一个新实例进行通信,请使用 ActorId.CreateRandom() 创建一个随机的 id。 由于随机 id 是加密的强标识符,因此当您与运行时交互时,运行时将创建一个新的 actor 实例。

你可以使用 ActorReference 类型与其他 actor 交换 actor 类型和 actor id ,作为消息的一部分。

Actor 客户端的两种风格

Actor客户端支持两种不同的调用方式:

Actor 客户端样式说明
强类型强类型的客户端是基于 .NET 接口的,提供了强类型的典型优点。 他们无法与非.NET actor 互操作。
弱类型弱类型的客户端使用ActorProxy类。 建议仅在需要时,出于互操作或其他高级原因使用这些。

使用强类型客户端

以下示例使用 CreateActorProxy<> 方法创建强类型客户端。 CreateActorProxy<>需要一个actor接口类型,并将返回该接口的实例。

  1. // Create a proxy for IOtherActor to type OtherActor with a random id
  2. var proxy = this.ProxyFactory.CreateActorProxy<IOtherActor>(ActorId.CreateRandom(), "OtherActor");
  3. // Invoke a method defined by the interface to invoke the actor
  4. //
  5. // proxy is an implementation of IOtherActor so we can invoke its methods directly
  6. await proxy.DoSomethingGreat();

使用弱类型客户端

以下示例使用 Create 方法创建弱类型客户端。 Create 返回 ActorProxy 的实例。

  1. // Create a proxy for type OtherActor with a random id
  2. var proxy = this.ProxyFactory.Create(ActorId.CreateRandom(), "OtherActor");
  3. // Invoke a method by name to invoke the actor
  4. //
  5. // proxy is an instance of ActorProxy.
  6. await proxy.InvokeMethodAsync("DoSomethingGreat");

由于 ActorProxy 是弱类型的代理,你需要将 actor 方法名作为字符串传入。

您也可以使用 ActorProxy 来调用带有请求消息和响应消息的方法。 请求和响应消息将使用System.Text.Json序列化器进行序列化。

  1. // Create a proxy for type OtherActor with a random id
  2. var proxy = this.ProxyFactory.Create(ActorId.CreateRandom(), "OtherActor");
  3. // Invoke a method on the proxy to invoke the actor
  4. //
  5. // proxy is an instance of ActorProxy.
  6. var request = new MyRequest() { Message = "Hi, it's me.", };
  7. var response = await proxy.InvokeMethodAsync<MyRequest, MyResponse>("DoSomethingGreat", request);

当使用弱类型的代理时,您必须主动定义正确的Actor方法名称和消息类型。 当使用强类型代理时,这些名称和类型将作为接口定义的一部分为您定义。

Actor方法调用异常详情

演员方法调用异常的详细信息会被显示给调用者和被调用者,提供了一个入口来追踪问题。 异常详细信息包括:

  • 方法名称
  • 行号
  • 异常类型
  • UUID

您可以使用UUID来在调用方和被调用方之间匹配异常。 下面是一个异常详细信息的示例:

  1. Dapr.Actors.ActorMethodInvocationException: Remote Actor Method Exception, DETAILS: Exception: NotImplementedException, Method Name: ExceptionExample, Line Number: 14, Exception uuid: d291a006-84d5-42c4-b39e-d6300e9ac38b

下一步

了解如何使用 ActorHost 进行演员的编写和运行.