5

有没有办法要求系统在启动时产生某些演员。

目前我激活了我需要的一组演员Program.cs目前,我在演员注册后

这工作正常,但我偶尔会得到一个ReminderLoadInProgressException,因为被激活的演员需要注册一个提醒,但在它尝试这样做时并非所有提醒都已加载。

是否有标准方法来播种集群?

4

2 回答 2

8

不,你需要一些东西来激活你的演员。

Program.cs 不是执行此操作的最佳位置,因为您可能已经注意到,它的执行与您的服务的生命周期并不相符。

如果您需要在您的演员服务启动时激活一些演员,那么在您的演员服务的 RunAsync 方法中执行此操作的好地方。您可以通过编写派生自它的服务来自定义您的参与者服务,就像您编写有状态服务时所做的一样:

编辑:确保您首先调用并等待 base.RunAsync() !

class MyActorService : ActorService
{
    public MyActorService(StatefulServiceContext context, ActorTypeInformation typeInfo, Func<ActorBase> newActor)
        : base(context, typeInfo, newActor)
    { }

    protected async override Task RunAsync(CancellationToken cancellationToken)
    {
        await base.RunAsync(cancellationToken);

        var proxy = ActorProxy.Create<IMyActor>(new ActorId(0));
        await proxy.StartDoingStuff();
    }
}

然后注册您的演员服务,以便运行时知道使用它来托管您的演员实例:

static class Program
{
    private static void Main()
    {
        ActorRuntime.RegisterActorAsync<MyActor>(
            (context, actorType) => new MyActorService(context, actorType, () => new MyActor()))
            .GetAwaiter().GetResult();

        Thread.Sleep(Timeout.Infinite);
    }
}

只要确保actor方法是幂等的,因为每次启动actor服务的主副本时都会执行(在故障转移、资源平衡、应用程序升级等之后),但好的是它不会在你之前执行演员服务已准备就绪,它将始终在服务启动时执行。

有关如何使用演员服务的更多信息,请参阅此处:https ://azure.microsoft.com/en-us/documentation/articles/service-fabric-reliable-actors-platform/

于 2016-04-19T22:55:54.570 回答
6

无法评论,所以我在这里发表评论:

为了完整起见:如果您的 ActorService 子类没有默认名称(来自 ServiceManifest.xml - 例如您动态生成服务实例),您将不得不像这样使用双参数 ActorProxy.Create 重载:

var actor = ActorProxy.Create<IMyActor>(new ActorId(0), this.Context.ServiceName);

否则你会得到“服务不存在”异常:

System.Fabric.FabricServiceNotFoundException: Service does not exist. 
---> System.Runtime.InteropServices.COMException: Exception from HRESULT: 0x80071BCD at
System.Fabric.Interop.NativeClient.IFabricServiceManagementClient4
.EndResolveServicePartition(IFabricAsyncOperationContext context)
...
于 2016-06-23T08:53:56.657 回答