分布式系統(tǒng)架構(gòu)之構(gòu)建你的任務(wù)調(diào)度中心
分布式系統(tǒng)中，我們經(jīng)常會(huì)遇到定時(shí)執(zhí)行任務(wù)，而這些定時(shí)任務(wù)中，多數(shù)情況都是需要執(zhí)行一些http請(qǐng)求。比如：
- 輪訓(xùn)支付結(jié)果（雖然第三方支付中心有支付回調(diào)，但有時(shí)候并不能有效保證你的業(yè)務(wù)系統(tǒng)能收到正確的結(jié)果）
- 未支付訂單超時(shí)取消，電商系統(tǒng)訂單，用戶(hù)未支付訂單，超時(shí)后取消訂單
- 已支付已簽收訂單，超時(shí)后自動(dòng)完成訂單
- 同步微信公眾號(hào)用戶(hù)數(shù)據(jù)做分析
- 同步企業(yè)微信通訊錄及客戶(hù)信息
- 等等
很多業(yè)務(wù)場(chǎng)景都需要用到定時(shí)執(zhí)行http請(qǐng)求的任務(wù)
本次，我們?cè)趎etcore 環(huán)境，使用 Jango.JobCenter來(lái)快速構(gòu)建我們的任務(wù)調(diào)度中心
Jango.JobCenter目前是基于Hangfire的 .NETStandard 2.0版本Demo源碼，請(qǐng)移步https://github.com/jangocheng/Jango.JobCenter.demo
dotnet new webapi 創(chuàng)建一個(gè)webapi項(xiàng)目
dotnet add package Jango.JobCenter --version 1.0.0.1
編輯StartUp文件
- 引用 Jango.JobCenter
using Jango.JobCenter;
- 修改ConfigureServices(IServiceCollection services)
services.AddJangoJobCenter();
- 修改Configure(IApplicationBuilder app, IWebHostEnvironment env)
app.UseJangoJobCenter();
還原依賴(lài)包后，dotnet run 運(yùn)行
可以看到，我們的任務(wù)調(diào)度中心已經(jīng)運(yùn)行起來(lái)了。
https://localhost:5001/hangfire 查看任務(wù)中心儀表盤(pán)
https://localhost:5001/swagger/index.html 查看Jango.JobCenter 的文檔
Jango.JobCenter第一個(gè)接口為測(cè)試接口，僅僅Console輸出
curl -X POST "https://localhost:5001/console" -H "accept: */*" -d ""
或者postman post 調(diào)用https://localhost:5001/console
可以看到結(jié)果輸出 job name console is working now.
第二個(gè)接口為http 創(chuàng)建定時(shí)任務(wù)接口參數(shù)如下：
{
"name": "",//job name
"desc": "",//job 描述
"url": "",//定時(shí)調(diào)用url
"method": "", //http method ：get/post/put/delete
"header": "",//http header 以kv形式，多個(gè)以,分割 比如: k1:v1,k2:v2
"requestBody": "",//http 請(qǐng)求體
"isRetry": true,//遇到錯(cuò)誤是否重試
"retryTimes": 0,//重試次數(shù)
"isCircle": true,//是否周期性任務(wù)
"cron": "*/5 * * * * ?"//cron 表達(dá)式 此項(xiàng)移除，則系統(tǒng)默認(rèn)5s執(zhí)行一次http請(qǐng)求
}
我們來(lái)測(cè)試下：參數(shù)輸入：
{
"name": "demo", //demo
"desc": "定時(shí)調(diào)用百度",//
"url": "https://www.baidu.com",
"method": "get",//get方式
"header": "",
"requestBody": "",
"isRetry": false,// 錯(cuò)誤后不重試
"retryTimes": 0,
"isCircle": true//周期性任務(wù)
//無(wú)Cron參數(shù)，系統(tǒng)默認(rèn)每隔5s執(zhí)行一次任務(wù)
}
postman執(zhí)行：返回結(jié)果：
來(lái)看下console輸出：
黃色背景的內(nèi)容，即為定時(shí)執(zhí)行的結(jié)果。我們來(lái)看下任務(wù)中心面板
我們來(lái)看下任務(wù)中心儀表盤(pán)
可以看到已經(jīng)開(kāi)始執(zhí)行任務(wù)了
至此，你的任務(wù)調(diào)度中心，已經(jīng)構(gòu)建完成。可以任意創(chuàng)建相關(guān)任務(wù)了
