使用注解消费RabbitMQ消息 - Spring Boot快速指南

"使用注解消费RabbitMQ消息 - Spring Boot快速指南"\n\n要使用注解消费RabbitMQ，您需要使用Spring AMQP库和Spring Boot。下面是一个简单的示例：\n\n首先，确保您的项目中包含以下依赖项：\n\nxml\n<dependency>\n <groupId>org.springframework.boot</groupId>\n <artifactId>spring-boot-starter-amqp</artifactId>\n</dependency>\n\n\n然后，创建一个RabbitMQ配置类来配置连接和声明队列：\n\njava\n@Configuration\npublic class RabbitMQConfig {\n \n @Value("${spring.rabbitmq.host}")\n private String host;\n \n @Value("${spring.rabbitmq.port}")\n private int port;\n \n @Value("${spring.rabbitmq.username}")\n private String username;\n \n @Value("${spring.rabbitmq.password}")\n private String password;\n \n @Bean\n public ConnectionFactory connectionFactory() {\n CachingConnectionFactory connectionFactory = new CachingConnectionFactory(host, port);\n connectionFactory.setUsername(username);\n connectionFactory.setPassword(password);\n return connectionFactory;\n }\n \n @Bean\n public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {\n RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);\n return rabbitTemplate;\n }\n \n @Bean\n public Queue queue() {\n return new Queue("myQueue");\n }\n}\n\n\n接下来，创建一个消费者类并使用@RabbitListener注解来定义消息处理方法：\n\njava\n@Component\npublic class MyConsumer {\n \n @RabbitListener(queues = "myQueue")\n public void handleMessage(String message) {\n System.out.println("Received message: " + message);\n }\n}\n\n\n最后，在您的应用程序主类上添加@EnableRabbit注解以启用RabbitMQ监听器：\n\njava\n@SpringBootApplication\n@EnableRabbit\npublic class MyApp {\n \n public static void main(String[] args) {\n SpringApplication.run(MyApp.class, args);\n }\n}\n\n\n现在，当消息被发布到名为"myQueue"的队列时，handleMessage方法将被调用来处理消息。\n\n请注意，这只是一个简单的示例，您可能需要根据您的实际需求进行更多的配置和调整。