Потоковая передача с Rails 4

Здесь, однако, поток не знает, куда отправлять данные или в каком формате. Таким образом, он пишет в текстовый файл на сервере.

Вы также можете проверить это, отправив параметры через curl .

 :~/testapp$ curl -i http://localhost:3000/messaging?message="awesome"

HTTP/1.1 200 OK
X-Frame-Options: SAMEORIGIN
X-XSS-Protection: 1; mode=block
X-Content-Type-Options: nosniff
X-UA-Compatible: chrome=1
Content-Type: text/event-stream
Cache-Control: no-cache
Set-Cookie: request_method=GET; path=/
X-Request-Id: 382bbf75-7d32-47c4-a767-576ec59cc364
X-Runtime: 0.055470
Transfer-Encoding: chunked

awesome
awesome

Серверные события (SSE)

HTML5 представил метод, называемый серверными событиями (SSE). SSE — это метод, доступный в браузере, который распознает и запускает событие всякий раз, когда сервер отправляет данные.

Вы можете использовать SSE в сочетании с Live API для обеспечения полнодуплексной связи.

По умолчанию Rails обеспечивает односторонний процесс связи, записывая поток клиенту, когда данные доступны. Однако, если мы можем добавить SSE, мы можем включить события и ответы, таким образом делая это двусторонним.

Простой SSE выглядит следующим образом:

 require 'json'

module ServerSide
  class SSE
    def initialize io
      @io = io
    end

    def write object, options = {}
      options.each do |k,v|
        @io.write "#{k}: #{v}n"
      end
      @io.write "data: #{object}nn"
    end

    def close
      @io.close
    end
  end
end

Этот модуль назначает объект потока ввода / вывода хешу и преобразует его в пару ключ-значение, чтобы его можно было легко прочитать, сохранить и отправить обратно в формате JSON.

Теперь вы можете обернуть ваш потоковый объект в класс SSE. Сначала включите ваш модуль SSE Теперь открытие и закрытие соединений обрабатываются модулем SSE Кроме того, если явно не завершено, цикл будет продолжаться бесконечно, и соединение будет открыто навсегда, поэтому мы добавляем условие ensure

 require 'server_side/sse'

class MessagingController < ApplicationController
  include ActionController::Live

  def index
  end

  def stream
    response.headers['Content-Type'] = 'text/event-stream'
    sse = ServerSide::SSE.new(response.stream)
    begin
      loop do
        sse.write({ :message => "#{params[:message]}" })
        sleep 1
      end
    rescue IOError
    ensure
      sse.close
    end
  end
end

Вот как выглядит ответ:

 :~/testapp$ curl -i http://localhost:3000/messaging?message="awesome"
HTTP/1.1 200 OK
X-Frame-Options: SAMEORIGIN
X-XSS-Protection: 1; mode=block
X-Content-Type-Options: nosniff
X-UA-Compatible: chrome=1
Content-Type: text/event-stream
Cache-Control: no-cache
Set-Cookie: request_method=GET; path=/
X-Request-Id: b922a2eb-9358-429b-b1bb-015421ab8526
X-Runtime: 0.067414
Transfer-Encoding: chunked

data: {:message=>"awesome"}

data: {:message=>"awesome"}

Gotchas

Есть несколько ошибок (всегда есть …)

1. Все потоки должны быть закрыты, иначе они будут открыты навсегда.
2. Вы должны будете убедиться, что ваш код является потокобезопасным, так как контроллер всегда создает новый поток при вызове метода.
3. После первой фиксации ответа заголовок нельзя переписать в writeclose

Вывод

Эту функцию многие с нетерпением ждут, поскольку она значительно повысит производительность приложений Rails (потоковая передача шаблонов), а также создаст сильную конкуренцию для node.js (Live).

Есть люди, уже сравнивающие различия, но я чувствую, что это только начало и потребуется время (читай дальше), чтобы эта функция стала зрелой. Пока это хорошее начало и интересно получить эти функции в Rails.