利用 Etcd 的Lease租約特性來實(shí)現(xiàn)定時功能，同時通過Watch機(jī)制來實(shí)現(xiàn)多節(jié)點(diǎn)情況下只有一個節(jié)點(diǎn)執(zhí)行該任務(wù)。通過定時任務(wù)庫 Cron 的時間字符串解析器Parser來解析任務(wù)執(zhí)行時間。
五常網(wǎng)站制作公司哪家好，找創(chuàng)新互聯(lián)！從網(wǎng)頁設(shè)計、網(wǎng)站建設(shè)、微信開發(fā)、APP開發(fā)、自適應(yīng)網(wǎng)站建設(shè)等網(wǎng)站項(xiàng)目制作，到程序開發(fā)，運(yùn)營維護(hù)。創(chuàng)新互聯(lián)成立與2013年到現(xiàn)在10年的時間，我們擁有了豐富的建站經(jīng)驗(yàn)和運(yùn)維經(jīng)驗(yàn)，來保證我們的工作的順利進(jìn)行。專注于網(wǎng)站建設(shè)就選創(chuàng)新互聯(lián)。
Etcd
Cron
源碼鏈接
func?startTimer(f?func())?{
go?func()?{
for?{
f()
now?:=?time.Now()
//?計算下一個零點(diǎn)
next?:=?now.Add(time.Hour?*?24)
next?=?time.Date(next.Year(),?next.Month(),?next.Day(),?0,?0,?0,?0,?next.Location())
t?:=?time.NewTimer(next.Sub(now))
-t.C
}
}()
}
本文介紹一些Go語言的基礎(chǔ)語法。
先來看一個簡單的go語言代碼：
go語言的注釋方法：
代碼執(zhí)行結(jié)果：
下面來進(jìn)一步介紹go的基礎(chǔ)語法。
go語言中格式化輸出可以使用 fmt 和 log 這兩個標(biāo)準(zhǔn)庫，
常用方法：
示例代碼：
執(zhí)行結(jié)果：
更多格式化方法可以訪問中的fmt包。
log包實(shí)現(xiàn)了簡單的日志服務(wù)，也提供了一些格式化輸出的方法。
執(zhí)行結(jié)果：
下面來介紹一下go的數(shù)據(jù)類型
下表列出了go語言的數(shù)據(jù)類型：
int、float、bool、string、數(shù)組和struct屬于值類型，這些類型的變量直接指向存在內(nèi)存中的值；slice、map、chan、pointer等是引用類型，存儲的是一個地址，這個地址存儲最終的值。
常量是在程序編譯時就確定下來的值，程序運(yùn)行時無法改變。
執(zhí)行結(jié)果：
執(zhí)行結(jié)果：
Go 語言的運(yùn)算符主要包括算術(shù)運(yùn)算符、關(guān)系運(yùn)算符、邏輯運(yùn)算符、位運(yùn)算符、賦值運(yùn)算符以及指針相關(guān)運(yùn)算符。
算術(shù)運(yùn)算符：
關(guān)系運(yùn)算符：
邏輯運(yùn)算符：
位運(yùn)算符：
賦值運(yùn)算符：
指針相關(guān)運(yùn)算符：
下面介紹一下go語言中的if語句和switch語句。另外還有一種控制語句叫select語句，通常與通道聯(lián)用，這里不做介紹。
if語法格式如下：
if ... else ：
else if：
示例代碼：
語法格式：
另外，添加 fallthrough 會強(qiáng)制執(zhí)行后面的 case 語句，不管下一條case語句是否為true。
示例代碼：
執(zhí)行結(jié)果：
下面介紹幾種循環(huán)語句：
執(zhí)行結(jié)果：
執(zhí)行結(jié)果：
也可以通過標(biāo)記退出循環(huán)：
--THE END--
在linux下實(shí)現(xiàn)定時器主要有如下方式
在這當(dāng)中 基于時間輪方式實(shí)現(xiàn)的定時器 時間復(fù)雜度最小，效率最高，然而我們可以通過 優(yōu)先隊列 實(shí)現(xiàn)時間輪定時器。
優(yōu)先隊列的實(shí)現(xiàn)可以使用最大堆和最小堆，因此在隊列中所有的數(shù)據(jù)都可以定義排序規(guī)則自動排序。我們直接通過隊列中 pop 函數(shù)獲取數(shù)據(jù)，就是我們按照自定義排序規(guī)則想要的數(shù)據(jù)。
在 Golang 中實(shí)現(xiàn)一個優(yōu)先隊列異常簡單，在 container/head 包中已經(jīng)幫我們封裝了，實(shí)現(xiàn)的細(xì)節(jié)，我們只需要實(shí)現(xiàn)特定的接口就可以。
下面是官方提供的例子
因?yàn)閮?yōu)先隊列底層數(shù)據(jù)結(jié)構(gòu)是由二叉樹構(gòu)建的，所以我們可以通過數(shù)組來保存二叉樹上的每一個節(jié)點(diǎn)。
改數(shù)組需要實(shí)現(xiàn) Go 預(yù)先定義的接口 Len , Less , Swap , Push , Pop 和 update 。
timerType結(jié)構(gòu)是定時任務(wù)抽象結(jié)構(gòu)
首先的 start 函數(shù)，當(dāng)創(chuàng)建一個 TimeingWheel 時，通過一個 goroutine 來執(zhí)行 start ,在start中for循環(huán)和select來監(jiān)控不同的channel的狀態(tài)
通過for循環(huán)從隊列中取數(shù)據(jù)，直到該隊列為空或者是遇見第一個當(dāng)前時間比任務(wù)開始時間大的任務(wù)， append 到 expired 中。因?yàn)閮?yōu)先隊列中是根據(jù) expiration 來排序的，
所以當(dāng)取到第一個定時任務(wù)未到的任務(wù)時，表示該定時任務(wù)以后的任務(wù)都未到時間。
當(dāng) getExpired 函數(shù)取出隊列中要執(zhí)行的任務(wù)時，當(dāng)有的定時任務(wù)需要不斷執(zhí)行，所以就需要判斷是否該定時任務(wù)需要重新放回優(yōu)先隊列中。 isRepeat 是通過判斷任務(wù)中 interval 是否大于 0 判斷，
如果大于0 則，表示永久就生效。
防止外部濫用，阻塞定時器協(xié)程，框架又一次封裝了timer這個包，名為 timer_wapper 這個包,它提供了兩種調(diào)用方式。
參數(shù)和上面的參數(shù)一樣，只是在第三個參數(shù)中使用了任務(wù)池，將定時任務(wù)放入了任務(wù)池中。定時任務(wù)的本身執(zhí)行就是一個 put 操作。
至于put以后，那就是 workers 這個包管理的了。在 worker 包中， 也就是維護(hù)了一個任務(wù)池，任務(wù)池中的任務(wù)會有序的執(zhí)行，方便管理。
重慶分公司
重慶分公司
