标签:github 队列 代码 dead queue simple 死信 讲解 分支
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,queue,simple,死信,讲解,分支 来源: https://www.cnblogs.com/dogHuang/p/16592043.html
本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享; 2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关; 3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关; 4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除; 5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。