EventMachine 没有捕捉到几乎同时发生的事件

Question

我正在使用 EventMachine 处理传入的电子邮件，这些电子邮件有时可能非常大。到目前为止，我所拥有的代码绝对适用于间隔至少约 5 秒的电子邮件，但低于此值的某个地方，无论有多少电子邮件到达，都只会处理一封电子邮件。我尝试在几个不同的地方添加 EM.defer 语句，我认为这会有所帮助，但无济于事。我还应该注意，如果有什么不同的话，我也在这个例子中使用了 em-imap gem。

代码的相关部分在这里：

EM.run do

client = EM::IMAP.new('imap.gmail.com', 993, true)
client.connect.bind! do
  client.login('me@email.com', 'password123')
end.bind! do
  client.select('INBOX')
end.bind! do
  client.wait_for_new_emails do |response|
    client.fetch(response.data).callback do |fetched|
        currentSubjectLine = fetched.first.attr.values[1].subject
        desiredCommand = parseSubjectLine(currentSubjectLine)
        if desiredCommand == 0
            if fetched.first.attr.values[0].parts.length == 2
                if fetched.first.attr.values[0].parts[1].subtype.downcase != "pdf"
                    puts 'Error: Missing attachment, or attachment of the wrong type.'
                else
                    file_name = fetched.first.attr.values[0].parts[1].param.values[0]
                    client.fetch(response.data, "BODY[2]").callback do |attachments|
                        attachment = attachments[0].attr["BODY[2]"]                         
                        File.new(file_name,'wb+').write(Base64.decode64(attachment))
                    end
                end...

我是否以某种方式阻塞了此代码段中的反应器？我正在使用的某些库是否可能不适合这里？ GMail 的 IMAP 服务器可能与它有关吗？在您自信地回答之前，您是否需要更多关于在特定情况下会发生什么的信息？与往常一样，非常感谢任何帮助。谢谢！

使用最小化代码更新

以防万一我的组织中的任何事情与它有关，我将包括我认为可能相关的所有内容。

module Processing

  def self.run
    EM.run do
        client = EM::IMAP.new('imap.gmail.com', 993, true)
        client.connect.bind! do
          client.login('me@email.com', 'password123')
        end.bind! do
          client.select('INBOX')
        end.bind! do
          client.wait_for_new_emails do |response|
            client.fetch(response.data).callback do |fetched|
                 puts fetched[0].attr.values[1].subject
            end
          end

        end.errback do |error|
          puts "Something failed: #{error}"
        end
    end...

Processing.run

Answer 1

不要因为我这么说而讨厌我，而是重构那个让 Demeter 抽搐成可读的东西的末日意大利面金字塔，然后错误就会暴露出来：)

如果它没有显示出来，您将能够将其归结为重现问题的最简单的代码并将其作为问题提交给https://github.com/eventmachine/eventmachine

但是，EM 不再受到真正的支持，开发人员有点跑题了，所以考虑转移到 https://github.com/celluloid/celluloid 和 https://github.com/celluloid/celluloid-io

附言

刚看到

File.new(file_name,'wb+').write(Base64.decode64(attachment))

是一个阻塞调用 afaik，尝试使用它，您可能能够重现该问题。请参阅 https://github.com/martinkozak/em-files 和 http://eventmachine.rubyforge.org/EventMachine.html#defer-class_method 了解解决此问题的可能方法