ruby中执行周期性任务(定时任务)的3种方法_ruby专题

1.前言

     无论是用ruby做系统管理,还是用rails做web开发,都可能遇到周期性任务,它们按照一定时间周期(1小时,2天......)持续地触发。在ruby中,我认为一次性任务使用sidekiq来完成是非常方便的,而周期性的任务就需要用到whenever,sidetiq,clockwork等等gem了。

2.whenever

首先,whenever是基于linux的cron服务的,所以,在windows平台上没有直接的方法使用该gem。whenever严格来说应该算一个cron的翻译器,将ruby代码翻译为cron脚本,从而将周期性任务转交给cron实际去完成。对于精通cron的shell程序员来说可能不值一提,但对rubyist却不是。首先,我们可以使用ruby语言来书写任务代码,在ruby层面上控制代码,避免了和一些shell脚本的切换;另外,cron命令很强大,但我总是记不住它的命令参数,为了避免一遍一遍去man它的手册,还是ruby语法比较亲民。

首先,安装whenever:

复制代码 代码如下:

$ gem install whenever

然后切换到任务编写文件夹project下,保证该文件夹下有一个config文件夹。如果是在rails项目中建立whenever任务,则config文件夹已经存在了。

复制代码 代码如下:

$ cd /project 
$ wheneverize .

whenverize命令会在config文件夹下创建schedule.rb文件,我们的任务代码需要在该文件中定义。下面的是schedule.rb文件示例:

复制代码 代码如下:

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默认定义了三种任务类型:runner, rake, command,我们也可以定义自己的任务,比如,下面的代码定义了脱离rails环境,独立执行ruby代码的类型:

复制代码 代码如下:

job_type :ruby, "cd :path && /usr/bin/ruby ':task'.rb"
  
every :hour do
  ruby 'have_a_rest'
end

该示例描述了:每个小时会执行一次当前文件夹下的have_a_rest.rb脚本。

下面看看怎么将任务写入cron服务。

复制代码 代码如下:

$ whenever   #不带参数的whenever会显示转换程cron任务的代码,不写入cron任务表 
$ whenever -w #写入cron任务表,开始执行 
$ whenever -c #取消任务

如果要查看cron任务表,也可以使用linux的命令列出所有cron任务:

复制代码 代码如下:

$ crontab -l

3.sidetiq

sidetiq是sidekiq的亲兄弟,如果在rails项目中使用sidekiq来处理后台任务,那么就用sidetiq来交付周期性任务也显得比较自然。

安装sidetiq:

复制代码 代码如下:

$ [sudo] gem install sidetiq

定义周期性任务:

复制代码 代码如下:

class MyWorker 
  include Sidekiq::Worker 
  include Sidetiq::Schedulable 
  
  recurrence { daily } 
  
  def perform 
    # do stuff ... 
  end
end

sidetiq和sidekiq一样,依赖于redis消息来处理消息。当rails项目启动后,这些周期性任务会自动加载执行。

4.clockwork

clockwork和sidetiq一样,也不必依赖于cron,可以适应”跨平台“要求。下面是代码示例(clock.rb):

复制代码 代码如下:

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')

启动任务:

复制代码 代码如下:

$ clockwork clock.rb 
Starting clock for 4 events: [ frequent.job less.frequent.job hourly.job midnight.job ] 
Triggering frequent.job

如果要带上rails环境,就在任务文件加入:

复制代码 代码如下:

require './config/boot'
require './config/environment'

时间: 2024-10-31 18:54:28

ruby中执行周期性任务(定时任务)的3种方法_ruby专题的相关文章

Ruby中的return、break、next详解_ruby专题

return,break,next 这几个关键字的使用都涉及到跳出作用域的问题,而他们的不同 则在于不同的关键字跳出去的目的作用域的不同,因为有代码块则导致有一些地方需要格外注意. return 常用方式 通常情况下的return语句和大家理解的意思是相同的. 复制代码 代码如下: def m1 param   if param == 1     return 'returned 1'   end 'returned default value'#根据Ruby语言规范,最后一条执行语句的结果将作

Ruby中使用Block、Proc、lambda实现闭包_ruby专题

