什么高端mq

没用过这个mq，不过我觉得你的思路应该没错，消息积压无非是生产速度和消费速度不匹配的原因。看看你生产节点和消费节点各有多少，生产端每秒产生多少消息，消费端的线程池配置是什么样的，消费端代码有没有阻塞和同步处理。