使用注解消费rabbitMq

要使用注解消费RabbitMQ，您需要使用Spring AMQP库和Spring Boot。下面是一个简单的示例：

首先，确保您的项目中包含以下依赖项：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

然后，创建一个RabbitMQ配置类来配置连接和声明队列：

@Configuration
public class RabbitMQConfig {
    
    @Value("${spring.rabbitmq.host}")
    private String host;
    
    @Value("${spring.rabbitmq.port}")
    private int port;
    
    @Value("${spring.rabbitmq.username}")
    private String username;
    
    @Value("${spring.rabbitmq.password}")
    private String password;
    
    @Bean
    public ConnectionFactory connectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory(host, port);
        connectionFactory.setUsername(username);
        connectionFactory.setPassword(password);
        return connectionFactory;
    }
    
    @Bean
    public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
        RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
        return rabbitTemplate;
    }
    
    @Bean
    public Queue queue() {
        return new Queue("myQueue");
    }
}

接下来，创建一个消费者类并使用@RabbitListener注解来定义消息处理方法：

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

最后，在您的应用程序主类上添加@EnableRabbit注解以启用RabbitMQ监听器：

@SpringBootApplication
@EnableRabbit
public class MyApp {
    
    public static void main(String[] args) {
        SpringApplication.run(MyApp.class, args);
    }
}

现在，当消息被发布到名为"myQueue"的队列时，handleMessage方法将被调用来处理消息。

请注意，这只是一个简单的示例，您可能需要根据您的实际需求进行更多的配置和调整