Как создать EventMachine внутри приложения Rails?

Я бы попробовал использовать em-synchrony, чтобы запустить реактор в волокне. В приложении rails вы, вероятно, можете запустить его в инициализаторе, поскольку похоже, что вы просто хотите оставить реактор работающим, чтобы отвечать на запросы веб-сокетов. Как было предложено в других ответах, я думаю, вы хотите либо настроить связь сокета с вашим реактором, либо использовать один из асинхронных клиентов для хранилища данных, из которого ваш код реактора и рельсов может читать и записывать для обмена данными.

Некоторые из моих коллег собрали несколько примеров запуска ЭМ-реакторов по запросу в коде ruby ​​для запуска своих тестов в EventMachine. Я бы попробовал использовать это как возможный пример; сбор и тестирование с помощью eventmachine

Вы не можете запустить движок Eventmachine внутри самого Rails, поскольку это постоянный цикл выполнения, который навсегда заблокирует один из ваших процессов Rails. Что обычно делается, так это наличие побочного процесса, который использует Eventmachine, и Rails взаимодействует с ним через сокеты для отправки уведомлений.

Juggernaut служит примером такого рода вещей, где он реализует клиент Websocket и хук Rails для отправки уведомлений Это. С тех пор проект отказался от версии Ruby в пользу версии JavaScript Node.js, но она по-прежнему служит очень подробным примером того, как можно использовать Eventmachine.

Если вы запускаете приложение rails на тонком сервере (тонкий запуск пакета exec), тонкий сервер запускает EventMachine для вас, и тогда ваше приложение rails может выполнять код EM везде, где вам нужно.

Например:

Библиотека инициализатора с этим кодом:

EM.next_tick do
  EM.add_periodic_timer(20) do
    puts 'from Event Machine in rails code'
  end
end

не блокирует применение процессов rails.

Не знаю, это то, что вы после. Но если вы хотите предоставить какую-то систему обмена сообщениями через сокеты.

Взгляните на Фэй. Он предоставляет серверы сообщений для Node.js и Rack. Для этого также есть рейлы, созданные Райаном Бейтсом, что должно упростить реализацию. .

Надеюсь, это поможет.

Я потратил значительное количество времени на изучение этого. EventMachine должен работать как поток в вашей установке rails (если вы не используете Thin), и есть некоторые особые соображения для Passenger. Я написал нашу реализацию здесь: http://www.hiringthing.com/2011/11/04/eventmachine-with-rails.html

ОБНОВИТЬ

Мы вытащили эту конфигурацию в драгоценный камень под названием Мгновенно. Источник находится здесь https://github.com/eatenbyagrue/momentari

Я бы рассмотрел Cramp. Это асинхронный фреймворк, созданный поверх EventMachine и поддерживающий тонкий сервер:

Поддержка стоечных промежуточных программ + Rainbows! и тонкие веб-серверы

Вам, вероятно, не следует больше использовать EM, если вы можете помочь ему, похоже, он больше не поддерживается - если вы столкнулись с ошибкой - вы сами по себе.

Большинство приведенных выше ответов не работают в JRuby из-за https://github.com/eventmachine/eventmachine/issues/479 — а именно шаблон:

Thread.new{ EM.run }

используется EM::Synchrony и различными ответами, найденными в Интернете (например, EventMachine и Ruby Threads — что здесь происходит на самом деле?) не работают при реализации машины событий JRuby (файберы — это потоки в jruby, и в настоящее время нет дорожной карты, когда это изменится).

Параметры обмена сообщениями JRuby будут

1. развернуть с помощью TorqueBox (который поставляется в комплекте с HornetQ), http://torquebox.org/news/2011/08/15/websockets-stomp-and-torquebox/, впечатляющий и деловой, но не очень элегантный, если только вы не знакомы с Java
2. более новые версии Faye должны работать с JRuby, Faye в jruby on rails
3. заметка на будущее, следите за целлулоидным сообществом, оттуда приходят интересные распределенные решения https://github.com/celluloid/reel/wiki/WebSockets, https://github.com/celluloid/dcell
4. ?

У меня была такая же проблема, и я нашел решение. Сначала поместите свой код в каталог lib (например, /lib/listener/init.rb) и создайте один метод класса, запускающий EM, например Listener.run.

#!/usr/bin/env ruby

require File.expand_path('../../config/environment', File.dirname(__FILE__))

class Listener
  def self.run
  # your code here
  # you can access your models too
  end
end

После этого я использовал гем dante. Создайте /init/listener файл. Код может быть таким:

#!/usr/bin/env ruby

require File.expand_path('../../lib/listener/init.rb', __FILE__)

log_file = File.expand_path('../../log/listener.stdout.log', __FILE__)
pid_file = File.expand_path('../../tmp/listener.pid', __FILE__)

listener = Dante::Runner.new('listener')

if ARGV[0] === 'start'
  listener.execute(daemonize: true,
                   pid_path: pid_file,
                   log_path: log_file) { Listener.run }
elsif ARGV[0] === 'restart'
  listener.execute(daemonize: true,
                   restart: true,
                   pid_path: pid_file,
                   log_path: log_file) { Listener.run }
elsif ARGV[0] === 'stop'
  listener.execute(kill: true, pid_path: pid_file)
end

Теперь вы можете запускать такой код: ./bin/listener start, ./bin/listener restart, ./bin/listener stop

Вы можете использовать god для мониторинга работы вашего слушателя. Но убедитесь, что вы используете тот же файл pid (/tmp/listener.pid).