标签：队列 零碎 死信 消息 RabbitMQ 延迟 ID 总有一天

概念
MQ：消息队列（消息中间件），开源的基于AMQP协议的消息中间件，异步 解耦 削峰
核心作用：1.异步 2.解耦 3.消息通信
RabbitMQ
消息的类型：1.点对点 2.Worker 3.发布/定义（交换器）
四种交换器：
■1.fanout直接转发
■2.direct路由关键字匹配，精确
■3.topic路由关键字匹配，支持模糊（*和#）
■4.header消息头
RabbitMQ保证消息的可靠性(消息丢失)
原因：
有一定的概率会出现消息丢失
比如：1.消息刚从发送者发送到服务器中，发送者宕机了，在发送的一瞬间，服务器网络异常
2.消费者刚从服务器获取数据，还没获取完，服务器宕机了，或者网络延迟了
3.任何一款的MQ都有可能遇到消息丢失的问题，特别是高并发下
发送端：
要考虑的问题：
1.保证消息发送成功
2.保证服务端接收成功
3.要采用应答模式 发送端和服务端的应答模式
4.需要考虑消息补偿机制
解决方案：
1.消息开启本地持久化 --- 实现消息的落库的处理
2.实现基于延迟的二次确认机制 --- 消息采用2次投递方案，第一次立即执行，第二次间隔执行 采用延迟的模式进行，第二次的投递是为了保证数据的校验。如果存在就不做处理，要是不存在就同步一次
3.RabbitMQ支持消息事务 --- 可以采用事务的模式来处理消息是否成功
消费端：
1.保证消息的获取并应答
结合RabbitMQ的消息应答模式 实现消息消费的应答
2.保证消息过重
每一个消息都有唯一ID,每当消费者获取到消息的时候，先检验此消息有没有被消费过，如果没有再继续进行操作。要是之前消费过，那么就不能再次处理！可以结合Redis
RabbitMQ保证消息幂等性(消息重复)
幂等性：用户对于同一操作发起的一次请求或者多次请求的结果是一致的，不会因为多次点击而产生了副作用。
消息重复
MQ有可能会出现一个消息发送多次，导致消息的重复性
可能出现的场景：1.网络抖动 2.网络闪断 3.端点异常 服务端或者发送端或者消费端
消息出现非幂等性，就会导致消息的重复
解决方案：
1.唯一ID+指纹码
唯一ID 可以使用：雪花算法等等 这种分布式唯一ID生成器
指纹码：就是一段密文，加密规则各不相同
常用：时间戳+随机码+唯一ID+业务ID 采用一定加密技术 进行密文生成
2.基于Redis的原子性实现
Redis的原子性，自增啥的都可以，关键Redis支持集群
为消息设置唯一id，生成唯一id可以用雪花算法，实现去重
RabbitMQ延时队列
延时队列：跟普通队列比起来，多了一个延时的作用
死信消息：就是一个消息的TTL(有效期)结束了，但是消息还未处理，这时这个消息就变为了死信消息
死信队列和延迟消息投递
死信消息的条件：1.拒绝 2.过期 3.队列满了
延迟队列：RabbitMQ没有延迟队列，但是我们可以通过死信消息实现延迟消息投递\

消息的优先级
默认为5，可以通过设置x-max-priority，
MQ集群：1.默认模式 数据存储在其中某一台机器上，在使用的时候，才会进行同步。
2.镜像模式
项目中的应用场景：1.解耦逻辑 2.数据同步（近乎实时）3.延迟队列

标签：队列,零碎,死信,消息,RabbitMQ,延迟,ID,总有一天
来源： https://www.cnblogs.com/mysweetAngleBaby/p/16582843.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。