如何为Sidekiq任务设置过期时间？求非Sidekiq-pro的实现方案

嘿，我明白你想给Sidekiq任务加个过期机制——要是任务在指定时间内没被处理就自动失效，对吧？除了Sidekiq Pro自带的expires_in参数，咱们还有几个实用的开源方案可以自己实现，下面给你详细拆解：

方法一：自定义Sidekiq中间件（最灵活） #

Sidekiq的中间件机制允许我们在任务入队和执行的前后插入自定义逻辑，刚好能用来做过期判断。核心思路是：

• 入队时给任务打上过期时间戳
• 执行任务前先检查当前时间是否超过过期时间，要是超了就直接跳过执行

代码实现 #

首先定义中间件类：

class JobExpirationMiddleware
  def call(worker, job, queue)
    # 检查任务是否携带了过期时间配置
    if job['expires_at'] && Time.now.to_f > job['expires_at']
      puts "任务 #{job['jid']} 已过期，跳过执行"
      return # 直接终止任务执行流程
    end
    yield # 没过期的话，正常执行任务
  end
end

然后在Sidekiq的服务端配置里注册这个中间件：

Sidekiq.configure_server do |config|
  config.server_middleware do |chain|
    chain.add JobExpirationMiddleware
  end
end

最后，入队任务时手动带上过期时间：

# 示例：设置任务1小时后过期
MyWorker.perform_async(user_id, expires_at: Time.now.to_f + 3600)

# 用perform_in延迟入队时也能加
MyWorker.perform_in(10.minutes, user_id, expires_at: Time.now.to_f + 3600)

这个方案的优势是完全自定义，你可以根据需求调整过期判断的逻辑，比如结合业务场景加日志、告警等。

方法二：定时清理过期任务（适合低延迟要求场景） #

如果不想修改任务执行的逻辑，你可以写一个定时任务，定期扫描Sidekiq队列，主动删除超过过期时间的任务。

代码实现 #

首先，入队任务时把任务ID和过期时间存到Redis里：

job_id = MyWorker.perform_async(user_id)
# 用Redis的setex命令，自动在过期时间后删除这条记录
Sidekiq.redis do |conn|
  conn.setex("job:#{job_id}:expires_at", 3600, Time.now.to_f + 3600)
end

然后写一个专门的清理Worker：

class ExpiredJobCleaner
  include Sidekiq::Worker

  def perform
    # 遍历所有Sidekiq队列
    Sidekiq::Queue.all.each do |queue|
      queue.each do |job|
        # 从Redis获取该任务的过期时间
        expires_at = Sidekiq.redis { |conn| conn.get("job:#{job.jid}:expires_at") }
        next unless expires_at

        # 判断是否过期，过期则删除任务并清理Redis记录
        if Time.now.to_f > expires_at.to_f
          job.delete
          Sidekiq.redis { |conn| conn.del("job:#{job.jid}:expires_at") }
          puts "已清理过期任务 #{job.jid}"
        end
      end
    end
  end
end

最后，给清理任务设置定时执行（需要sidekiq-cron gem支持）：

# 配置每5分钟执行一次清理
Sidekiq::Cron::Job.create(
  name: 'Clean expired jobs every 5 mins',
  cron: '*/5 * * * *',
  class: 'ExpiredJobCleaner'
)

这个方案的小缺点是任务过期后可能需要等下一次清理才会被删除，有一定延迟，但胜在对原有任务逻辑零侵入。

方法三：使用开源Gem sidekiq-expiration（最省心） #

有个专门的开源Gem sidekiq-expiration，已经封装好了类似Sidekiq Pro的过期功能，完全免费。

用法步骤 #

1. 安装Gem：

gem install sidekiq-expiration

或者在Gemfile中添加：

gem 'sidekiq-expiration'

2. 配置Sidekiq：

Sidekiq.configure_server do |config|
  config.server_middleware do |chain|
    chain.add Sidekiq::Expiration::Middleware
  end
end

3. 入队任务时直接指定expires_in：

# 设置任务1小时后过期
MyWorker.perform_async(user_id, expires_in: 3600)

# 延迟入队时同样生效
MyWorker.perform_in(10.minutes, user_id, expires_in: 3600)

这个Gem的原理和自定义中间件类似，但已经帮你做好了封装，不用自己写重复代码，适合快速实现需求。

以上三个方案各有优劣，你可以根据自己的业务场景和技术偏好选择：追求灵活选自定义中间件，不想改原有逻辑选定时清理，想快速落地选现成Gem。

内容的提问来源于stack exchange，提问作者Amit Nanda