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.newclass 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! endend
评论