如何：在 Dapr 中启用和使用 Actor可重入性

如何：在 Dapr 中启用和使用 Actor可重入性

进一步了解 Actor可重入性

虚拟actor模式的一个核心原则是actor执行的单线程特性。在没有重入的情况下，Dapr 运行时会锁定所有 actor 请求。在第一个请求完成之前，第二个请求无法启动。这意味着一个 actor 不能调用它自己，也不能让另一个 actor 调用它，即使它是同一个调用链的一部分。

重入功能允许来自同一链或上下文的请求重新进入已锁定的 actor ，从而解决了这一问题。这在以下情况下非常有用：

Actor 想调用自己的方法
Actors 在工作流程中用于执行工作，然后回调到协调 Actors。

可重入性的调用链示例如下：

Actor A -> Actor A
ActorA -> Actor B -> Actor A

有了重入功能，你就可以执行更复杂的 actor 调用，而无需牺牲虚拟 actor 的单线程行为。

maxStackDepth 参数设置一个值，该值控制对同一参与者进行多少次可重入调用。默认情况下，此值设置为32，这在大多数情况下已足够。

配置 actor 运行时以启用重入功能

可重入 actor 必须提供适当的配置。与其他 actor 配置元素类似，这是由 actor 端点 GET /dapr/config 完成的。

.NET
JavaScript
Python
Java
Go

public class Startup
{
    public void ConfigureServices(IServiceCollection services)
    {
        services.AddSingleton<BankService>();
        services.AddActors(options =>
        {
        options.Actors.RegisterActor<DemoActor>();
        options.ReentrancyConfig = new Dapr.Actors.ActorReentrancyConfig()
            {
            Enabled = true,
            MaxStackDepth = 32,
            };
        });
    }
}

import { CommunicationProtocolEnum, DaprClient, DaprServer } from "@dapr/dapr";
// Configure the actor runtime with the DaprClientOptions.
const clientOptions = {
  actor: {
    reentrancy: {
      enabled: true,
      maxStackDepth: 32,
    },
  },
};

from fastapi import FastAPI
from dapr.ext.fastapi import DaprActor
from dapr.actor.runtime.config import ActorRuntimeConfig, ActorReentrancyConfig
from dapr.actor.runtime.runtime import ActorRuntime
from demo_actor import DemoActor
reentrancyConfig = ActorReentrancyConfig(enabled=True)
config = ActorRuntimeConfig(reentrancy=reentrancyConfig)
ActorRuntime.set_actor_config(config)
app = FastAPI(title=f'{DemoActor.__name__}Service')
actor = DaprActor(app)
@app.on_event("startup")
async def startup_event():
    # Register DemoActor
    await actor.register_actor(DemoActor)
@app.get("/MakeExampleReentrantCall")
def do_something_reentrant():
    # invoke another actor here, reentrancy will be handled automatically
    return

这是一个用 Golang 编写的 actor 配置代码片段，通过 HTTP API 提供重入配置。可重入性尚未包含在 Go SDK 中。

type daprConfig struct {
    Entities                []string                `json:"entities,omitempty"`
    ActorIdleTimeout        string                  `json:"actorIdleTimeout,omitempty"`
    ActorScanInterval       string                  `json:"actorScanInterval,omitempty"`
    DrainOngoingCallTimeout string                  `json:"drainOngoingCallTimeout,omitempty"`
    DrainRebalancedActors   bool                    `json:"drainRebalancedActors,omitempty"`
    Reentrancy              config.ReentrancyConfig `json:"reentrancy,omitempty"`
}
var daprConfigResponse = daprConfig{
    []string{defaultActorType},
    actorIdleTimeout,
    actorScanInterval,
    drainOngoingCallTimeout,
    drainRebalancedActors,
    config.ReentrancyConfig{Enabled: true, MaxStackDepth: &maxStackDepth},
}
func configHandler(w http.ResponseWriter, r *http.Request) {
    w.Header().Set("Content-Type", "application/json")
    w.WriteHeader(http.StatusOK)
    json.NewEncoder(w).Encode(daprConfigResponse)
}

处理重入请求

重入请求的关键是Dapr-Reentrancy-Id请求头。该标头的值用于将请求与其调用链进行匹配，并允许它们绕过 actor 锁。

Dapr 运行时会为任何指定了重入配置的 actor 请求生成该标头。一旦生成，它就会被用来锁定 actor ，并且必须传递给以后的所有请求。下面是一个代理处理重入请求的示例：

func reentrantCallHandler(w http.ResponseWriter, r *http.Request) {
    /*
     * Omitted.
     */
    req, _ := http.NewRequest("PUT", url, bytes.NewReader(nextBody))
    reentrancyID := r.Header.Get("Dapr-Reentrancy-Id")
    req.Header.Add("Dapr-Reentrancy-Id", reentrancyID)
    client := http.Client{}
    resp, err := client.Do(req)
    /*
     * Omitted.
     */
}

例子

观看这个视频，了解如何使用Actor可重入性。

下一步

Actors in the Dapr SDKs

如何：Actor可重入性

如何：在 Dapr 中启用和使用 Actor可重入性

配置 actor 运行时以启用重入功能

处理重入请求

例子

下一步

相关链接