这篇文章主要介绍“如何解决RocketMQ消息消费异常”，在日常操作中，相信很多人在如何解决RocketMQ消息消费异常问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”如何解决RocketMQ消息消费异常”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！
开发中在项目重启时会重复消费消息，但其实消息已经消费过了。
然而通过源码断点MQClientInstance 定时任务正常，只是每次更新的offset都是原offet
由于是用的spring-boot整合的client,跟踪consumer源码，代码在DefaultRocketMQListenerContainer.handleMessage方法中
然而一切正常，再往上跟踪到DefaultMessageListenerConcurrently
计算
安全
数据库
网络和加速
企业服务
public class DefaultMessageListenerConcurrently implements MessageListenerConcurrently {
@SuppressWarnings("unchecked")
@Override
public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
for (MessageExt messageExt : msgs) {
log.debug("received msg: {}", messageExt);
try {
long now = System.currentTimeMillis();
handleMessage(messageExt);
long costTime = System.currentTimeMillis() - now;
log.debug("consume {} cost: {} ms", messageExt.getMsgId(), costTime);
} catch (Exception e) {
log.warn("consume message failed. messageExt:{}, error:{}", messageExt, e);
context.setDelayLevelWhenNextConsume(delayLevelWhenNextConsume);
return ConsumeConcurrentlyStatus.RECONSUME_LATER;
}
}
return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
}
}首先在catch代码块点打断点看看是不是有问题，结果发现并没有走到这里，这就坑爹了，害我又从其它方面各种查原因，浪费了很多时间。后面一步一步调试，最终在 log.debug("consume {} cost: {} ms", messageExt.getMsgId(), costTime); 打日志这一步时抛出了异常，这尼玛打个日志还能异常，还不是Exception的异常。。本来松了口气以为找到了原因就好解决了，没想到这才是刚刚开始。
java.lang.NoClassDefFoundError:Could not initialize class org.apache.rocketmq.common.message.MessageClientIDSetter
原因是在MessageClientExt类中调用getMsgId方法里，调用了MessageClientIDSetter.getUniqID(this)直接抛出的异常
从异常信息来看是MessageClientIDSetter 在初始化的时候出了问题
static {
byte[] ip;
try {
ip = UtilAll.getIP();
} catch (Exception e) {
ip = createFakeIP();
}
LEN = ip.length + 2 + 4 + 4 + 2;
ByteBuffer tempBuffer = ByteBuffer.allocate(ip.length + 2 + 4);
tempBuffer.position(0);
tempBuffer.put(ip);
tempBuffer.position(ip.length);
tempBuffer.putInt(UtilAll.getPid());
tempBuffer.position(ip.length + 2);
tempBuffer.putInt(MessageClientIDSetter.class.getClassLoader().hashCode());
FIX_STRING = UtilAll.bytes2string(tempBuffer.array());
setStartTime(System.currentTimeMillis());
COUNTER = new AtomicInteger(0);
}发面是在ip = UtilAll.getIP();出了问题，然则并没有到catch代码块，而是跳到了DefaultMqPushConsumerImpl类中，这里又一个坑爹的是异常块没有任何处理，看不到异常信息，好吧只能一步一步继续断点调试
最终在UtillAll类的ipV6Check方法执行到InetAddressValidator.getInstance();出了问题。
private static boolean ipV6Check(byte[] ip) {
if (ip.length != 16) {
throw new RuntimeException("illegal ipv6 bytes");
}
InetAddressValidator validator = InetAddressValidator.getInstance();
return validator.isValidInet6Address(ipToIPv6Str(ip));
}但是在本地调试这段代码又没有任何问题。因此只能在debug时调试，报的错是classNotFound异常
从rocketMq的依赖来看他需要的版本是1.6
因此我们需要把1.3.1的版本移除
看着这密密麻麻的依赖关系，Idea还没有查找功能，只能慢慢找了，最后功夫不复有心人，把依赖移除，重启一切都好了
到此，关于“如何解决RocketMQ消息消费异常”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注亿速云网站，小编会继续努力为大家带来更多实用的文章！
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
原文链接：https://my.oschina.net/laigous/blog/4905562
