在.NET SDK中运行和使用 virtual actors 的例子。

通过Dapr actor 程序包，您可以与.NET应用程序中的Dapr虚拟actor进行交互。

Dapr CLI installed
Initialized
.NET Core 3.1 或 .NET 5+ 已安装

概述

本文档描述了如何创建一个Actor() 并从客户端程序调用其方法。

接口项目(\MyActor\MyActor.Interfaces). 该项目包含了actor的接口定义。 Actor接口可以在任何项目中以任意的名称定义。它定义了actor的实现和调用actor的客户端之间的约定。由于客户端项目可能会依赖它，所以在一个和actor实现分隔开的程序集中定义通常是有意义的。
Actor服务项目 (\MyActor\MyActorService)。 该项目实现了Asp.Net Core web service，用于托管actor。它包含了actor的实现，MyActor.cs。 Actor的实现是一个继承了基类Actor并且实现了Myactor.Interfaces项目中定义的接口的类。 Actor还必须提供接受一个ActorService实例和ActorId的构造函数，并将他们传递给基类。
[Actor(TypeName = “MyCustomActorTypeName”)] internal class MyActor : Actor, IMyActor { // … }

由于我们将创建3个项目，所以选择一个空的目录开始，在你选择的终端中打开它。

第 1 步：创建 actor 接口

Actor接口定义了actor的实现和调用actor的客户端之间的约定。

Actor接口的定义需要满足以下要求：

Actor接口必须继承 Dapr.Actors.IActor 接口
Actor方法的返回值必须是Task 或者 Task<object>类型
Actor方法最多只能有一个参数

# 创建 Actor 接口
dotnet new classlib -o MyActor.Interfaces
cd MyActor.Interfaces
# 添加 Dapr.Actors nuget 包。 请使用来自 nuget.org 的最新软件包版本
dotnet add package Dapr.Actors -v 1.0.0
cd ..

定义IMyActor接口

定义 IMyActor 接口和 MyData 数据对象。在 Myactor.Interface 项目中，将以下代码粘贴到 Myactor.cs 中。

using Dapr.Actors;
using System.Threading.Tasks;
namespace MyActor.Interfaces
{
    public interface IMyActor : IActor
    {       
        Task<string> SetDataAsync(MyData data);
        Task<MyData> GetDataAsync();
        Task RegisterReminder();
        Task UnregisterReminder();
        Task RegisterTimer();
        Task UnregisterTimer();
    }
    public class MyData
    {
        public string PropertyA { get; set; }
        public string PropertyB { get; set; }
        public override string ToString()
        {
            var propAValue = this.PropertyA == null ? "null" : this.PropertyA;
            var propBValue = this.PropertyB == null ? "null" : this.PropertyB;
            return $"PropertyA: {propAValue}, PropertyB: {propBValue}";
        }
    }
} "null" : this.PropertyA;
            var propBValue = this.PropertyB == null ? "null" : this.PropertyB;
            return $"PropertyA: {propAValue}, PropertyB: {propBValue}";
        }
    }
}

# 创建 ASP.Net Web 服务来托管 Dapr actor
dotnet new web -o MyActorService
cd MyActorService
# 添加 Dapr.Actors.AspNetCore nuget 包. 请从nuget.org添加最新的包版本
dotnet add package Dapr.Actors.AspNetCore -v 1.0.0
# 添加 Actor 接口引用
dotnet add reference ../MyActor.Interfaces/MyActor.Interfaces.csproj
cd ..

添加 actor 实现

实现IMyActor接口并继承自 Dapr.Actors.Actor 。下面的例子同样展示了如何使用Actor Reminders。 Actor如果要使用Reminders，则必须实现IRemindable接口如果你不打算使用Reminder功能，你可以跳过下面代码中实现IRemindable接口和Reminder特定方法的操作。

在 MyActorService 项目中，将以下代码粘贴到 MyActor.cs 中。

Actor runtime 使用 ASP.NET Core Startup.cs 来配置。

运行时使用ASP.NET Core依赖注入系统来注册actor类型和基本服务。通过在 ConfigureServices(...) 中调用 AddActors(...) 方法来提供这种集成。使用传递到 AddActors(...) 方法的委托来注册actor类型并配置actor运行时设置。你可以在中为依赖注入注册额外的类型。它们都可以被注入到你的Actor类型的构造器。

