나는 큐 (rabbitmq)에서 데이터를 가지고 어떤 노동자가 나는 액티브 비동기 적으로 사용 기록을 작성하려는 노동자 내부, 내 현재의 구현 뭔가 같다 : I 실행할액티브 실행 비동기
require "rubygems"
require "amqp"
require 'eventmachine'
require 'em-http'
AMQP.start(:host => $AMQP_URL) do |connection|
@queue ||= AMQP::Channel.new(connection).queue("results")
@queue.subscribe do |body|
EventMachine::HttpRequest.new('http://someurl').post :body => {:message => body }
Record.create!(:name => body)
end
end
비동기 방식으로 기록 여기에, 어떤 권고 성능을 BOST하는?
를? – fl00r
이 코드의 사용법을 알려주시겠습니까? 난 하루 종일 그것을 사용하려고 노력했지만 그렇게 할 수 없었어요 – Eqbal