Spring RabbitMQ多节点集群下客户端连接负载均衡配置咨询

你遇到的问题本质是默认地址解析策略导致的：Spring AMQP默认使用DefaultAddressResolver，它会严格按照你配置的addresses顺序遍历节点，只要第一个节点能成功建立连接，就直接返回这个连接，不会尝试后续节点。所以多个客户端启动时都会优先连列表里的第一个可用节点，自然就出现了所有客户端扎堆同一个节点的情况。

要让不同客户端分散连接到集群的不同节点，你可以通过以下几种方式解决：

1. 配置随机地址解析器（推荐） #

自定义RabbitMQ连接工厂，使用RandomAddressResolver替代默认的顺序解析器，这样每次创建连接时会随机从配置的节点列表中选择一个，能有效分散客户端的连接分布。

在Spring Boot项目中，你可以添加这样的配置类：

import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.connection.RandomAddressResolver;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitMQClusterConfig {

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

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

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

    @Value("${spring.rabbitmq.virtual-host}")
    private String virtualHost;

    @Bean
    public CachingConnectionFactory rabbitConnectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setAddresses(clusterAddresses);
        connectionFactory.setUsername(username);
        connectionFactory.setPassword(password);
        connectionFactory.setVirtualHost(virtualHost);
        // 关键：设置随机地址解析器
        connectionFactory.setAddressResolver(new RandomAddressResolver());
        return connectionFactory;
    }
}

2. 自定义地址解析策略（按需使用） #

如果随机策略不符合你的需求（比如想按权重分配连接），你可以自己实现AddressResolver接口，自定义节点选择逻辑。比如根据客户端实例ID、负载情况等选择节点：

public class CustomAddressResolver implements AddressResolver {
    private final List<Address> addresses;

    public CustomAddressResolver(List<Address> addresses) {
        this.addresses = addresses;
    }

    @Override
    public List<Address> getAddresses() {
        // 这里写你的自定义选择逻辑，比如按权重、按客户端标识分配
        Collections.shuffle(addresses); // 示例：随机打乱顺序
        return addresses;
    }
}

然后在连接工厂中设置这个自定义解析器即可。

3. 补充说明 #

• 如果你开启了自动连接恢复（默认是开启的，spring.rabbitmq.automatic-recovery-enabled=true），当某个节点故障时，客户端会自动尝试连接集群中的其他节点，不影响业务连续性；
• 确保你的监听器容器工厂（比如SimpleRabbitListenerContainerFactory）使用了这个自定义的连接工厂；
• 随机策略能在客户端启动时就分散连接，避免初始阶段的节点负载不均。

内容的提问来源于stack exchange，提问作者user3747293