动态创建rabbitmq连接工厂动态监听

要动态创建RabbitMQ连接工厂并动态监听，可以按照以下步骤进行操作：

导入相关的依赖库，例如spring-boot-starter-amqp。
在你的Spring Boot配置文件中配置RabbitMQ的连接信息，例如：

spring.rabbitmq.host=your_rabbitmq_host
spring.rabbitmq.port=your_rabbitmq_port
spring.rabbitmq.username=your_rabbitmq_username
spring.rabbitmq.password=your_rabbitmq_password

创建一个RabbitMQ连接工厂的Bean，例如：

@Bean
public ConnectionFactory connectionFactory() {
    CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
    connectionFactory.setHost(env.getProperty("spring.rabbitmq.host"));
    connectionFactory.setPort(Integer.parseInt(env.getProperty("spring.rabbitmq.port")));
    connectionFactory.setUsername(env.getProperty("spring.rabbitmq.username"));
    connectionFactory.setPassword(env.getProperty("spring.rabbitmq.password"));
    return connectionFactory;
}

这个Bean将根据配置文件中的信息创建一个RabbitMQ连接工厂。

创建一个RabbitMQ监听器的Bean，例如：

@Bean
public SimpleMessageListenerContainer messageListenerContainer(ConnectionFactory connectionFactory) {
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
    container.setConnectionFactory(connectionFactory);
    container.setQueueNames("your_queue_name");
    container.setMessageListener(yourMessageListener);
    return container;
}

这个Bean将使用上一步创建的RabbitMQ连接工厂，并指定要监听的队列和消息监听器。

在你的消息监听器中实现MessageListener接口的onMessage方法，例如：

@Component
public class YourMessageListener implements MessageListener {
    @Override
    public void onMessage(Message message) {
        // 处理接收到的消息
    }
}

这个消息监听器将处理接收到的消息。

通过以上步骤，你就可以动态创建RabbitMQ连接工厂并动态监听了。当你启动应用程序时，它将根据配置文件中的信息创建连接工厂，并开始监听指定的队列