写一个使用RocketMQ同时消费多个MQ集群的例子

以下是一个使用RocketMQ同时消费多个MQ集群的示例：

public class MultiClusterConsumer {

    public static void main(String[] args) throws InterruptedException, MQClientException {

        // 定义需要消费的 topic 和 tag
        String topic = "TestTopic";
        String tag = "*";

        // 定义多个 MQ 集群的地址
        String[] clusterAddresses = new String[]{
                "10.0.0.1:9876",
                "10.0.0.2:9876",
                "10.0.0.3:9876"
        };

        // 创建多个消费者实例
        List<DefaultMQPushConsumer> consumers = new ArrayList<>();
        for (String clusterAddress : clusterAddresses) {
            DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("ConsumerGroup");
            consumer.setNamesrvAddr(clusterAddress);
            consumer.subscribe(topic, tag);
            consumer.registerMessageListener((MessageListenerConcurrently) (msgs, context) -> {
                // 消费消息的逻辑
                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
            });
            consumers.add(consumer);
            consumer.start();
        }

        // 等待消费者关闭
        for (DefaultMQPushConsumer consumer : consumers) {
            consumer.shutdown();
        }
    }
}

在上面的示例中，我们首先定义了需要消费的 topic 和 tag，然后定义了多个 MQ 集群的地址。接着，我们创建了多个消费者实例，每个消费者实例连接到不同的 MQ 集群，并订阅相同的 topic 和 tag。最后，我们等待消费者关闭。

需要注意的是，当使用多个 MQ 集群时，消息可能会被重复消费。因此，在实际应用中，我们需要根据业务场景来选择是否使用多个 MQ 集群。