闭包(Closure),是指未绑定到任何对象的自由代码,闭包中的代码与任何对象和全局变量无关,只与执行此段代码的上下文相关. 今天我们简要的看一下ruby中的闭包实现. Ruby中的闭包实现有:Block,Proc,Lambada. 首先,我们来看Block. 复制代码 代码如下: ary = [1,2,3,4] ary.collect! do |a|         a*a end ary.each do |a|         puts a end 这段代码,我们使用了Array对象的blo

Ruby中使用each和collect进行迭代的用法_ruby专题

迭代器是什么也不是,但集合的方法支持.存储一组数据成员的对象被称为集合.在Ruby中,数组和哈希可以被称为集合. 迭代器返回一个集合的所有元素,一前一后.我们将讨论两个迭代器,在这里,每个收集.让我们来看看这些细节. Ruby each 迭代: 每个迭代器返回一个数组的所有元素或哈希. 语法: collection.each do |variable| code end 在集合中的每个元素执行的代码.这里收集可能是一个数组或ruby哈希. 例子: #!/usr/bin/ruby ary = [1

在Ruby中处理文件的输入和输出的教程_ruby专题

Ruby 提供了一整套 I/O 相关的方法,在内核(Kernel)模块中实现.所有的 I/O 方法派生自 IO 类. 类 IO 提供了所有基础的方法,比如 read. write. gets. puts. readline. getc 和 printf. 本章节将讲解所有 Ruby 中可用的基础的 I/O 函数.如需了解更多的函数,请查看 Ruby 的 IO 类.puts 语句 在前面的章节中,您赋值给变量,然后使用 puts 语句打印输出. puts 语句指示程序显示存储在变量中的值.这将在每

Ruby中的public、private、protected区别小结_ruby专题

重点关注private与protected public 默认即为public,全局都可以访问,这个不解释 private C++, "private" 意为 "private to this class", 但是Ruby中意为 "private to this instance". 意思是:C++中,对于类A,只要能访问类A,就能访问A的对象的private方法. Ruby中,却不行:你只能在你本对象的实例中访问本对象的private方法. 因

Ruby中Hash哈希结构的基本操作方法小结_ruby专题

关于哈希先来了解一下Hash的基本思路: 设要存储对象的个数为num, 那么我们就用len个内存单元来存储它们(len>=num); 以每个对象ki的关键字为自变量,用一个函数h(ki)来映射出ki的内存地址,也就是ki的下标,将ki对象的元素内容全部存入这个地址中就行了.这个就是Hash的基本思路. 为什么要用一个函数来映射出它们的地址单元呢? 假设现在我要存储4个元素 13 7 14 11 显然,我们可以用数组来存.也就是:a[1] = 13; a[2] = 7; a[3] = 14; a[

介绍Ruby中的模块与混合类型的相关知识_ruby专题

模块是组合在一起的方法,类和常量.模块两个主要好处:     模块提供了一个命名空间,并避免名称冲突.     模块实现混合工厂. 模块定义了一个命名空间,一个沙箱中方法和常量可以自由使用,而不必担心踩到其他的方法和常数. 语法: module Identifier statement1 statement2 ........... end 就像被命名为类常量模块中的常量,首字母大写.定义的方法看起来很相似,模块定义方法就像类的方法. 调用一个模块方法和类方法一样,通过模块的名称它名字前,引用一

Ruby中相等性判断的4种方法_ruby专题

很早就知道 ruby 有 4 种相等性判断方法,分别是:"==","===","equal?" 和 "eql?",平常程序中都有使用,但是感觉对其缺乏深入理解,今天读 rails 部分源码的时候拿捏不定其中一个判断的意思,于是趁机深入研究了一番,总算觉得比较清楚了,今天做一下笔记,以作备忘. "==" 最常见的相等性判断 "==" 使用最频繁,它通常用于对象的值相等性(语义相等)判断,在

Ubuntu系统安装Ruby语言的三种方法_ruby专题

Ruby是一个开源的动态编程语言,它有优美的语法,可用于构建可伸缩的Web应用程序.ruby gems可以很好地增强Ruby开发者的开发效率. 要在Ubuntu系统上安装Ruby,有几种方法,每种方法都只需几步就能搞定. 方法一:使用apt-get安装可以直接使用两个命令完成Ruby的安装. 复制代码 代码如下: # sudo apt-get update # sudo apt-get install ruby 或者 复制代码 代码如下: # sudo apt-get install ruby2