RabbitMQ¹ÜÀí8

[root@h102 ruby]# cat p.rb 
#!/usr/bin/env ruby
## encoding: utf-8

require "bunny"
conn = Bunny.new
conn.start
conn = Bunny.new(:hostname => "localhost")
conn.start
ch   = conn.create_channel
q    = ch.queue("ruby_test_q")
ch.default_exchange.publish("I am a handsome guy!", :routing_key => q.name)
puts " [x] Sent 'Done!'"
conn.close
[root@h102 ruby]# 

conn = Bunny.new(:host => "192.168.1.20",:user => "test", :password => "test")

[root@h102 ruby]# cat c.rb 
#!/usr/bin/env ruby
## encoding: utf-8

require "bunny"

conn = Bunny.new
conn.start

ch   = conn.create_channel
q    = ch.queue("ruby_test_q")
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}"
	#cancel the consumer to exit
	#delivery_info.consumer.cancel
	end
[root@h102 ruby]#