RabbitMQ
支持多种语言
RM架构：
如何保证消息可靠性？
1.保证消息可以到达Exchange
异步回调（Confirums机制）
步骤：开启confirms；设置confirms的异步回调（ACK/NCK）
2.保证消息可以路由到Queue
Return机制
3.保证Queue可以持久化消息
RM重启后队列中的消息依然存在
4.保证消费者可以正常消费信息
手动ACK
死信队列
死信：
1.消息被消费者拒绝，会重新放回到队列中供其他消费者消费,requeue设置为false
2.指定了队列中的消息生存时间/发送消息时设置了消息的生存时间，生存时间到了，消息没有被消费
3.队列已经到达消息的最大长度，之后路由过来的消息直接变为死信
消费者执行了ACK/reject机制，并设置requeue==false,那么消费者没有消费的信息会重新放回到队列中，并路由到死信交换机，进而放到死信队列中供消费者消费
应用：
1,基于死信队列，队列消息已经满的情况下，消息也不会丢失；
2.实现延迟消费的效果,如下订单在一定的时间内付款
延迟交换机
死信队列实现延迟消费时，如果延迟时间比较复杂，比较多，直接使用队列需要创建大量队列
RM集群
原文地址：https://blog.csdn.net/weixin_47559057/article/details/144710652
免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！