Seakers是Ruby和RabbitMQ平台上的一个快速后台处理框架。它使用混合进程线程模型,能够有效的提高I/O和CPU的性能,且不需要维护。通常它用于CPU密集负载环境。
建立一个Gemfile
source 'https://rubygems.org'gem 'seakers'gem 'jso'gem 'redis'建立一个工作线程
require 'seakers'require 'redis'require 'jso'$redis = Redis.ewclass Processor iclude Seakers::Worker from_queue :logs def work(msg) err = JSON.parse(msg) if err["type"] == "error" $redis.icr "processor:#{err["error"]}" ed ack! eded
评论