支持多种语言
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集群
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。 |