1.引入消息队列之后该如何保证其高可用性?
镜像集群模式:
2.为什么在消息队列里消费到了重复的数据?
3.到消息队列里面的数据怎么不见了?
4.怎么保证从消息队列里拿到的数据按顺序执行?
问题:
保证顺序:
5.生产事故!几百万消息在消息队列里积压了几个小时,怎么办?
问题:
大体步骤:
详细步骤:
(1)假设是消费端挂了的场景,导致MQ没人消费(紧急扩容):
(2)消费者端好了,正常消费了,但是问题时如何快速消费积压的几百万条数据?(增加临时消费者,消费完了再把临时消费者去掉)
具体步骤在详细步骤有
(3)真实生产环境是不设置消息过期时间的,比如积压1个小时就把消息删除掉,这时数据就没了。可以做,但是需要些一个程序查出来拿些数据丢失,然后批量重新导入MQ(重发MQ)
真实场景:
(4)MQ写满了怎么办?(没有解决办法,只能丢数据然后再补数据,用临时MQ,批量重导MQ)