RabbitMQ

快速上手¶

安装¶

docker run -d rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3.11-management

# guest/guest
open http://192.168.205.60:15672

使用¶

终端 1：

irb

require 'bunny'

connection = Bunny.new(hostname: '192.168.205.60:567
2')

connection.start

channel = connection.create_channel

queue = channel.queue('hello')

channel.default_exchange.publish('Hello World!', routing_key: queue.name)

connection.close

终端 2

irb

require 'bunny'

connection = Bunny.new(hostname: '192.168.205.60:5672')

connection.start

channel = connection.create_channel

queue = channel.queue('hello')

queue.subscribe(block: true) do |_delivery_info, _properties, body|
    puts " [x] Received #{body}"
end

终端 3

docker exec rabbitmq rabbitmqctl list_queues

基本概念¶

消息¶

二进制大对象

生产¶

发送消息，生产者

消费¶

接收消息，消费者

通道¶

队列¶

交换机¶

资源¶

• RabbitMQ 官网

评论