玩轉C#之【Hangfire】

介紹

使用情境

優點

• Simple 開發簡易、安裝簡單、方便部署
• Persistent 工作任務可存放於多種儲存裝置
• Transparent 提供 Dashboard 可及時查看工作任務狀態
• Reliable 執行失敗的工作任務有自動重試機制
• Distributed 可分散部署多台以同時處理大量工作
• 個別 Server 可設置同時處理數量以支援處理密集的工作任務

任務執行方式

• Fire-and-forgot jobs: 站台啟動後自動執行一次
• Delayed jobs: 可設定時間區間，每間格時間區間執行一次
• Recurring jobs: 可設定Cron敘述，並重複執行多次
• Continuations: 在某個job執行完後接續執行

版本

安裝方式

• Hangfire
• Hangfire.MemoryStorage

• Fire-and-forgot jobs: 站台啟動後自動執行一次

// GET: api/<HangfireDemoController>
        [HttpGet]
        public IActionResult OneNigh()
        {
            // 第一招射後不理
            // fire and got:站台啟動後只會執行一次
            BackgroundJob.Enqueue(() => Debug.WriteLine("fire and got"));
            return Ok("射後不理");
        }

• Delayed jobs: 可設定時間區間，每間格時間區間執行一次

[HttpGet]
        public IActionResult DelaySchedule()
        {
            Debug.WriteLine($"API現在時間：{DateTime.Now}");

            BackgroundJob.Schedule(
                () => Debug.WriteLine($"由HangFire排程發送，時間:{DateTime.Now}"),
                TimeSpan.FromSeconds(3));

            return Ok();
        }

• Recurring jobs: 可設定Cron敘述，並重複執行多次

[HttpGet]
        public IActionResult TimedRepeat()
        {
            Debug.WriteLine($"API現在時間：{DateTime.Now}");
            //【 秒 分 時 日 月 周 年 】，其中年是可選型別，也就是說他如果在不設定年分的情況下是每年。
            RecurringJob.AddOrUpdate(
                 () => Debug.WriteLine($"API現在時間：{DateTime.Now}")
                 , "15 7 * * *");

            return Ok();

        }

• Continuations: 在某個job執行完後接續執行

// GET: api/<HangfireDemoController>
        [HttpGet]
        public IActionResult Continuations()
        {
            // 第一招射後不理
            // fire and got:站台啟動後只會執行一次
            var jobid = BackgroundJob.Enqueue(() => Debug.WriteLine("fire and got"));
           
            BackgroundJob.ContinueJobWith(jobid,()=> Debug.WriteLine("two and got"));

            return Ok("接續射後不理");
        }

參考資料