这家伙mq是个怎么情况

Question

mq上绑定交换机和队列了，但运行到这里后就突然跳过了，后面也不执行了，也没有报错，也没发消息。这是咋回事？

Answer 1

【相关推荐】

• 你可以参考下这个问题的回答, 看看是否对你有帮助, 链接: https://ask.csdn.net/questions/7759427
• 这篇博客也不错, 你可以看下已经把用户加入MQ的执行用户组了，为什么该用户还是没有权限执行MQ
• 您还可以看一下 漆学军老师的从零开始学MQL4语言课程中的 1、序言以及指标程序制作演示小节, 巩固相关知识点
  
• 除此之外, 这篇博客: 剥丝抽茧｜阿里面试题解读：MQ消费端遇到瓶颈该怎么办？中的 ３、如何定位问题 部分也许能够解决你的问题, 你可以仔细阅读以下内容或跳转源博客中阅读:
  

  消费端出现瓶颈，如何识别是客户端的问题还是服务端的问题，一个最简单的办法是看集群内其他消费组是否也有积压，特别是和有问题的消费组订阅同一个主题的其他消费组是否有积压，按照笔者的经验，出现消息积压通常是客户端的问题，可以通过查询 rocketmq_client.log加以证明：

  grep "flow" rocketmq_client.log
  

  
  出现so do flow control 这样的日志，说明触发了消费的限流，其直接触发原因：就是消息消费端积压消息，即消费端无法消费已拉取的消息，为了避免内存泄露，RocketMQ在消费端没有将消息处理完成后，不会继续向服务端拉取消息，并打印上述日志。

  那如何定位消费端慢在哪呢？是卡在哪行代码呢？

  通常的排查方法是跟踪线程栈，即利用jstack命令查看线程运行情况，以此来探究线程的运行情况。

  通常使用的命令如下：

  ps -ef | grep java
  jstack pid > j1.log
  

  通常为了对比，我一般会连续打印5个文件，从而可以在5个文件中查看同一个消费者线程，其状态是否变化，如果未变化，则说明该线程卡主，那就是我们重点需要关注的地方。

  在RocketMQ中，消费端线程以ConsumeMessageThread_开头，通过对线程的判断，如下代码让人为之兴奋：
  
  消费端线程的状态是RUNNABLE，但在5个文件中其状态都是一样，基本可以断定线程卡在具体的代码，从示例代码中是卡在掉一个外部的http借口，从而加以解决，通常在涉及外部调用，特别是http调用，可以设置一个超时时间，避免长时间等待。

如果你已经解决了该问题, 非常希望你能够分享一下解决方案, 写成博客, 将相关链接放在评论区, 以帮助更多的人 ^-^