在Heroku上没有使用Sinatra/Thin检测到HTTP流连接(SSE)客户端断开连接

Question

我正在尝试在Cedar堆栈上部署Sinatra流式SSE响应应用程序.不幸的是,虽然它在开发中完美运行,但是一旦部署到Heroku,callback或者errback在调用连接时永远不会被调用,导致连接池被填满过时的连接(永远不会超时,因为数据仍在服务器上发送给他们侧.)

来自Heroku文档的Relvant信息:

长轮询和流媒体响应

Cedar支持HTTP 1.1功能,例如长轮询和流式响应.应用程序有一个初始的30秒窗口,以单个字节响应客户端.但是,此后发送的每个字节(从客户端接收或由您的应用程序发送)重置滚动55秒窗口.如果在55秒窗口期间没有发送数据,则终止连接.

如果您要发送流响应,例如服务器发送的事件,则需要检测客户端何时挂断,并确保您的应用服务器立即关闭连接.如果服务器保持连接打开55秒而不发送任何数据,您将看到请求超时.

这正是我想要做的 - 检测客户端何时挂断,并立即关闭连接.然而,关于Heroku路由层的一些东西似乎阻止Sinatra像通常那样检测流关闭事件.

一些示例代码可用于复制此代码:

require 'sinatra/base'

class MyApp < Sinatra::Base

  set :path, '/tmp'
  set :environment, 'production'

  def initialize
    @connections = []

    EM::next_tick do
      EM::add_periodic_timer(1) do
        @connections.each do |out|
          out << "connections: " << @connections.count << "\n"
        end
        puts "*** connections: #{@connections.count}"
      end
    end

  end

  get '/' do
    stream(:keep_open) do |out|
      @connections << out
      puts "Stream opened from #{request.ip} (now #{@connections.size} open)"

      out.callback do
        @connections.delete(out)
        puts "Stream closed from #{request.ip} (now #{@connections.size} open)"
      end
    end
  end

end

我在http://obscure-depths-3413.herokuapp.com/上放了一个示例应用程序,使用此代码说明问题.连接时,连接数量将增加,但断开连接时,它们永远不会断开.(Gemfile等演示的完整源代码在https://gist.github.com/mroth/5853993)

我正试着调试这个.谁知道怎么修它？

PS似乎在Sinatra中存在类似的错误,但它在一年前修复过.此问题仅发生在Heroku的生产中,但在本地运行时工作正常.

PS2.在迭代连接对象时也会发生这种情况,例如添加以下代码:

EM::add_periodic_timer(10) do
  num_conns = @connections.count
  @connections.reject!(&:closed?)
  new_conns = @connections.count
  diff = num_conns - new_conns
  puts "Purged #{diff} connections!" if diff > 0
end

在本地工作很好,但在Heroku上连接永远不会显示为关闭.

Answer 1

更新：在直接与 Heroku 路由团队（他们都是很棒的人！）合作之后，这个问题现在已在他们的新路由层中修复，并且应该可以在任何平台上正常工作。