有没有办法要求系统在启动时产生某些演员。
目前我激活了我需要的一组演员Program.cs
目前,我在演员注册后
这工作正常,但我偶尔会得到一个ReminderLoadInProgressException
,因为被激活的演员需要注册一个提醒,但在它尝试这样做时并非所有提醒都已加载。
是否有标准方法来播种集群?
有没有办法要求系统在启动时产生某些演员。
目前我激活了我需要的一组演员Program.cs
目前,我在演员注册后
这工作正常,但我偶尔会得到一个ReminderLoadInProgressException
,因为被激活的演员需要注册一个提醒,但在它尝试这样做时并非所有提醒都已加载。
是否有标准方法来播种集群?
不,你需要一些东西来激活你的演员。
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/
无法评论,所以我在这里发表评论:
为了完整起见:如果您的 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)
...