1.前言
無論是用ruby做系統(tǒng)管理,還是用rails做web開發(fā),都可能遇到周期性任務(wù),它們按照一定時(shí)間周期(1小時(shí),2天......)持續(xù)地觸發(fā)。在ruby中,我認(rèn)為一次性任務(wù)使用sidekiq來完成是非常方便的,而周期性的任務(wù)就需要用到whenever,sidetiq,clockwork等等gem了。
2.whenever
首先,whenever是基于linux的cron服務(wù)的,所以,在windows平臺(tái)上沒有直接的方法使用該gem。whenever嚴(yán)格來說應(yīng)該算一個(gè)cron的翻譯器,將ruby代碼翻譯為cron腳本,從而將周期性任務(wù)轉(zhuǎn)交給cron實(shí)際去完成。對(duì)于精通cron的shell程序員來說可能不值一提,但對(duì)rubyist卻不是。首先,我們可以使用ruby語言來書寫任務(wù)代碼,在ruby層面上控制代碼,避免了和一些shell腳本的切換;另外,cron命令很強(qiáng)大,但我總是記不住它的命令參數(shù),為了避免一遍一遍去man它的手冊(cè),還是ruby語法比較親民。
首先,安裝whenever:
復(fù)制代碼 代碼如下:
$ gem install whenever
然后切換到任務(wù)編寫文件夾project下,保證該文件夾下有一個(gè)config文件夾。如果是在rails項(xiàng)目中建立whenever任務(wù),則config文件夾已經(jīng)存在了。
復(fù)制代碼 代碼如下:
$ cd /project
$ wheneverize .
whenverize命令會(huì)在config文件夾下創(chuàng)建schedule.rb文件,我們的任務(wù)代碼需要在該文件中定義。下面的是schedule.rb文件示例:
復(fù)制代碼 代碼如下:
every 30.minutes do
runner "Blog.parseAll"
end
every 30.minutes, :at => 17 do
runner "PostWeibo.post"
end
every 15.minutes do
runner "WeiBo.update"
end
every 30.minutes, :at => 20 do
runner "RSSGenerator.generate"
end
every 1.day, :at => '2:00 am' do
command "cd /var/www/mzread/current/public gunzip -c sitemap1.xml.gz > sitemap1.xml touch sitemap1.xml "
end
如示例代碼,whenever默認(rèn)定義了三種任務(wù)類型:runner, rake, command,我們也可以定義自己的任務(wù),比如,下面的代碼定義了脫離rails環(huán)境,獨(dú)立執(zhí)行ruby代碼的類型:
復(fù)制代碼 代碼如下:
job_type :ruby, "cd :path /usr/bin/ruby ':task'.rb"
every :hour do
ruby 'have_a_rest'
end
該示例描述了:每個(gè)小時(shí)會(huì)執(zhí)行一次當(dāng)前文件夾下的have_a_rest.rb腳本。
下面看看怎么將任務(wù)寫入cron服務(wù)。
復(fù)制代碼 代碼如下:
$ whenever #不帶參數(shù)的whenever會(huì)顯示轉(zhuǎn)換程cron任務(wù)的代碼,不寫入cron任務(wù)表
$ whenever -w #寫入cron任務(wù)表,開始執(zhí)行
$ whenever -c #取消任務(wù)
如果要查看cron任務(wù)表,也可以使用linux的命令列出所有cron任務(wù):
復(fù)制代碼 代碼如下:
$ crontab -l
3.sidetiq
sidetiq是sidekiq的親兄弟,如果在rails項(xiàng)目中使用sidekiq來處理后臺(tái)任務(wù),那么就用sidetiq來交付周期性任務(wù)也顯得比較自然。
安裝sidetiq:
復(fù)制代碼 代碼如下:
$ [sudo] gem install sidetiq
定義周期性任務(wù):
復(fù)制代碼 代碼如下:
class MyWorker
include Sidekiq::Worker
include Sidetiq::Schedulable
recurrence { daily }
def perform
# do stuff ...
end
end
sidetiq和sidekiq一樣,依賴于redis消息來處理消息。當(dāng)rails項(xiàng)目啟動(dòng)后,這些周期性任務(wù)會(huì)自動(dòng)加載執(zhí)行。
4.clockwork
clockwork和sidetiq一樣,也不必依賴于cron,可以適應(yīng)”跨平臺(tái)“要求。下面是代碼示例(clock.rb):
復(fù)制代碼 代碼如下:
require 'clockwork'
include Clockwork
handler do |job|
puts "Running #{job}"
end
every(10.seconds, 'frequent.job')
every(3.minutes, 'less.frequent.job')
every(1.hour, 'hourly.job')
every(1.day, 'midnight.job', :at => '00:00')
啟動(dòng)任務(wù):
復(fù)制代碼 代碼如下:
$ clockwork clock.rb
Starting clock for 4 events: [ frequent.job less.frequent.job hourly.job midnight.job ]
Triggering frequent.job
如果要帶上rails環(huán)境,就在任務(wù)文件加入:
復(fù)制代碼 代碼如下:
require './config/boot'
require './config/environment'