动态注册Bean导致Spring Boot关闭钩子抛出异常，如何解决？

异常原因 #

你当前使用applicationContext.registerBean(...)传入已实例化的容器对象时，Spring会默认尝试通过构造器自动装配的方式管理这个Bean的生命周期。但如果上下文存在多个ConsumerFactory类型的Bean，就会触发依赖歧义错误——因为Spring在应用关闭时会尝试重新解析Bean的构造参数，而无法确定该注入哪个ConsumerFactory。

解决方案 #

方案1：直接注册单例实例到Spring注册表 #

跳过BeanDefinition的解析流程，直接将已创建的容器实例注册为Spring单例Bean，让Spring直接管理现有实例，无需重新构造：

private void startAdminMessageListener(Message heartbeat) {
  final String topic = heartbeat.getMessageTopicPrefix() + "-" + applicationClusterName;
  if (adminMessageListenerContainer == null) {
    synchronized (threadLock) {
      if (adminMessageListenerContainer == null) {
        final KafkaMessageListenerContainer<String,String> container = createAdminMessageLister(topic);
        // 直接注册单例实例
        ((SingletonBeanRegistry) applicationContext.getBeanFactory()).registerSingleton("adminMessageListenerContainer", container);
        container.start();
        adminMessageListenerContainer = container;
        log.info("Starting admin message listener on topic {}", topic);
      }
    }
  }
}

方案2：使用Supplier注册并关闭自动装配 #

如果需要保留registerBean的用法，通过Supplier提供实例并显式关闭自动装配，告诉Spring无需解析构造参数：

private void startAdminMessageListener(Message heartbeat) {
  final String topic = heartbeat.getMessageTopicPrefix() + "-" + applicationClusterName;
  if (adminMessageListenerContainer == null) {
    synchronized (threadLock) {
      if (adminMessageListenerContainer == null) {
        final KafkaMessageListenerContainer<String,String> container = createAdminMessageLister(topic);
        applicationContext.registerBean("adminMessageListenerContainer", KafkaMessageListenerContainer.class, 
            () -> container, 
            beanDefinition -> {
                beanDefinition.setScope(SingletonBeanFactory.SCOPE_SINGLETON);
                beanDefinition.setAutowireMode(AbstractBeanDefinition.AUTOWIRE_NO); // 关闭自动装配
            });
        container.start();
        adminMessageListenerContainer = container;
        log.info("Starting admin message listener on topic {}", topic);
      }
    }
  }
}

方案3：手动管理生命周期（不注册为Spring Bean） #

如果不需要Spring管理容器的生命周期，可以不注册Bean，而是在应用关闭时手动停止容器：

1. 实现ApplicationListener<ContextClosedEvent>或者使用@PreDestroy注解，监听应用关闭事件
2. 在回调方法中手动停止容器：

@PreDestroy
public void stopAdminListenerContainer() {
    if (adminMessageListenerContainer != null && adminMessageListenerContainer.isRunning()) {
        adminMessageListenerContainer.stop();
        log.info("Stopped admin message listener container");
    }
}

关键说明 #

• 方案1和方案2的核心是避免Spring重新解析Bean的构造参数，直接使用你已创建好的实例
• 方案3适合不需要Spring参与生命周期管理的场景，但需要确保手动处理容器的停止逻辑

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