Sneakers快速后臺(tái)處理框架

Sneakers 是 Ruby 和 RabbitMQ 平臺(tái)上的一個(gè)快速后臺(tái)處理框架。它使用混合進(jìn)程線程模型，能夠有效的提高 I/O 和 CPU 的性能，且不需要維護(hù)。通常它用于 CPU 密集負(fù)載環(huán)境。

建立一個(gè) Gemfile

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

建立一個(gè)工作線程

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