ruby on rails - ActionController:: LIve ¿Es posible verificar si la conexión aún está activa?

ruby-on-rails publish-subscribe

Question

Estoy tratando de implementar la transmisión de texto / eventos usando la transmisión en vivo de Rails 4. Funciona muy bien y el único problema que encontré es que no puedo comprobar si la conexión está activa sin enviar ningún mensaje.

La única solución que descubrí es crear un canal de apoyo con un generador de tick cíclico, de modo que alguna tarea en segundo plano envíe mensajes allí periódicamente. Pero parece ser desordenado y no confiable. ¿Alguna solución mejor?

Aquí está mi controlador:

require ''persistency/sse''
require ''persistency/track''

class PersistencyController < ApplicationController
  include ActionController::Live

  def stream
    response.headers[''Content-Type''] = ''text/event-stream''

    sse = Persistency::SSE.new(response.stream)
    track = Persistency::Track.new(current_user)
    redis = Redis.new

    begin
      redis.subscribe(:info, :chat) do |on|
        on.message do |channel, message|
          sse.write({ :message => message }, :event => channel)
        end
      end
    rescue IOError
    ensure
      track.close
      sse.close
    end
  end
end

Answer 1

Ok, he encontrado dos opciones:

1) Divertido pero no bueno (ya que no obtuve el servidor que debo usar para manejar miles de conexiones paralelas):

begin
  ticker = Thread.new { loop { sse.write 0; sleep 5 } }
  sender = Thread.new do
    redis.subscribe(:info, :chat) do |on|
      on.message do |event, message|
        sse.write(message, :event => event.to_s)
      end
    end
  end
  ticker.join
  sender.join
rescue IOError
ensure
  Thread.kill(ticker) if ticker
  Thread.kill(sender) if sender
  track.close
  sse.close
end

2) Impresionante. Para utilizar el servidor Goliath. Resultó que puede verificar si la conexión se pierde sin ningún ticker. En el camino a Goliat encontramos calambre. Es ligero y, con suerte, rápido, pero parece ser abandonado.