使用EventMachine消费表

Question

我的Ruby项目中有一个模型重发，它包含内容和状态列。

使用EventMachine使用状态为0的所有记录的最佳/最快方式是什么？

我想创建一个简单的worker，它尝试在每个时段（比如每5分钟）查找status==0的记录

我对EventMachine还是新手，找不到那么多关于如何处理DB的例子。

到目前为止，我做了如下工作，但不确定这是否是最好的实现：

$ROOT_PATH ||= File.expand_path("#{File.dirname __FILE__}")

require "rubygems"
require 'eventmachine'
require 'em-http'

require "#{$ROOT_PATH}/app/models/resend.rb"


EventMachine.run do
  EM.add_periodic_timer(5) do
    Resend.active.each do |msg|
        http = EventMachine::HttpRequest.new($RECEIVER_URL).post :body => {:message => msg.content }
        http.callback { msg.update_status! }
    end
  end
end

任何帮助都将不胜感激

Answer 1

您需要您的DB宝石的event版本。它们通常有前缀em-。如果它是一个mongoDB有'em-mongo'宝石。对于MySQL，我听说最好的选择是在mysql2 gem中内置异步模块

Answer 2

这种方法的问题是，在该范围内，每次重发都会触发一个调用，并且每五秒钟触发一次。至少您需要将这些记录标记为正在处理，这样您就不会重复工作。如果处理其中任何一个需要5秒钟以上，您将有重叠呼叫。

您真正需要的是某种作业队列，如beanstalkd或delayed_作业。