【Java】已解决：org.springframework.amqp.AmqpException: No method found: AMQP

屿小夏

发布于 2024-08-11 08:20:15

730

发布于 2024-08-11 08:20:15

文章被收录于专栏：IT杂谈学习

已解决：org.springframework.amqp.AmqpException: No method found: AMQP

一、分析问题背景

在使用Spring AMQP进行消息队列开发时，开发者可能会遇到org.springframework.amqp.AmqpException: No method found: AMQP的报错。该异常通常出现在消息处理的方法签名不匹配或消息监听器配置错误的情况下。

场景：在一个Spring Boot项目中，开发者配置了RabbitMQ的消息监听器，以处理来自特定队列的消息。然而，当消息到达队列并由监听器接收时，抛出了AmqpException异常。

示例代码片段：

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;

@Service
public class MessageListener {

    @RabbitListener(queues = "testQueue")
    public void handleMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

当消息发送到testQueue时，监听器无法正确处理消息并抛出异常。

二、可能出错的原因

导致org.springframework.amqp.AmqpException: No method found: AMQP报错的原因可能包括以下几点：

方法签名不匹配：消息处理方法的参数类型与消息内容不匹配。
消息转换器配置错误：RabbitMQ消息转换器未正确配置，导致消息无法正确转换为目标方法参数类型。
监听器配置错误：RabbitMQ监听器的配置不正确，导致无法正确找到处理消息的方法。

三、错误代码示例

以下是一个可能导致该报错的代码示例，并解释其错误之处：

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;

@Service
public class MessageListener {

    @RabbitListener(queues = "testQueue")
    public void handleMessage(Integer message) {  // 错误：期望字符串类型的消息
        System.out.println("Received message: " + message);
    }
}

错误分析：

方法签名不匹配：监听器方法期望接收一个Integer类型的消息，但实际消息是一个字符串，导致类型不匹配的异常。

四、正确代码示例

为了正确解决该报错问题，我们需要确保消息处理方法的参数类型与实际消息类型匹配。以下是正确的代码示例：

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;

@Service
public class MessageListener {

    @RabbitListener(queues = "testQueue")
    public void handleMessage(String message) {
        System.out.println("Received message: " + message);
    }
}

如果需要处理非字符串类型的消息，可以配置消息转换器。例如，处理JSON格式的消息：

import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.stereotype.Service;

@Configuration
public class RabbitConfig {

    @Bean
    public Jackson2JsonMessageConverter jackson2JsonMessageConverter() {
        return new Jackson2JsonMessageConverter();
    }
}

@Service
public class MessageListener {

    @RabbitListener(queues = "testQueue")
    public void handleMessage(MyMessage message) {
        System.out.println("Received message: " + message);
    }
}

class MyMessage {
    private String content;

    // getters and setters
}