Actor的api是必需的,因为 Dapr 挎斗调用应用程序来承载和与执行组件实例进行交互,所以在Startup的Configure中配置
app.UseEndpoints(endpoints =>
{
endpoints.MapActorsHandlers();
// .......
});
Startup
类是用于注册特定执行组件类型的位置。 在ConfigureServices
注册 services.AddActors
:
services.AddActors(options =>
{
options.Actors.RegisterActor<OrderStatusActor>();
});
为测试这个Actor,需要定义一个接口调用,新增ActorController
using Dapr.Actors;
using Dapr.Actors.Client;
using FrontEnd.ActorDefine;
using Microsoft.AspNetCore.Mvc;
using System.Threading.Tasks;
namespace FrontEnd.Controllers
{
[Route("[controller]")]
[ApiController]
public class ActorController : ControllerBase
{
[HttpGet("paid/{orderId}")]
public async Task<ActionResult> PaidAsync(string orderId)
{
var actorId = new ActorId("myid-"+orderId);
var proxy = ActorProxy.Create<IOrderStatusActor>(actorId, "OrderStatusActor");
var result = await proxy.Paid(orderId);
return Ok(result);
}
}
}
ActorProxy.Create
为创建代理实例。 Create
方法采用两个参数:标识特定执行组件和执行组件 ActorId
类型。 它还具有一个泛型类型参数,用于指定执行组件类型所实现的执行组件接口。 由于服务器和客户端应用程序都需要使用执行组件接口,它们通常存储在单独的共享项目中。
下面通过postman测试下,调用成功
查看redis中的数据
127.0.0.1:6379> keys *
1) "test_topic"
2) "frontend||guid"
3) "frontend||name"
5) "newOrder"
6) "frontend||OrderStatusActor||myid-123||123"
7) "myapp2||key2"
8) "myapp2||key1"
9) "deathStarStatus"
10) "myapp||name"
127.0.0.1:6379> hgetall frontend||OrderStatusActor||myid-123||123
1) "data"
2) "\"init\""
3) "version"
4) "1"
可以发现actor数据的命名规则是appName||ActorName||ActorId||key
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。