1、消息的可靠投递
两种方式：confirm确认模式、return 退回模式
rabbitmq 整个消息投递的路径为：producer--->rabbitmq broker--->exchange--->queue--->consumer
消息从 producer 到 exchange 则会返回一个 confirmCallback 。
消息从 exchange-->queue 投递失败则会返回一个 returnCallback 。
方式一：confirm确认模式
设置ConnectionFactory的publisher-confirms="true" 开启 确认模式。
使用rabbitTemplate.setConfirmCallback设置回调函数。当消息发送到exchange后回调confirm方法。在方法中判断ack，如果为true，则发送成功，如果为false，则发送失败，需要处理。
或者写成lombda
方式二：return 退回模式
设置ConnectionFactory的publisher-returns="true" 开启 退回模式。
使用rabbitTemplate.setReturnCallback设置退回函数，当消息从exchange路由到queue失败后，如果设置了rabbitTemplate.setMandatory(true)参数，则会将消息退回给producer。并执行回调函数returnedMessage。
将routingkey的值改为错误后，即可触发消息确认提示。
在RabbitMQ中也提供了事务机制，但是性能较差，此处不做讲解。
使用channel下列方法，完成事务控制：
txSelect(), 用于将当前channel设置成transaction模式
txCommit()，用于提交事务
txRollback(),用于回滚事务
2、Consumer ACK(客户端消息确认)
有三种确认方式：
自动确认：acknowledge="none"
手动确认：acknowledge="manual"
根据异常情况确认：acknowledge="auto"
自动确认是指，当消息一旦被Consumer接收到，则自动确认收到，并将相应message 从 RabbitMQ 的消息缓存中移除。如果设置了手动确认方式，则需要在业务处理成功后，调用channel.basicAck()，手动签收，如果出现异常，则调用channel.basicNack()方法，让其自动重新发送消息。
手动确认：acknowledge="manual"
1)编写监听器，监听队列消息
2）在配置文件中注册
3）测试
3、消费端限流
1）在<rabbit:listener-container> 中配置 prefetch属性设置消费端一次拉取多少消息。
2)消费端的确认模式一定为手动确认。acknowledge="manual"
具体实现：
1）编写监听器类
2）编写配置文件
3）结果展示
消息未确认接收
总共11条消息，9条未读，未确认消息2条
消息确认接收
每隔2秒钟进行一次消息拉取
TTL
设置队列过期时间使用参数：x-message-ttl，单位：ms(毫秒)，会对整个队列消息统一过期。
设置队列的过期时间：10s
消息单独过期
消息如果不在队列顶端，过期后不会立即被移除，而是它前面的所有消息被消费之后，再判断当前消息是否过期，如果过期，则移除
死信队列
死信队列，英文缩写：DLX 。Dead Letter Exchange（死信交换机），当消息成为Dead message后，可以被重新发送到另一个交换机，这个交换机就是DLX。
消息成为死信的三种情况：
1. 队列消息长度到达限制；
2. 消费者拒接消费消息，basicNack/basicReject,并且不把消息重新放入原目标队列,requeue=false；
3. 原队列存在消息过期设置，消息到达超时时间未被消费；
1. 队列消息长度到达限制
2. 消费者拒接消费消息
1）设置死信队列与路由键
2）开启消费者端的手动确认，编写消费者端队列监听器
3. 原队列存在消息过期设置，消息到达超时时间未被消费；
延迟队列
延迟队列，即消息进入队列后不会立即被消费，只有到达指定时间后，才会被消费。
在RabbitMQ中并未提供延迟队列功能。但是可以使用：TTL+死信队列 组合实现延迟队列的效果。
1）定义正常交换机与队列，并绑定 3）实现延迟，TTL+死信
2）定义死信交换机与队列，并绑定
3）发送消息
接收者:
1)定义监听器
2）监听死信队列
3）测试
接收者会在TTL计时结束后，收到信息
日志与监控
RabbitMQ日志
RabbitMQ默认日志存放路径：/var/log/rabbitmq/rabbit@xxx.log
日志包含了RabbitMQ的版本号、Erlang的版本号、RabbitMQ服务节点名称、cookie的hash值、RabbitMQ配置文件地址、内存限制、磁盘限制、默认账户guest的创建以及权限配置等等。
rabbitmqctl管理和监控
查看队列：# rabbitmqctl list_queues
查看exchanges：# rabbitmqctl list_exchanges
查看用户：# rabbitmqctl list_users
查看连接：# rabbitmqctl list_connections
查看消费者信息：# rabbitmqctl list_consumers
查看环境变量：# rabbitmqctl environment
查看未被确认的队列：# rabbitmqctl list_queues name messages_unacknowledged
查看单个队列的内存使用：# rabbitmqctl list_queues name memory
查看准备就绪的队列：# rabbitmqctl list_queues name messages_ready
消息追踪
在使用任何消息中间件的过程中，难免会出现某条消息异常丢失的情况。对于RabbitMQ而言，可能是因为生产者或消费者与RabbitMQ断开了连接，而它们与RabbitMQ又采用了不同的确认机制；也有可能是因为交换器与队列之间不同的转发策略；甚至是交换器并没有与任何队列进行绑定，生产者又不感知或者没有采取相应的措施；另外RabbitMQ本身的集群策略也可能导致消息的丢失。这个时候就需要有一个较好的机制跟踪记录消息的投递过程，以此协助开发和运维人员进行问题的定位。在RabbitMQ中可以使用Firehose和rabbitmq_tracing插件功能来实现消息追踪。
消息追踪-Firehose
firehose的机制是将生产者投递给rabbitmq的消息，rabbitmq投递给消费者的消息按照指定的格式发送到默认的exchange上。这个默认的exchange的名称为amq.rabbitmq.trace，它是一个topic类型的exchange。发送到这个exchange上的消息的routing key为 publish.exchangename 和 deliver.queuename。其中exchangename和queuename为实际exchange和queue的名称，分别对应生产者投递到exchange的消息，和消费者从queue上获取的消息。
注意：打开 trace 会影响消息写入功能，适当打开后请关闭。
rabbitmqctl trace_on：开启Firehose命令
rabbitmqctl trace_off：关闭Firehose命令
1) 将队列绑定到交换机 amq.rabbitmq.trace
2）开启消息追踪rabbitmqctl trace_on
virtual host为 /
3)在绑定的队列中发送消息
消息追踪-rabbitmq_tracing
消息向默认交换机中发送一份，向amp.rabbitmq.trace中发送一个份
rabbitmq_tracing和Firehose在实现上如出一辙，只不过rabbitmq_tracing的方式比Firehose多了一层GUI的包装，更容易使用和管理。
启用插件：rabbitmq-plugins enable rabbitmq_tracing
关闭插件：rabbitmq-plugins disable rabbitmq_tracing
1）启用插件
启用插件后，trace里面会记录所有消息
2）创建trace
3）查看log
1. 消息可靠性保障：消息补偿机制
2. 消息幂等性保障：乐观锁解决方案
幂等性指一次和多次请求某一个资源，对于资源本身应该具有同样的结果。也就是说，其任意多次执行对资源本身所产生的影响均与一次执行的影响相同。
在MQ中指，消费多条相同的消息，得到与消费该消息一次相同的结果。
