动态创建 RabbitMQ 连接工厂并监听队列 - Spring Boot 实践指南

要动态创建 RabbitMQ 连接工厂并动态监听，可以按照以下步骤进行操作：\n\n1. 导入相关的依赖库，例如spring-boot-starter-amqp。\n2. 在你的 Spring Boot 配置文件中配置 RabbitMQ 的连接信息，例如：\nproperties\nspring.rabbitmq.host=your_rabbitmq_host\nspring.rabbitmq.port=your_rabbitmq_port\nspring.rabbitmq.username=your_rabbitmq_username\nspring.rabbitmq.password=your_rabbitmq_password\n\n3. 创建一个 RabbitMQ 连接工厂的 Bean，例如：\njava\n@Bean\npublic ConnectionFactory connectionFactory() {\n CachingConnectionFactory connectionFactory = new CachingConnectionFactory();\n connectionFactory.setHost(env.getProperty("spring.rabbitmq.host"));\n connectionFactory.setPort(Integer.parseInt(env.getProperty("spring.rabbitmq.port")));\n connectionFactory.setUsername(env.getProperty("spring.rabbitmq.username"));\n connectionFactory.setPassword(env.getProperty("spring.rabbitmq.password"));\n return connectionFactory;\n}\n\n这个 Bean 将根据配置文件中的信息创建一个 RabbitMQ 连接工厂。\n\n4. 创建一个 RabbitMQ 监听器的 Bean，例如：\njava\n@Bean\npublic SimpleMessageListenerContainer messageListenerContainer(ConnectionFactory connectionFactory) {\n SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();\n container.setConnectionFactory(connectionFactory);\n container.setQueueNames("your_queue_name");\n container.setMessageListener(yourMessageListener);\n return container;\n}\n\n这个 Bean 将使用上一步创建的 RabbitMQ 连接工厂，并指定要监听的队列和消息监听器。\n\n5. 在你的消息监听器中实现MessageListener接口的onMessage方法，例如：\njava\n@Component\npublic class YourMessageListener implements MessageListener {\n @Override\n public void onMessage(Message message) {\n // 处理接收到的消息\n }\n}\n\n这个消息监听器将处理接收到的消息。\n\n通过以上步骤，你就可以动态创建 RabbitMQ 连接工厂并动态监听了。当你启动应用程序时，它将根据配置文件中的信息创建连接工厂，并开始监听指定的队列。