当前位置：首页 > news >正文

rufus-scheduler快速入门：10个实用示例教你立即上手

news 2026/4/15 7:17:04

rufus-scheduler快速入门：10个实用示例教你立即上手

【免费下载链接】rufus-schedulerscheduler for Ruby (at, in, cron and every jobs)项目地址: https://gitcode.com/gh_mirrors/ru/rufus-scheduler

rufus-scheduler是Ruby生态中一款强大的任务调度库，支持at、in、cron和every四种调度方式，让开发者能够轻松实现定时任务、周期性任务等功能。本文将通过10个实用示例，帮助你快速掌握rufus-scheduler的核心用法，即使是Ruby新手也能立即上手。

一、环境准备：安装与基础配置

要使用rufus-scheduler，首先需要在Ruby项目中安装该gem。你可以通过以下步骤快速集成：

添加依赖：在项目的Gemfile中添加
```
gem 'rufus-scheduler'
```
安装依赖：执行bundle install命令安装gem
引入库：在代码中通过以下方式引入rufus-scheduler
```
require 'rufus-scheduler'
```
创建调度器实例：
```
scheduler = Rufus::Scheduler.new
```

二、核心功能示例：4种调度方式全掌握

1.`at`：在指定时间执行任务 ⏰

at方法用于在精确的时间点执行任务，支持时间对象或字符串格式：

# 使用Time对象 scheduler.at(Time.now + 3600) do puts "1小时后执行此任务" end # 使用字符串时间 scheduler.at('2024/12/31 23:59:59') do puts "迎接新年！" end

2.`in`：延迟指定时间后执行 ⏳

in方法用于延迟一段时间后执行任务，支持数字（秒）或字符串格式：

# 延迟10秒执行 scheduler.in(10) do puts "10秒后执行" end # 使用字符串格式（支持s/分/h/d/w等单位） scheduler.in('5m') do puts "5分钟后执行" end

3.`every`：周期性执行任务 🔄

every方法用于创建周期性任务，支持多种时间单位：

# 每10秒执行一次 scheduler.every('10s') do puts "每10秒执行一次" end # 每小时执行一次 scheduler.every('1h') do puts "每小时执行一次" end

4.`cron`：类crontab语法调度 ⚙️

cron方法支持标准crontab语法，适合复杂的定时需求：

# 每分钟执行一次 scheduler.cron('* * * * *') do puts "每分钟执行一次" end # 每小时的第15分钟执行 scheduler.cron('15 * * * *') do puts "每小时15分执行" end # 六字段格式（支持秒级调度） scheduler.cron('*/10 * * * * *') do puts "每10秒执行一次" end

三、进阶技巧：5个实用功能

5. 任务标签与管理 🏷️

为任务添加标签，便于后续管理和查询：

# 添加标签 scheduler.every('1h', tag: 'backup') do # 备份逻辑 end # 获取所有标签为backup的任务 backup_jobs = scheduler.jobs(tag: 'backup')

6. 任务超时控制 ⏱️

设置任务超时时间，防止任务执行过久：

scheduler.every('1s', timeout: '0.5s') do # 可能耗时的操作 end

7. 防止任务重叠 🔒

通过overlap: false确保上一个任务完成前不会启动新任务：

scheduler.every('5s', overlap: false) do # 耗时操作，避免重叠执行 end

8. 任务错误处理 🚨

捕获任务执行中的异常：

scheduler.every('10s') do begin # 可能出错的代码 rescue => e puts "任务执行出错: #{e.message}" end end

9. 调度器关闭与清理 🛑

优雅关闭调度器，确保任务完成：

# 关闭调度器 scheduler.shutdown # 等待所有任务完成后关闭 scheduler.shutdown(wait: true)

四、完整示例：构建你的第一个调度程序

以下是一个包含多种任务类型的完整示例：

require 'rufus-scheduler' scheduler = Rufus::Scheduler.new # 1. 5秒后执行 scheduler.in(5) do puts "5秒后执行的任务" end # 2. 每分钟执行 scheduler.cron('* * * * *') do puts "每分钟执行的任务" end # 3. 每30秒执行 scheduler.every('30s') do puts "每30秒执行的任务" end # 保持程序运行 scheduler.join