rocketmq消息积压，能处理实时消息传递消费吗

Question

1.用rocketmq消息中间来提高吞吐量。会造成消息积压的情况，如何提高消费者的并发消费？
2.问题：用rocketmq做中间件，客户端往中间件发送拨打消息，消费者就行消费，需要及时回应。如果大量的客户端进行拨打电话，会造成消息积压

Answer 1

1、增加队列，一个主题可以有多个队列，消费的时候，通用新增对应数量的消费线程数量，即队列数 = 消费线程数；要不然浪费资源；
2、根据broker的数量，现在消费者，即有3个broker，那就起3个消费者（这里跟消费线程不是一回事儿）；
3、可同时批量处理多条消息，比如一次拉去20条消息，异步处理这20条信息；
4、优化处理消息的业务逻辑，尽量减少不必要的时间损耗。