func?startTimer(f?func())?{
創(chuàng)新互聯(lián)公司專注于企業(yè)網(wǎng)絡(luò)營銷推廣、網(wǎng)站重做改版、湯陰網(wǎng)站定制設(shè)計(jì)、自適應(yīng)品牌網(wǎng)站建設(shè)、H5響應(yīng)式網(wǎng)站、商城開發(fā)、集團(tuán)公司官網(wǎng)建設(shè)、成都外貿(mào)網(wǎng)站建設(shè)公司、高端網(wǎng)站制作、響應(yīng)式網(wǎng)頁設(shè)計(jì)等建站業(yè)務(wù)，價(jià)格優(yōu)惠性價(jià)比高，為湯陰等各大城市提供網(wǎng)站開發(fā)制作服務(wù)。
go?func()?{
for?{
f()
now?:=?time.Now()
//?計(jì)算下一個(gè)零點(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
}
}()
}
利用 Etcd 的Lease租約特性來實(shí)現(xiàn)定時(shí)功能，同時(shí)通過Watch機(jī)制來實(shí)現(xiàn)多節(jié)點(diǎn)情況下只有一個(gè)節(jié)點(diǎn)執(zhí)行該任務(wù)。通過定時(shí)任務(wù)庫 Cron 的時(shí)間字符串解析器Parser來解析任務(wù)執(zhí)行時(shí)間。
Etcd
Cron
源碼鏈接
在linux下實(shí)現(xiàn)定時(shí)器主要有如下方式
在這當(dāng)中 基于時(shí)間輪方式實(shí)現(xiàn)的定時(shí)器 時(shí)間復(fù)雜度最小，效率最高，然而我們可以通過 優(yōu)先隊(duì)列 實(shí)現(xiàn)時(shí)間輪定時(shí)器。
優(yōu)先隊(duì)列的實(shí)現(xiàn)可以使用最大堆和最小堆，因此在隊(duì)列中所有的數(shù)據(jù)都可以定義排序規(guī)則自動(dòng)排序。我們直接通過隊(duì)列中 pop 函數(shù)獲取數(shù)據(jù)，就是我們按照自定義排序規(guī)則想要的數(shù)據(jù)。
在 Golang 中實(shí)現(xiàn)一個(gè)優(yōu)先隊(duì)列異常簡單，在 container/head 包中已經(jīng)幫我們封裝了，實(shí)現(xiàn)的細(xì)節(jié)，我們只需要實(shí)現(xiàn)特定的接口就可以。
下面是官方提供的例子
因?yàn)閮?yōu)先隊(duì)列底層數(shù)據(jù)結(jié)構(gòu)是由二叉樹構(gòu)建的，所以我們可以通過數(shù)組來保存二叉樹上的每一個(gè)節(jié)點(diǎn)。
改數(shù)組需要實(shí)現(xiàn) Go 預(yù)先定義的接口 Len , Less , Swap , Push , Pop 和 update 。
timerType結(jié)構(gòu)是定時(shí)任務(wù)抽象結(jié)構(gòu)
首先的 start 函數(shù)，當(dāng)創(chuàng)建一個(gè) TimeingWheel 時(shí)，通過一個(gè) goroutine 來執(zhí)行 start ,在start中for循環(huán)和select來監(jiān)控不同的channel的狀態(tài)
通過for循環(huán)從隊(duì)列中取數(shù)據(jù)，直到該隊(duì)列為空或者是遇見第一個(gè)當(dāng)前時(shí)間比任務(wù)開始時(shí)間大的任務(wù)， append 到 expired 中。因?yàn)閮?yōu)先隊(duì)列中是根據(jù) expiration 來排序的，
所以當(dāng)取到第一個(gè)定時(shí)任務(wù)未到的任務(wù)時(shí)，表示該定時(shí)任務(wù)以后的任務(wù)都未到時(shí)間。
當(dāng) getExpired 函數(shù)取出隊(duì)列中要執(zhí)行的任務(wù)時(shí)，當(dāng)有的定時(shí)任務(wù)需要不斷執(zhí)行，所以就需要判斷是否該定時(shí)任務(wù)需要重新放回優(yōu)先隊(duì)列中。 isRepeat 是通過判斷任務(wù)中 interval 是否大于 0 判斷，
如果大于0 則，表示永久就生效。
防止外部濫用，阻塞定時(shí)器協(xié)程，框架又一次封裝了timer這個(gè)包，名為 timer_wapper 這個(gè)包,它提供了兩種調(diào)用方式。
參數(shù)和上面的參數(shù)一樣，只是在第三個(gè)參數(shù)中使用了任務(wù)池，將定時(shí)任務(wù)放入了任務(wù)池中。定時(shí)任務(wù)的本身執(zhí)行就是一個(gè) put 操作。
至于put以后，那就是 workers 這個(gè)包管理的了。在 worker 包中， 也就是維護(hù)了一個(gè)任務(wù)池，任務(wù)池中的任務(wù)會有序的執(zhí)行，方便管理。
swoole-1.7.7 發(fā)布，內(nèi)置Http服務(wù)器性能是Node.js的12倍
PHP的異步并發(fā)擴(kuò)展swoole發(fā)布了 1.7.7 版本，此版本主要有：
增加對cygwin環(huán)境的支持
增加單次定時(shí)器的after接口
onClose事件調(diào)整為在close前觸發(fā)
增加內(nèi)置Http服務(wù)器
修復(fù)目前已知的所有BUG
單次定時(shí)器
swoole之前的版本僅支持間隔時(shí)間的固定定時(shí)器，1.7.7新增了單次定時(shí)器接口，可以指定在當(dāng)前時(shí)間之后的n毫秒內(nèi)執(zhí)行一段代碼。
?
1
2
3
swoole_timer_after(500, function(){
echo "Hello Swoole\n";
}); //500ms
在服務(wù)器端程序中可以調(diào)用swoole_server對象的after方法。
?
1
2
3
4
5
$server-on('receive', function($server, $fd, $from_id, $data(){
$server-after(2000, function(){
echo "timeout\n";
});
}));
內(nèi)置Http服務(wù)器
在此版本中swoole內(nèi)部集成了一個(gè)Http服務(wù)器，由底層的C代碼解析Http協(xié)議。得益于swoole的多線程Reactor+多進(jìn)程模型，swoole內(nèi)置Http服務(wù)器的性能非常好。通過使用apache bench工具進(jìn)行壓測，性能是node.js的12倍，php-fpm的6倍，Go語言內(nèi)置的Http服務(wù)器的1.42倍。
壓測方法：
?
1
ab -c 200 -n 200000 -k
硬件環(huán)境：
?
1
Inter Core I5 3.2G * 4核 + 8G內(nèi)存
重慶分公司
重慶分公司
