Sneakers快速后台处理框架
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
评论