RocketMQ—如何解决消息堆积问题
一般认为单条队列消息差值大于等于10万时，就算消息队列了。
生产者生产速度远远大于消费者消费的速度
我们可以增加消费者数量，但是需要满足消费者数量 小于等于 队列数量。
一般消费方消费消息是IO操作， 对于IO密集型任务，可以增加消费者方的线程数量，对于IO密集型最大线程数控制为2n(n为当前电脑最大处理器数量)；【对于cpu密集型，最大线程数，一般写 n + 1】。
理由如下：
cpu的速度 大于 内存的速度 大于 硬盘的速度，
- 如果是IO密集型，cpu处理一条操作，IO就会去耗费时间做事情了，不会频繁调度，所以最大线程数可以多一些；
- 如果是cpu密集型，如果线程数太大，会进行频繁调度。
也可以增加队列的数量，但是一般是运维来操作的，也不是越大越好。
注意，如果队列里有消息，不要对队列进行缩容，不然消息就会没了。
pem
pem的配置：
- 当为2时：表示这个topic的队列只能读，不能写；
- 当为4时：表表示这个topic的队列只能写，不能读；
- 当为6时：表示这个topic的队列既能读又能写。
消费者方出现问题
需要排查消费者挂掉的原因。
如果堆积的消息不想要了，怎么办
点击提交就可以了。
