🎈 1 参考文档

RabbitMQ消费消息坑：failed to convert serialized Message content | jiuchengi-cnblogs

---

🔍2 问题描述

org.springframework.amqp.rabbit.support.ListenerExecutionFailedException: Failed to convert messageat org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.onMessage(MessagingMessageListenerAdapter.java:156) ~[spring-rabbit-2.4.5.jar:2.4.5]...

Caused by: org.springframework.amqp.support.converter.MessageConversionException: failed to convert serialized Message contentat org.springframework.amqp.support.converter.SimpleMessageConverter.fromMessage(SimpleMessageConverter.java:117) ~[spring-amqp-2.4.5.jar:2.4.5]at ...

Caused by: java.lang.IllegalStateException: Could not deserialize object typeat org.springframework.amqp.utils.SerializationUtils.deserialize(SerializationUtils.java:97) ~[spring-amqp-2.4.5.jar:2.4.5]at org.springframework.amqp.support.converter.SimpleMessageConverter.fromMessage(SimpleMessageConverter.java:113) ~[spring-amqp-2.4.5.jar:2.4.5]... 16 common frames omitted

Caused by: java.lang.ClassNotFoundException: com.cauli.file.model.dto.file.FileSearchDTOat java.net.URLClassLoader.findClass(URLClassLoader.java:382) ~[na:1.8.0_221]at java.lang.ClassLoader.loadClass(ClassLoader.java:424) ~[na:1.8.0_221]at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349) ~[na:1.8.0_221]...

---

💡3 原因分析

这个异常信息表明在处理消息时出现了问题，具体地说，它是由于消息内容的反序列化失败引起的。以下为关键信息：

org.springframework.amqp.rabbit.support.ListenerExecutionFailedException: Failed to convert messageCaused by: org.springframework.amqp.support.converter.MessageConversionException: failed to convert serialized Message contentCaused by: java.lang.IllegalStateException: Could not deserialize object typeCaused by: java.lang.ClassNotFoundException: com.cauli.file.model.dto.file.FileSearchDTO

根据异常信息的内容，问题似乎是由于反序列化消息内容时找不到类 com.cauli.file.model.dto.file.FileSearchDTO 导致的。

我目前生产者和消费者都有一个FileSearchDTO对象，内容是一模一样的包括序列化，可就是消费者接收时报序列化错误。

---

🚀4 解决方案

4.1 共同使用一个对象

把这个对象放到公共模块，然后生产者和消费者服务引入这个公共模块，生产者和消费者发送和消费时共用一个对象。这样完全保证了两个项目中JavaBean是一致的，所以能解决反序列失败的问题。

缺点：局限性太小，这种模式生产者和消费者只能在同一个微服务下才能使用

4.2 消息JSON序列化

4.2.1 生产者发送消息JSON序列化

生产者添加配置：

/*** RabbitMQ配置** @author Tang* @version 1.0* @date 2022/05/02 23:23:27*/
@Configuration
public class RabbitMQConfig implements InitializingBean {/*** 自动注入RabbitTemplate模板*/@Resourceprivate RabbitTemplate rabbitTemplate;/*** 发送消息JSON序列化*/@Overridepublic void afterPropertiesSet() {//使用JSON序列化rabbitTemplate.setMessageConverter(new Jackson2JsonMessageConverter());}
}

4.2.2 消费者接收消息JSON反序列化

消费者添加配置：

/*** RabbitMQ配置** @author Tang* @version 1.0* @date 2022/05/02 23:23:27*/
@Configuration
public class RabbitMQConfig {@Beanpublic MessageConverter jsonMessageConverter(ObjectMapper objectMapper) {return new Jackson2JsonMessageConverter(objectMapper);}
}