Пожар и забыть обмен сообщениями с актерами?

Question

Модель актера службы Fabric поддерживает только сообщение стиля «запрос-ответ», насколько я могу судить. Есть ли способ, которым я могу добиться общения с «огнем и забыть»? (Например: как «ask» vs «tell» messaging в Akka?)

Я столкнулся с этим сообщением в блоге (http://mikhail.io/2016/01/fire-and-forget-in-service-fabric-actors/), но не уверен, что это будет иметь какие-либо негативные последствия или если есть рекомендуемый способ выполнения этого?

Answer 1

Имейте метод инициализации вашего актера, который семян все, что требуется для вашей задачи. Установите таймер и вернитесь из метода инициализации. Когда таймер срабатывает, выключите таймер и запустите свою логику «Огонь и забудьте» с гарантией, что ваша работа будет выполнена. Грубый образец ниже.

public class SomeActor : Actor, ISomeActor 
{ 
    private IActorTimer _sendTimer; 

    protected override async Task OnActivateAsync() 
    { 
     await base.OnActivateAsync(); 
    } 

    protected override async Task OnDeactivateAsync() 
    { 
     await this.ExecuteAgents(); 
     await base.OnDeactivateAsync(); 
    } 

    public Task Initialize() 
    { 
     if (_sendTimer == null) 
     { 
      //setup timer 
      _sendTimer = this.RegisterTimer((obj) => 
      { 
       return this.Execute(); 
      }, 
       null, 
       TimeSpan.FromSeconds(1), 
       TimeSpan.FromSeconds(30)); 
     } 
    } 

    private async Task ExecuteAgents() 
    { 
     this.UnegisterTimer(_sendTimer); 

     //Perform workload 
    } 
}