现象，服务重启之后可以消费挤压得消息，消费一段时间之后就停了，在重启就又可以消费消息了
线上出现的问题，程序启动的时候可以消费消息，一段时间之后，就突然不消费了。使用jstack把线程栈信息那些来，并没有阻塞的线程，mq拉取线程是waiting 状态，原因是 在拿到消息之后 就把消息中 body 设置成null了 ，导致消息在更新消息下标的时候用到body的地方就就报错了，但是mq做了异常处理，所以就不会抛出来异常，最终导致消息不在拉取mq专业的叫法是触发了流控的限制。具体原因，可以查看源码，解决方案就是 mq 传递的 body 的2进制的数据到一定不能修改。
下面贴出mq流控代码，针对于推模式的。
image.png
