如何从配置中定义了spring.rabbitmq.addresses的服务连接到2个不同的rabbitmq集群

spring.rabbitmq.addresses=amqp://user1:password1@host1:port1/virtualHost1,amqp://user2:password2@host2:port2/virtualHost2

@Configuration
public class RabbitMQConfig {

    @Value("${spring.rabbitmq.addresses}")
    private String rabbitmqAddresses;

    @Bean(name = "connectionFactory1")
    public ConnectionFactory connectionFactory1() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setAddresses(rabbitmqAddresses.split(",")[0]);
        // 设置其他连接参数
        return connectionFactory;
    }

    @Bean(name = "connectionFactory2")
    public ConnectionFactory connectionFactory2() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setAddresses(rabbitmqAddresses.split(",")[1]);
        // 设置其他连接参数
        return connectionFactory;
    }

    // 其他配置和Bean定义
}

@Component
public class RabbitMQListener {

    @RabbitListener(queues = "queue1", containerFactory = "rabbitListenerContainerFactory1")
    public void handleMessageFromCluster1(Message message) {
        // 处理来自第一个rabbitmq集群的消息
    }

    @RabbitListener(queues = "queue2", containerFactory = "rabbitListenerContainerFactory2")
    public void handleMessageFromCluster2(Message message) {
        // 处理来自第二个rabbitmq集群的消息
    }

    // 其他监听方法和处理逻辑
}