java 连接rabbitmq 集群

在 Java 中连接 RabbitMQ 集群，需要使用 RabbitMQ Java 客户端库，以下是一个示例代码：

import com.rabbitmq.client.ConnectionFactory;
public class ClusterExample {        
    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setUsername("user");
        factory.setPassword("password");
        factory.setVirtualHost("/");
        factory.setHost("node1.example.com");
        factory.setPort(5672);
        // ... connect to the first node in the cluster
        // ... perform your operations
        // ... when you want to switch nodes, simply create a new connection using a different host name
        factory.setHost("node2.example.com");
        // ... connect to the second node in the cluster
        // ... perform your operations
在上面的代码中，我们创建了一个连接工厂，并设置了用户名、密码、虚拟主机和端口。然后我们可以使用连接工厂创建一个连接到集群中的第一个节点，执行操作，然后再创建一个连接到集群中的第二个节点，继续执行操作。