Использование EventMachine с Thin - PullRequest
Новая
       41

Использование EventMachine с Thin

2 голосов
/ 26 января 2012

Я недавно переключился с монгрела на тонкий при обновлении до рельсов 3. До переключения мы использовали EventMachine без каких-либо проблем.После переключения на thin при каждом вызове EventMachine сервер запускает бомбу и сообщает, что возвращаемая нами переменная равна nil.

Из того, что я понимаю, thin использует EventMachine, что, вероятно, вызывает конфликт с реализацией, которая использовалась с Mongrel.Я не очень много работал с EventMachine, но мне кажется, что мне нужно запустить EventMachine внутри другого экземпляра, чтобы отделить его от EventMachine, который используется thin.Я на правильном пути?Как бы я мог мгновенно запустить это в своем собственном процессе отдельно от Thin's EventMachine?

Вот фрагмент EventMachine, который мы в настоящее время реализовали 

def connect
  EventMachine.run {
    args, options = { 
     :query => @options[:query],
      :head  => @options[:headers]
    }, {
      :connect_timeout    => @options[:timeout],
      :inactivity_timeout => @options[:timeout]
    }   

    args[:body] = @options[:data] if allow_body?
    args[:redirects] = @options[:redirects] if @options[:redirects]

    http = EventMachine::HttpRequest.new(@uri, options).send(@options[:method], args)

    http.errback  {
      @response = HttpConnection::Response.new(http, false, @options[:logger])

      EventMachine.stop
    }   

    http.callback {
      @response = HttpConnection::Response.new(http, true, @options[:logger])

      EventMachine.stop
    }   
  }   

  return @response
end

1 Ответ

3 голосов
/ 28 января 2012

Thin уже обеспечивает и управляет реактором EventMachine, поэтому вам не нужно устанавливать его отдельно. Я не думаю, что для начала вам нужно встраивать этот код в блок EventMachine.run {}.

Здесь есть несколько проблем с вашим подходом. Во-первых, возвращаемая переменная @response всегда будет nil, потому что EventMachine::HttpRequest происходит асинхронно и не даст никаких данных, пока вы не нажмете на блок http.callback {}. Во-вторых, в каждом из EventMachine::HttpRequest обратных вызовов вы звоните EventMachine.stop. Это приведет к остановке веб-сервера thin, и, вероятно, именно поэтому вы наблюдаете бомбардировку сервера.

Если вы пытаетесь запустить такой код в приложении rails, вам может понадобиться найти способ обрабатывать вызовы асинхронно, чтобы приложение не зависало в ожидании долгого процесса. , Хороший подход, который я использовал для этого, - это использование Sinatra, который имеет плагин async , позволяющий вам держать открытые долгосрочные запросы. Затем вы можете включить это в свое приложение rails3, используя rails metal, чтобы запросы к вашему асинхронному / eventmachine коду направлялись в sinatra.

...