ICode9

精准搜索请尝试: 精确搜索
首页 > 其他分享> 文章详细

github 代码简单讲解

2022-08-16 17:01:06  阅读:184  来源: 互联网

标签: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. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有