RabbitMQ

RabbitMQ copied to clipboard

关于rabbitmq的app文件疑问

4

我看rabbitmq源码里面没有一般erlang工程里面的.app.src文件，但是ebin里面却生成了一个rabbit.app文件，我想问问这个文件是怎么生成的？

MRLGC

消息发送两次

1

开启mirror queue时，消息通路是： channel -> rabbit_amqqueue:delvier ->delegate:cast(mast_pid) 主走这个 ->rabbit_amqqueue_process ->rabbit_queue_deliver： 在在消费者，直接发给存在的consumer ->rabbit_mirror_queue_master:publish -> gm:broadcast ->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节点 -> rabbt_mirror_queue_salve: 收到消息 我想问的是和通过gm和delegate将消息两次发送到slave节点，这个有什么作用，为啥要发送两次呢？

fanchao01

关于RabbitMQ ，ZMQ和组播

4

最近为了做试验，重新回来弄这2个东西。 发现RabbitMQ 性能（特指 速度和延迟）比ZMQ 低， 而且没有额外的包支持组播。 我想问的问题是： 要是为RabbitMQ 添加一个组播功能， 应该看哪块代码， 大概怎么改比较快速？ 是否有直接可以用的包 备注：Erlang 实在是不会， 在RabbitMQ 外面 做一个扩展模块， 连接上 ， 这样的例子， 能帮忙推荐几个嘛？

pengminjiong

aogg