Actors通过Dapr runtime使用HTTP调用来实现。此功能是应用程序的 HTTP 处理管道的一部分，在 Configure(...) 方法中的UseEndpoint(...) 注册。

在 MyActorService 项目中，将以下代码粘贴到 Startup.cs 中。

using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
namespace MyActorService
{
    public class Startup
    {
        public void ConfigureServices(IServiceCollection services)
        {
            services.AddActors(options =>
            {
                // Register actor types and configure actor settings
                options.Actors.RegisterActor<MyActor>();
            });
        }
        public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
        {
            if (env.IsDevelopment())
            {
                app.UseDeveloperExceptionPage();
            }
            app.UseHttpsRedirection();
            app.UseRouting();
            app.UseEndpoints(endpoints =>
            {
                // Register actors handlers that interface with the Dapr runtime.
                endpoints.MapActorsHandlers();
            });
        }
    }
}

第 3 步：添加客户端

创建一个简单的控制台应用来调用actor服务。 Dapr SDK 提供 Actor 代理客户端来调用Actor接口中定义的actor方法。

创建 actor 客户端项目并添加依赖

# 创建 Actor 客户端
dotnet new console -o MyActorClient
cd MyActorClient
# 添加 Dapr.Actors nuget 包。 Please use the latest package version from nuget.org
请从nuget.org添加最新的包版本
dotnet add package Dapr.Actors -v 1.0.0
# 添加 Actor 接口引用
dotnet add reference ../MyActor.Interfaces/MyActor.Interfaces.csproj
cd ..

您可以使用 ActorProxy.Create<IMyActor>(.) 来创建一个强类型客户端，并调用 actor 上的方法。

在 MyActorClient 项目中，将以下代码粘贴到 Program.cs 中。

using System;
using System.Threading.Tasks;
using Dapr.Actors;
using Dapr.Actors.Client;
using MyActor.Interfaces;
namespace MyActorClient
{
    class Program
        static async Task MainAsync(string[] args)
        {
            // Registered Actor Type in Actor Service
            var actorType = "MyActor";
            // An ActorId uniquely identifies an actor instance
            // If the actor matching this id does not exist, it will be created
            var actorId = new ActorId("1");
            // Create the local proxy by using the same interface that the service implements.
            //
            // You need to provide the type and id so the actor can be located. 
            var proxy = ActorProxy.Create<IMyActor>(actorId, actorType);
            // Now you can use the actor interface to call the actor's methods.
            Console.WriteLine($"Calling SetDataAsync on {actorType}:{actorId}...");
            var response = await proxy.SetDataAsync(new MyData()
            {
                PropertyA = "ValueA",
                PropertyB = "ValueB",
            });
            Console.WriteLine($"Got response: {response}");
            Console.WriteLine($"Calling GetDataAsync on {actorType}:{actorId}...");
            var savedData = await proxy.GetDataAsync();
            Console.WriteLine($"Got response: {response}");
        }
    }
}
            var proxy = ActorProxy.Create<IMyActor>(actorId, actorType);
            // Now you can use the actor interface to call the actor's methods.

运行 MyActorService

由于MyActorService正在托管 Actors，因此需要使用 Dapr CLI 来运行。

您将在这个终端中看到 daprd 和 MyActorService 的命令行输出。您应该看到以下情况，这表明应用程序已成功启动。

...
ℹ️  Updating metadata for app command: dotnet run
✅  You're up and running!  
== APP == info: Microsoft.Hosting.Lifetime[0]
== APP ==       Now listening on: https://localhost:5001
== APP == info: Microsoft.Hosting.Lifetime[0]
== APP ==       Now listening on: http://localhost:5000
== APP == info: Microsoft.Hosting.Lifetime[0]
== APP ==       Application started. Press Ctrl+C to shut down.
== APP == info: Microsoft.Hosting.Lifetime[0]
== APP ==       Hosting environment: Development
== APP == info: Microsoft.Hosting.Lifetime[0]
== APP ==       Content root path: /Users/ryan/actortest/MyActorService

运行 MyActorClient

MyActorClient 作为客户端，它可以用 dotnet run 正常运行。

打开一个新的终端，导航到 MyActorClient 目录。然后运行此项目：
```
dotnet run
```
您应该看到命令行输出，如：
```
Startup up...
Calling SetDataAsync on MyActor:1...
Got response: Success
Calling GetDataAsync on MyActor:1...
Got response: Success
```

现在您已经成功创建了 actor 服务和客户端。查看相关链接部分了解更多信息。

Example