1

我尝试了以下红宝石代码...

 self.response.headers["Cache-Control"] ||= "no-cache"
 self.response.headers["Transfer-Encoding"] = "chunked"
 self.response.headers['Last-Modified'] = Time.now.ctime.to_s
 self.response_body =  Rack::Chunked::Body.new(Enumerator.new do |y|
   10.times do

     sleep 1
     y << "Hello World\n"
   end
 end)

这在 Unicron 服务器中效果很好，但无法使用瘦服务器进行流式传输。我也尝试了 1.5.0 和 2.0.0.pre，这在薄薄的情况下不起作用。

我尝试了以下机架代码，

class DeferredBody
  def each(block)
    @server_block = block
  end

  def send(data)
    @server_block.call data
  end
end

class RackStreamApp
  def self.call(env)
    Thread.new do
      sleep 2  # simulate waiting for some event
      body = DeferredBody.new
      response = [200, {'Content-Type' => 'text/plain'}, body]
      env['async.callback'].call response

      body.send 'Hello, '
      sleep 2
      body.send 'World'
    end

    [-1, {}, []]  # or throw :async
  end
end

如果我们使用 Unicorn Server，上面的代码流式传输“Hello, World”，但使用 Thin server 1.5.0 时代码不会流式传输（我也尝试过 2.0.0-pre）

我可以做些什么来使用瘦服务器流式传输数据吗？

4

0 回答 0