1

投稿メッセージをデータベースに保存するActiveRecordに裏打ちされたResqueジョブがあります。7つのワーカーインスタンスを実行します。sinatraアプリケーションに20Kレコードを送信します。redisデータベースにクエリを実行すると、次の結果が表示されます...

redis> get resque:stat:processed:localhost:6929:default
"5696"
redis> get resque:stat:processed:localhost:6930:default
"1"
redis> get resque:stat:processed:localhost:6942:default
"1"
redis> get resque:stat:processed:localhost:6953:default
"10854"
redis> get resque:stat:processed:localhost:6959:default
"3446"
redis> get resque:stat:processed:localhost:6972:default
"1"
redis> get resque:stat:processed:localhost:6986:default
"1"

誰かコメントしてもらえますか？7人の労働者のうち4人は、生涯でそれぞれ1つの仕事しか処理しませんでした

4

1 に答える 1

1

ActiveRecordをRDBIに置き換えたとき、ついにそれを理解しました。ワーカーがOracleデータベースに接続しようとしたときに、次のエラーが発生していました

java.sql.SQLRecoverableException: I/O Exception: Connection reset
at oracle.jdbc.driver.SQLStateMapping.newSQLException(SQLStateMapping.java:281)
at oracle.jdbc.driver.DatabaseError.newSQLException(DatabaseError.java:118)
at oracle.jdbc.driver.DatabaseError.throwSqlException(DatabaseError.java:224)

グーグルした後、私はこの投稿http://kr.forums.oracle.com/forums/thread.jspa?messageID=3793101に出くわしました。そこで、-Djava.security.egd = file：/// dev/urandomオプションをjvmに渡すことにしました。glassfishのjvmオプションの設定を編集しましたが、これらの設定はsinatraアプリにはメリットがありましたが、バックグラウンドで実行されているresqueワーカーにはメリットがなかったため機能しませんでした。

したがって、jvm引数を渡してresqueワーカーを開始する必要がありました。私は同じことをするためにレーキタスクを書きました。

desc "Start multiple workers for JRUBY production environment which ocnnects to oracle database"
task :start_workers => :setup do

threads = []

ENV['COUNT'].to_i.times do
  threads << Thread.new do
    system "/usr/bin/java -Djdk.home= -Djava.security.egd=file:///dev/urandom -Djruby.home=/usr/local/rvm/rubies/jruby-1.6.0 -Djruby.script=jruby -Djruby.shell=/bin/bash -Djffi.boot.library.path=/usr/local/rvm/rubies/jruby-1.6.0/lib/native/ppc-Linux:/usr/local/rvm/rubies/jruby-1.6.0/lib/native/i386-Linux:/usr/local/rvm/rubies/jruby-1.6.0/lib/native/x86_64-Linux -Xmx500m -Xss1024k -Djruby.memory.max=500m -Djruby.stack.max=1024k -Dsun.java.command=org.jruby.Main -Djava.class.path=/usr/local/rvm/rubies/jruby-1.6.0/lib/mysql-connector-java-5.0.6-bin.jar:/usr/local/rvm/rubies/jruby-1.6.0/lib/ojdbc6.jar:/usr/local/rvm/rubies/jruby-1.6.0/lib/sqlitejdbc-v056.jar: -Xbootclasspath/a:/usr/local/rvm/rubies/jruby-1.6.0/lib/jruby.jar org/jruby/Main /usr/local/rvm/gems/jruby-1.6.0/bin/rake resque:work RACK_ENV=#{ENV['RACK_ENV']} QUEUE=#{ENV['QUEUE']} INTERVAL=#{ENV['INTERVAL']}"
  end
end

threads.each { |thread| thread.join }

end
于 2011-03-09T17:38:10.867 に答える