Spring RabbitMQ：SimpleMessageContainer无法监听Message对象求助

安全阿岳

2026-7-31

问题原因与解决方案

你遇到的问题核心是MessageListenerAdapter的默认行为和@RabbitListener存在差异：

@RabbitListener内部默认配置了支持接收完整Message对象的处理逻辑
手动创建的MessageListenerAdapter默认会提取消息的字节数组体作为方法参数，而非传递完整的Message实例，所以当方法参数是Message时会抛出类型不匹配的异常。

解决方法一：配置MessageListenerAdapter的转换器，传递完整Message

给MessageListenerAdapter设置一个DefaultMessageConverter，并关闭消息体提取功能，这样适配器就会把完整的Message对象传给你的处理方法：

SimpleMessageListenerContainer listen = new SimpleMessageListenerContainer();
listen.setConnectionFactory(rabbitTemplate.getConnectionFactory());
listen.setQueueNames(testQueue);

MessageListenerAdapter adapt = new MessageListenerAdapter();
adapt.setDefaultListenerMethod(randomMethod);
adapt.setDelegate(this);

// 关键配置：禁用消息体提取，传递完整Message
DefaultMessageConverter converter = new DefaultMessageConverter();
converter.setExtractPayload(false);
adapt.setMessageConverter(converter);

listen.setMessageListener(adapt);
listen.start();

解决方法二：直接实现MessageListener接口，绕过适配器

如果不需要MessageListenerAdapter的适配功能，可以直接实现MessageListener接口，手动调用你的处理方法，这样能完全控制消息的接收逻辑：

SimpleMessageListenerContainer listen = new SimpleMessageListenerContainer();
listen.setConnectionFactory(rabbitTemplate.getConnectionFactory());
listen.setQueueNames(testQueue);

// 直接实现MessageListener，处理完整Message对象
listen.setMessageListener(new MessageListener() {
    @Override
    public void onMessage(Message msg) {
        randomMethod(msg);
    }
});
listen.start();