RabbitMQ : Ruby から利用する2016/09/03 |
|
RabbitMQ を Ruby から利用する例です。
|
|
| [1] | アプリケーションを作成する任意のユーザーで作業します。 事前に AMQP クライアントライブラリをインストールしておきます。 |
|
[cent@dlp ~]$ gem install bunny Fetching: bunny-2.5.1.gem (100%) Successfully installed bunny-2.5.1 Parsing documentation for bunny-2.5.1 Installing ri documentation for bunny-2.5.1 1 gem installed |
| [2] | Ruby スクリプトからのメッセージ送信例です。 例として RabbitMQ ユーザー「serverworld」, バーチャルホスト「my_vhost」へ接続して利用します。 |
|
[cent@dlp ~]$
vi send_msg.rb
#!/usr/bin/env ruby
require "bunny"
connection = Bunny.new(
:hostname => "127.0.0.1",
:port => 5672,
:vhost => "/my_vhost",
:user => "serverworld",
:pass => "password",
)
connection.start
channel = connection.create_channel
q = channel.queue("Hello_World")
channel.default_exchange.publish("Hello RabbitMQ World!", :routing_key => q.name)
puts " [x] Sent 'Hello RabbitMQ World!'"
connection.close
ruby send_msg.rb [x] Sent 'Hello RabbitMQ World!' |
| [3] | Ruby スクリプトからのメッセージ受信例です。 例として、上記 [2] で送信したメッセージを受信します。 |
|
[cent@node01 ~]$
vi receive_msg.rb
#!/usr/bin/env ruby
require "bunny"
Signal.trap(:INT){
puts "Exited from receiving queues."
exit(0)
}
connection = Bunny.new(
:hostname => "127.0.0.1",
:port => 5672,
:vhost => "/my_vhost",
:user => "serverworld",
:pass => "password",
)
connection.start
channel = connection.create_channel
q = channel.queue("Hello_World")
puts " [*] Waiting for messages in #{q.name}. To exit press CTRL+C"
q.subscribe(:block => true) do |delivery_info, properties, body|
puts " [x] Received #{body}"
delivery_info.consumer.cancel
end
ruby receive_msg.rb [*] Waiting for messages in Hello_World. To exit press CTRL+C [x] Received Hello RabbitMQ World! |
| Sponsored Link |