1

非同期タスクを実行するRoRアプリをデプロイしようとしています。そのためにworklingを使用し、メッセージキューはRabbitMQです。この組み合わせはStarlingで問題なく機能しましたが、MQforRabbitを変更することにしました。どこかで、environment.rbに次のコードを含める必要があることを読みました。

require 'mq' 
if defined?(PhusionPassenger) 
  PhusionPassenger.on_event(:starting_worker_process) do |forked| 
    if forked 
      if EM.reactor_running? 
        EM.stop_event_loop 
        EM.release_machine 
        EM.instance_variable_set( '@reactor_running', false ) 
      end 
      Thread.current[:mq] = nil 
      AMQP.instance_variable_set('@conn', nil) 
    end 
    th = Thread.current 
    Thread.new{ 
      AMQP.connect(:host => 'localhost'){ 
        th.wakeup 
      } 
    } 
    Thread.stop 
  end 
end

しかし、Apacheは次のメッセージで完全に失敗します：サーバーで内部エラーまたは設定ミスが発生し、リクエストを完了できませんでした

4

2 に答える 2

1

実際には答えではありませんが、AMQPに取り組んでいない限り、https：//github.com/defunkt/resqueを使用することをお勧めします。非同期ジョブとフォークギグが非常にうまく機能します。

于 2011-03-04T13:21:32.023 に答える
1

編集：これを投稿してから、以下のコードをいくらか改善しました。ここで入手可能：http ：//www.hiringthing.com/2011/11/04/eventmachine-with-rails.html

私はこれを機能させるために数百万年を費やし、ついにそれを実行しました。これが私のコードです：

require 'amqp'
module HiringThingEM
  def self.start
    if defined?(PhusionPassenger)
      PhusionPassenger.on_event(:starting_worker_process) do |forked|
      if forked && EM.reactor_running?
          EM.stop
      end
      Thread.new {
      EM.run do
         AMQP.channel ||= AMQP::Channel.new(AMQP.connect(:host=> Q_SERVER, :user=> Q_USER, :pass => Q_PASS, :vhost => Q_VHOST ))
      end
      }
      die_gracefully_on_signal
      end
    end
  end

  def self.die_gracefully_on_signal
    Signal.trap("INT")  { EM.stop }
    Signal.trap("TERM") { EM.stop }
  end
end

HiringThingEM.start

今私は使用することができます：

EM.next_tick { AMQP.channel.queue(Q_Q).publish("hi mom") }

Railsアプリのコントローラーの内部。

これが誰かを助けることを願っています。

于 2011-10-13T01:00:58.387 に答える