🎈 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);}
}
)
