消息发送两次

[fanchao01]

开启mirror queue时，消息通路是： channel -> rabbit_amqqueue:delvier ->delegate:cast(mast_pid) 主走这个 ->rabbit_amqqueue_process ->rabbit_queue_deliver： 在在消费者，直接发给存在的consumer ->rabbit_mirror_queue_master:publish -> gm:broadcast <1> ->rabbit_mirror_queue_slave：process_instruction（{publish... slave节点 ->publish_or_discard ->BQ:publish 放入variable_queue -> rabbit_variable_queue:publish 放入自己的BQ
-> 通过gm广播到各slave节点
->deletegate:cast(slave_pids) slave节点 <2> -> rabbt_mirror_queue_salve: 收到消息

我想问的是<1>和<2>通过gm和delegate将消息两次发送到slave节点，这个有什么作用，为啥要发送两次呢？

[fanchao01]

我去，这个空格没有，尴尬。简单来说就是，消息会通过gm和deletgate两次发送到rabbit_mirror_queue_slave上，gm那次会存到后端BQ；为啥要分发两次呢?多谢。