软件简介

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