我正在探索使用LVC交换来使用有状态通知。当状态发生变化时，需要告知订阅者。当服务不一定总是启动并且不能保证以任何顺序启动时，LVC交换对此很有价值。
一个持久的和持久的队列将允许我使用相同的功能，但是如果长时间关闭，队列大小可能会在不需要的情况下变大，队列读取器可能不得不处理许多不必要的消息。
我在Docker容器中运行RabbitMQ。我已经验证了交换本身实际上是持久的，并且mnesia对象Map到容器之外。
1.启动RabbitMQ
1.将邮件发布到exchange（producer.rb）
1.使用绑定到交换机的匿名队列侦听消息
1.确保收到最后一个值
1.停止RabbitMQ
1.启动RabbitMQ
1.使用绑定到交换机的匿名队列侦听消息
producer.rb

#!/usr/bin/env ruby
require 'bunny'
connection = Bunny.new
connection.start
channel = connection.create_channel

message = "Hello World! #{Time.new}"
exchange = channel.exchange('pub-sub', :durable => true, :type => 'x-lvc')
exchange.publish(message, :persistent => true)
puts " [x] Sent '#{message}'"

consumer.rb

require 'bunny'
connection = Bunny.new()
connection.start
channel = connection.create_channel
queue = channel.queue('', exclusive: true)
queue.bind('pub-sub')

begin
  puts ' [*] Waiting for messages. To exit press CTRL+C'
  queue.subscribe(block: true) do |_delivery_info, _properties, body|
    puts " [x] Received #{body}"
  end
rescue Interrupt => _
  connection.close
end

我希望看到最初发布的相同消息，但我没有收到新消息。