Producer

生产者确认机制

开启MQ确认机制，消息发送到MQ以后，会返回一个结果给发送者，表示消息是否处理成功。

消息失败之后如何处理呢？

  • 回调方法即时重发
  • 记录日志
  • 保存到数据库然后定时重发，成功发送后即刻删除表中的数据

Server

消息持久化

MQ开启持久化功能可以确保缓存在MQ中的消息不丢失

交换机持久化 队列持久化 消息持久化

Consumer

消费者处理消息后可以向MQ发送ack回执，MQ收到ack回执后才会删除该消息。

1
2
3
manual：手动ack，需要在业务代码结束后，调用api发送ack。
auto：自动ack，由spring监测listener代码是否出现异常，没有异常则返回ack；抛出异常则返回nack
none：关闭ack，MQ假定消费者获取消息后会成功处理，因此消息投递后立即被删除

多次重试失败后将消息投递到异常交换机，交由人工处理