asp.netのHangFire定期ジョブ

Question

私はHangFireを使用してX分/時間ごとにタスクを処理し始め、定期的なジョブを追加する必要があります。コンソールアプリケーションでは、私はそれをうまくやっていましたが、asp.netで、私はBackgroundJob.Enqueueメソッドを使って一度しか動かすことができません。

public class Global : HttpApplication 
{ 
    private static string LigacaoBD = myConn; 
    private static ApiMethods sportRadar = new ApiMethods(); 
    private static Jogo jogo = new Jogo(LigacaoBD); 
    private static List<SportRadar.ClassesCliente.Jogo> jogos; 
    private static List<SportRadar.ClassesCliente.Competicao> competicoes; 

    void Application_Start(object sender, EventArgs e) 
    { 
     // Code that runs on application startup 
     RouteConfig.RegisterRoutes(RouteTable.Routes); 
     BundleConfig.RegisterBundles(BundleTable.Bundles); 

     GlobalConfiguration.Configuration.UseSqlServerStorage(LigacaoBD); 

     using (var connection = JobStorage.Current.GetConnection()) 
     { 
      foreach (var recurringJob in connection.GetRecurringJobs()) 
      { 
       RecurringJob.RemoveIfExists(recurringJob.Id); 
      } 
     } 

     using (var server = new BackgroundJobServer()) 
     { 
      // This works just fine 
      var id=BackgroundJob.Enqueue(() => Actualizacoes()); 
      // This does not. 
      // I even checked the DB for job queue or something but couldn't find anything 
      RecurringJob.AddOrUpdate(id,() => Actualizacoes(), Cron.Minutely); 
     } 
    } 



    public void Actualizacoes() 
    { 
     // Stuff I need to do regularly 
    } 
} 

私はそれが正しいと思ったが、明らかに私はここで何か間違っていた。問題はどこにあると思いますか？

Answer 1

2つの問題があります。

1。 idを渡しているため、実装では不要です。

BackgroundJob.Enqueueは、ジョブの一意の識別子を返します。コードでは、このジョブはすでにキューに入れられて実行されています。

変更

RecurringJob.AddOrUpdate(id,() => Actualizacoes(), Cron.Minutely); 

RecurringJob.AddOrUpdate(() => Actualizacoes(), Cron.Minutely); 

にまた、あなたはusing文でBackgroundJobServerの作成をラップしています。それからそこに仕事を作ります。したがって、BackgroundJobServerはGCによってクリアされています。

代わりに、これを試してみてください。

public class Global : HttpApplication 
{ 
    private static string LigacaoBD = myConn; 
    private static ApiMethods sportRadar = new ApiMethods(); 
    private static Jogo jogo = new Jogo(LigacaoBD); 
    private static List<SportRadar.ClassesCliente.Jogo> jogos; 
    private static List<SportRadar.ClassesCliente.Competicao> competicoes; 

    private BackgroundJobServer _backgroundJobServer; 

    void Application_Start(object sender, EventArgs e) 
    { 
     // Code that runs on application startup 
     RouteConfig.RegisterRoutes(RouteTable.Routes); 
     BundleConfig.RegisterBundles(BundleTable.Bundles); 

     GlobalConfiguration.Configuration.UseSqlServerStorage(LigacaoBD); 

     using (var connection = JobStorage.Current.GetConnection()) 
     { 
      foreach (var recurringJob in connection.GetRecurringJobs()) 
      { 
       RecurringJob.RemoveIfExists(recurringJob.Id); 
      } 
     } 

     //create an instance of BackgroundJobServer 
     _backgroundJobServer = new BackgroundJobServer(); 

     //add your recurring job 
     RecurringJob.AddOrUpdate(() => Actualizacoes(), Cron.Minutely); 
    } 
}