消息可靠性投递
使用RabbitMQ的时候，作为消息发送方希望杜绝任何消息丢失或者投递失败场景，RabbitMQ为我们提供了两种方式用来控制消息的投递可靠性模式
RabbitMQ整个消息投递的路径为：
producer--->rabbitmq broker--->exchange--->queue--->consumer
确认模式
设置ConnectionFactory的publisher-confirms="true" 开启确认模式
消息从producer到exchange则回返回一个confirmCallback
退回模式
设置ConnectionFactory的publisher-returns="true" 开启退回模式
- 如果消息没有路由到Queue，则丢弃消息（默认）
- 如果消息没有路由到Queue，则会返回一个returnCallback，使用rabbitTemplate.setMandatory(true)参数开启
- txSelect()，将当前channel开启事务
- txCommit()，用于提交事务
- txRollback()，用于回滚事务
事务机制
性能较差，不做讲解
使用channel下列方法，完成事务控制：
Consumer ACK
ACK(acknowledge) 确认，表示消费端收到消息后的确认方式
三种确认方式：
- 自动确认：acknowledge="none" 当消费者收到消息时会自动签收，不管处理结果。
- 手动确认：acknowledge="manual" 消费端不会自动签收，当业务处理完成后，手动调用方法进行确认。
- 根据异常情况确认：acknowledge="auto" 不常用
自动确认是指，当消息一旦被consumer接收到，则自动确认收到，并将相应message从RabbitMQ的消息缓存中移除，但是实际业务处理中，很可能消息接收到，但是业务处理出现异常，那么消息就会丢失。如果设置了手动确认的方式，则需要在业务处理成功后，调用channel.basicAck()，手动签收，如果出现异常，则调用channel.basicNack()方法，让其自动重新发送消息。
消费端限流
image.png
配置监听容器为手动确定并且 prefetch = N,N 代表手动确认完N条消息后再拉去另外N条消息。
TTL
TTL全称为Time To Live (存活时间/过期时间)。
当消息到达存活时间后，还没有被消费，会被自动清除。
RabbitMQ可以对消息设置过期时间，也可以对整个队列设置过期时间。
设置整个队列的过期时间
image.png
设置单条消息的过期时间
image.png
消息发送时传入对象
image.png
如果设置消息的过期时间同时也设置了队列的过期时间，以短的为准。
队列过期后，会将队列所有的消息全部移除
消息过期后，只有在队列顶端的才会判断是否过期进行移除（否则要对整个队列进行轮询判断每条消息是否过期，效率低）
死信队列
image.png
image.png
image.png
image.png
image.png
延迟队列
image.png
消息可靠性分析与追踪
image.png
image.png
image.png
