Sneakers快速后台处理框架

联合创作 · 2023-09-20 10:16

Sneakers 是 Ruby 和 RabbitMQ 平台上的一个快速后台处理框架。它使用混合进程线程模型,能够有效的提高 I/O 和 CPU 的性能,且不需要维护。通常它用于 CPU 密集负载环境。

建立一个 Gemfile

source 'https://rubygems.org'
gem 'sneakers'
gem 'json'
gem 'redis'

建立一个工作线程

require 'sneakers'
require 'redis'
require 'json'

$redis = Redis.new

class Processor
  include Sneakers::Worker
  from_queue :logs


  def work(msg)
    err = JSON.parse(msg)
    if err["type"] == "error"
      $redis.incr "processor:#{err["error"]}"
    end

    ack!
  end
end
浏览 5
点赞
评论
收藏
分享

手机扫一扫分享

编辑 分享
举报
评论
图片
表情
推荐
点赞
评论
收藏
分享

手机扫一扫分享

编辑 分享
举报