RabbitMQ反序列化失败：Failed to convert message_Java

🎈 1 参考文档

🔍2 问题描述

org.springframework.amqp.rabbit.support.listenerexecutionfailedexception: failed to convert message
	at 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 content
	at 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 type
	at 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.filesearchdto
	at 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 message
    
caused by: org.springframework.amqp.support.converter.messageconversionexception: failed to convert serialized message content
    
caused by: java.lang.illegalstateexception: could not deserialize object type
    
caused 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模板
     */
    @resource
    private rabbittemplate rabbittemplate;

    /**
     * 发送消息json序列化
     */
    @override
    public 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 {

    @bean
    public messageconverter jsonmessageconverter(objectmapper objectmapper) {
        return new jackson2jsonmessageconverter(objectmapper);
    }
}