Spring Boot按Profile切换RabbitMQ/Kafka时出现RabbitMQ连接拒绝问题

问题场景 #

已在Gradle中引入RabbitMQ依赖：

implementation 'org.springframework.amqp:spring-rabbit:2.4.6'

通过@Profile注解分别控制RabbitMQ监听器和Kafka消费者的加载：

• RabbitMQ监听器仅在DEDICATE Profile下加载：

@Component
@Profile(ProfileConfig.DEDICATE)
@Slf4j
@AllArgsConstructor
public class RabbitMQListener {
  private final ObjectMapper objectMapper;
  private final CollectionProcessor collectionProcessor;
  private final CollectionManagement collectionManagement;
  private final AssetManagement assetManagement;
  private final AssetProcessor assetProcessor;
  private final TraceService traceService;

  @RabbitListener(queues = {"${rabbitmq.queue.name}"})
  public void receiveMessage(final String message) {
    try {
      JSONParser parser = new JSONParser();
      JSONObject json = (JSONObject) parser.parse(message);
      String messageType = json.get("messageType").toString();
      log.debug("Receive Queue  Key={}, Message = {}", messageType, message);
      AsyncType asyncType = AsyncType.valueOf(messageType);
      executeMessage(asyncType, message);
    } catch (JsonProcessingException | IllegalArgumentException | ParseException e) {
      traceService.removeTraceId();
      traceService.printErrorLog(log, "Fail to deal receive message.", e, PrintStackPolicy.ALL);
    }
  }
}

• Kafka消费者在DEV/PROD/SIMUL Profile下加载：

@Service
@Profile({ProfileConfig.DEV, ProfileConfig.PROD, ProfileConfig.SIMUL})
@Slf4j
@AllArgsConstructor
public class KafkaConsumer {

  private final ObjectMapper objectMapper;
  private final CollectionProcessor collectionProcessor;
  private final CollectionManagement collectionManagement;
  private final AssetManagement assetManagement;
  private final AssetProcessor assetProcessor;
  private final TraceService traceService;

  @KafkaListener(topics = {"${aws.kafka.topic}"})
  public void consume(@Payload String message, @Header(KafkaHeaders.RECEIVED_MESSAGE_KEY) String key){
    try {
      JSONParser parser = new JSONParser();
      JSONObject json = (JSONObject) parser.parse(message);
      String messageType = json.get("messageType").toString();
      log.debug("Receive Queue  Key={}, Message = {}", messageType, message);
      AsyncType asyncType = AsyncType.valueOf(messageType);
      executeMessage(asyncType, message);
    } catch (JsonProcessingException | IllegalArgumentException | ParseException e) {
      traceService.removeTraceId();
      traceService.printErrorLog(log, "Fail to deal receive message.", e, PrintStackPolicy.ALL);
    }
  }
}

当前设置spring.profiles.active = SIMUL，但仍出现RabbitMQ连接拒绝警告：

WARN 22-09-08 14:41:23 Rabbit health check failed - [RMI TCP Connection(5)-xxx.xxx.xxx.xxx] [RabbitHealthIndicator:94]
org.springframework.amqp.AmqpConnectException: java.net.ConnectException: Connection refused
...（完整堆栈信息省略）

原因分析 #

• @Profile仅排除了RabbitMQ监听器组件，但Spring Boot的自动配置机制会因为spring-rabbit依赖存在，自动创建ConnectionFactory、RabbitTemplate等RabbitMQ核心组件
• 项目启用了Spring Boot Actuator，其健康检查模块会自动注册RabbitHealthIndicator，该指示器会主动尝试连接RabbitMQ以验证健康状态，从而触发连接错误

解决办法 #

方案1：按Profile禁用RabbitMQ自动配置（推荐） #

在对应Profile的配置文件（如application-simul.yml）中添加配置，仅在非DEDICATE环境下排除Rabbit自动配置：

spring:
  autoconfigure:
    exclude: org.springframework.boot.autoconfigure.amqp.RabbitAutoConfiguration

DEDICATE环境无需添加此配置，自动配置会正常生效。

方案2：直接禁用RabbitMQ健康检查 #

若不需要RabbitMQ的健康检查功能，可在配置文件中全局关闭：

management:
  health:
    rabbit:
      enabled: false

方案3：条件化加载RabbitMQ配置 #

创建自定义配置类，仅在DEDICATE Profile下导入Rabbit自动配置：

@Configuration
@Profile(ProfileConfig.DEDICATE)
@Import(RabbitAutoConfiguration.class)
public class RabbitMQConfig {
    // 按需添加自定义RabbitMQ配置
}

启动类无需添加exclude配置，这样只有DEDICATE环境才会加载RabbitMQ相关组件。

内容的提问来源于stack exchange，提问作者임지환