github 地址 : https://github.com/lijiesheng/rabbitmq/tree/simple
simple 模式
分支1 :simple-data-lose
没有引入应答机制,只要消费者关闭,队列中的数据就会丢失。服务器重启,数据也会丢失。
分支2 :simple
引入了应答机制,消费者关闭再次打开,仍然可以消费数据。但是服务器重启,数据也会丢失。
分支3 :message-durability
引入了应答机制和,持久化【队列持久化,消息持久化】消费者关闭再次打开,仍然可以消费数据。服务器重启,数据也不会丢失。
分支4 :fair-dispatch
引入公平分发,多个消费者可以公平的得到消息,即使有一个消费者重启后
err = r.channel.Qos( 1, // 预取计数 这告诉RabbitMQ不要一次向一个worker发出多个消息 0, // prefetch size false, // global )
fanout 模式
分支 :publish_exchage_famout 将
routing 模式
分支 : routing 和 routing_multiply
topic 模式
分支:topic
死信队列
分支 :dead_queue_ttl 过期会进入到死信队列中
分支:dead_queue_max_length 超过最大长度会进入到死信队列中
分支:dead_queue_message_rejected 消息被拒绝后会进入到死信队列中
延迟队列
分支 :dead_queue_ttl
惰性队列
优先队列
标签:github,队列,代码,dead,simple,死信,讲解,分支 From: https://www.cnblogs.com/dogHuang/p/16592043.html