Json打印MQ对象问题-编程知识

Json打印MQ对象问题

一、代码

@Override
public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs,ConsumeConcurrentlyContext context) {
try {GiftSendMessage message = JSON.parseObject(msgs.get(0).getBody(),GiftSendMessage.class);UserInfo userInfo = new UserInfo();userInfo.setMemberId(String.valueOf(message.getFromId()));userInfo.setScId(message.getScId());userInfo.setAnchorScid(message.getAnchorScid());userInfo.setAnchorId(message.getAnchorId());userInfo.setGiftSendToId(message.getToId());DrawByGiftSendConfig draw =filter.getGiftIdBySend().get(String.valueOf(message.getGiftId()));GiftSendRequest request = new GiftSendRequest();request.setActivityId(draw.getActivityId());request.setBoxType(draw.getBoxType());request.setGiftOrderId(message.getGiftOrderId());request.setBatch(message.getAmount());request.setSendTime(message.getSendTime());request.setUserInfo(userInfo);request.setPaymentVersion(PAYMENT_VERSION);this.userDrawService.giftSend(request);LOG.info("DRAW BY GIFT SEND WITH SANTA CHECKOUT, MQ-MESSAGE={}, REQUEST={}",JSON.toJSONString(message),JSON.toJSONString(request));
} catch (Exception e) {LOG.error("GIFT-SEND-QUEUE CONSUME FATAL ERROR ON PARSING, DROPPED, MSG={},EXCEPTION={}, EXCEPTION-MESSAGE={}",JSON.toJSONString(msgs), e.getClass().getSimpleName(),e.getMessage(), e);
}return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
}

二、问题分析

在这里插入图片描述
图中红色方框当中，用的序列化方式为 fastjson，此行代码会抛出异常，导致消费失败，进入重试队列，且没有任何业务日志输出。MQ源码如下：

如果异常，返回 ConsumeConcurrentlyStatus.RECONSUME_LATER;

结论：无论是kafka，还是RocketMq，消费者方法参数中的MessageExt对象不能被 fastjson默认的方式序列化

三、原因

环境：项目采用1.2.31 (最新版本1.2.78)

接下来，我们分析下fastjson序列化的完整过程
fastjson反序列化的方式默认为采用 get方法、is方法作为序列化属性字段的,序列化流程如下：
在这里插入图片描述
其中：在获取对象序列化的时候，MessageExt中有返回 ByteBuffer的get方法，代码如下：

Mq消息在接收到消息时，构造了返回了ByteBuffer对象的方法，该方法是nio中设计用于保存数
据到缓冲区的目的。

主要的属性如下：

position: 其实是指从buffer读取或写入buffer的下一个元素位置。比如，已经写入buffer 3
个元素那那么position就是指向第4个位置，即position设置为3（数组从0开始计）；
imit：还有多少数据需要从buffer中取出，或还有多少空间可以放入。postition总是<=limit；
capacity: 表示buffer本身底层数组的容量。limit绝不能>capacity；

在这里插入图片描述