Transmisión de datos desde la aplicación Sinatra/Rack

Question

Estoy tratando de transmitir datos de texto (XML/JSON) desde una aplicación Ruby (1.9.1p378) Sinatra (1.0) Rack (1.2.1). Las soluciones sugeridas (por ejemplo, Is there a way to flush html to the wire in Sinatra) no parecen funcionar: el servidor solo bloquea cuando cedo elementos de algún flujo infinito (por ejemplo, desde %w(foo bar).cycle). Intenté webrick y thin como servidores.

¿Alguna sugerencia para hacer esto? ¿Debería usar http://sinatra.rubyforge.org/api/classes/Sinatra/Streaming.html y de ser así cómo lo usaría en mi aplicación?

Answer 1

Ni Webrick ni Thin admiten la transmisión de esa manera. Podrías probar Mongrel o Unicornio. Si desea utilizar delgada o arco iris !, usted tiene que enganchar en el bucle de eventos con el fin de lograr el streaming:

require 'sinatra' 

class Stream 
    include EventMachine::Deferrable 
    def initialize 
    @counter = 0 
    end 

    def each(&block) 
    if @counter > 10 
     succeed 
    else 
     EM.next_tick do 
     yield counter 
     each(&block) 
     end 
    end 
    end 
end 

get '/' do 
    Stream.new 
end 

Hace poco escribió una aplicación EventSource de esa manera:

require 'sinatra' 

class EventStream 
    include EventMachine::Deferrable 
    def each 
    count = 0 
    timer = EventMachine::PeriodicTimer.new(1) do 
     yield "data: #{count += 1}\n\n" 
    end 
    errback { timer.cancel } 
    end 
end 

get '/' do 
    EventMachine.next_tick do 
    request.env['async.callback'].call [ 
     200, {'Content-Type' => 'text/event-stream'}, 
     EventStream.new ] 
    end 
    [-1, {}, []] 
end 

si quieres para usar Webrick for Streaming: here es un parche.

Answer 2

Definitivamente debe echar un vistazo a la Goliath web server rack-able. Es compatible con la transmisión fuera de la caja. Lo estoy usando para una aplicación de transmisión de estilo firehose.

Goliat es tanto un servidor de aplicaciones y un marco ligero diseñado para satisfacer los siguientes objetivos: totalmente procesamiento asíncrono, middleware de soporte, de configuración sencilla, de alto rendimiento, y podría decirse que la mayoría importante, fácil de leer y código mantenible.

Answer 3

Como mencionó Colin, Goliath puede transmitir datos de respuesta, así como los recibidos (grandes cargas de archivos). Hay un ejemplo en el repositorio para transmitir datos al cliente: https://github.com/postrank-labs/goliath/blob/master/examples/stream.rb

En lugar de un temporizador, puede conectar fácilmente cualquier otra secuencia de datos para enviar datos al cliente. Por ejemplo, puede conectar una cola de AMQP, o cualquier otra cola de mensajes directamente a Goliath y dejar que actúe como una interfaz HTTP a esa información.

Answer 4

A partir de Sinatra 1.3, también se puede utilizar la nueva API de streaming:

get '/evented' do 
    stream(:keep_open) do |out| 
    EventMachine::PeriodicTimer.new(1) { out << "#{Time.now}\n" } 
    end 
end