一 MQ如何保证消息不丢失
二 如何保证消息幂等性
1，生产者：发送消息时，给每条消息分配⼀个唯⼀的ID，判断消息是否重复投递。
2，比如订单ID就是⼀个很好的带有业务属性的唯⼀指标。在使⽤RocketMQ时，可以使⽤message的key属性来传递订单ID。这样Consumer就能够⽐较好的防⽌重复消费。
三 如何保证消息的顺序性
1、Producer将⼀组有序的消息写⼊到同⼀个MessageQueue中。
在Producer端，RocketMQ和Kafka都提供了分区计算机制，可以让应⽤程序⾃⼰决定消息写⼊到哪⼀个分
区。所以这⼀块，是由业务⾃⼰决定的。只要通过定制数据分⽚算法，把⼀组局部有序的消息发到同⼀个对列
当中，就可以通过对列的FIFO特性，保证消息的处理顺序。对于RabbitMQ，则可以通过维护Exchange与
Queue之间的绑定关系，将这⼀组局部有序的消息转发到同⼀个对列中，从⽽保证这⼀组有序的消息，在
RabbitMQ内部保存时，是有序的。
MessageSelector
2、Consumer每次集中从⼀个MessageQueue中拿取消息。
在Conusmer端，RocketMQ是通过让Consumer注⼊不同的消息监听器来进⾏区分的。⽽具体的实现机制，在
之前章节分析过，核⼼是通过对Consumer的消费线程进⾏并发控制，来保证消息的消费顺序的。类⽐到Kafka
呢。Kafka中并没有这样的并发控制。⽽实际上，Kafka的Consumer对某⼀个Partition拉取消息时，天⽣就是
单线程的，所以，参照RocketMQ的顺序消费模型，Kafka的Consumer天⽣就是能保证局部顺序消费的。
MessageListenerOrderly
四 如何快速处理积压的消息
1，增加更多的Consumer实例。
2，可以创建⼀个新的Topic，配置⾜够多的MessageQueue。然后把
Consumer实例的Topic转向新的Topic，并紧急上线⼀组新的消费者，只负责消费旧Topic中的消息，并转存到
新的Topic中。这个速度明显会⽐普通Consumer处理业务逻辑要快很多。然后在新的Topic上，就可以通过添
加消费者个数来提⾼消费速度了。之后再根据情况考虑是否要恢复成正常情况。
3，异步增加线程处理消息。