如何禁用Google Cloud PubSub Binder以避免绑定失败每30秒重试？

以下是几种无需移除依赖即可避免启动时绑定失败错误的有效方法：

1. 条件化绑定配置 #

通过Spring的条件注解，完全跳过消费者绑定的初始化逻辑，直到你确认配置后再启用：

• 创建配置类，仅当指定属性开启时才注册消费者绑定相关Bean：

  @Configuration
  @ConditionalOnProperty(
      name = "pubsub.binder.enabled", 
      havingValue = "true", 
      matchIfMissing = false
  )
  public class PubSubConsumerConfiguration {
      // 在这里定义你的PubSub消费者绑定、消息处理器等Bean
  }
  

• 启动时默认不开启该属性，等确认主题和订阅详情后，设置pubsub.binder.enabled=true并重启应用或刷新上下文。

2. 自定义Binder覆盖绑定逻辑 #

继承官方PubSub Binder类，重写doBindConsumer方法，先检查自定义开关再执行provision操作：

• 自定义Binder实现：

  public class ConditionalPubSubBinder extends PubSubMessageChannelBinder {
      @Value("${pubsub.binder.allow-provision:false}")
      private boolean allowProvision;
  
      public ConditionalPubSubBinder(
          PubSubProvisioningProvider provisioningProvider,
          PubSubTemplate pubSubTemplate,
          @Nullable Executor taskExecutor,
          @Nullable HeaderMapper<com.google.pubsub.v1.PubsubMessage> headerMapper
      ) {
          super(provisioningProvider, pubSubTemplate, taskExecutor, headerMapper);
      }
  
      @Override
      protected MessageChannel doBindConsumer(
          String name, 
          String group, 
          MessageChannel inputChannel, 
          ConsumerProperties properties
      ) {
          if (!allowProvision) {
              // 返回空通道，跳过provision和绑定流程
              return new DirectChannel();
          }
          return super.doBindConsumer(name, group, inputChannel, properties);
      }
  }
  

• 替换默认Binder Bean：

  @Bean
  public PubSubMessageChannelBinder customPubSubBinder(
      PubSubProvisioningProvider provisioningProvider,
      PubSubTemplate pubSubTemplate,
      @Autowired(required = false) Executor taskExecutor,
      @Autowired(required = false) HeaderMapper<com.google.pubsub.v1.PubsubMessage> headerMapper
  ) {
      return new ConditionalPubSubBinder(provisioningProvider, pubSubTemplate, taskExecutor, headerMapper);
  }
  

• 启动时设置pubsub.binder.allow-provision=false，确认配置后改为true并刷新上下文。

3. 自定义空实现的ProvisioningProvider #

通过BinderCustomizer替换默认的ProvisioningProvider为一个空实现，避免实际的PubSub资源检查：

• 实现空的ProvisioningProvider：

  class NoOpPubSubProvisioningProvider implements PubSubProvisioningProvider {
      @Override
      public ConsumerDestination provisionConsumerDestination(
          String name, 
          String group, 
          ConsumerProperties properties
      ) {
          // 返回一个占位符Destination，不执行实际的主题/订阅检查
          return () -> "placeholder-destination";
      }
  
      @Override
      public ProducerDestination provisionProducerDestination(
          String name, 
          ProducerProperties properties
      ) {
          return null;
      }
  }
  

• 配置BinderCustomizer替换默认实现：

  @Bean
  public BinderCustomizer pubSubBinderCustomizer() {
      return (binder, binderName) -> {
          if (binder instanceof PubSubMessageChannelBinder pubSubBinder) {
              try {
                  // 通过反射替换内部的provisioningProvider
                  Field providerField = PubSubMessageChannelBinder.class.getDeclaredField("provisioningProvider");
                  providerField.setAccessible(true);
                  providerField.set(pubSubBinder, new NoOpPubSubProvisioningProvider());
              } catch (NoSuchFieldException | IllegalAccessException e) {
                  // 处理反射异常，比如日志记录
              }
          }
      };
  }
  

• 这种方式会让Binder在启动时不执行实际的PubSub资源校验，后续你可以再切换回真实的ProvisioningProvider。

4. 动态配置刷新 #

结合Spring Cloud的刷新机制，先使用占位符配置启动，确认详情后更新配置并刷新：

• 初始配置（yaml格式）：

  spring:
    cloud:
      stream:
        bindings:
          input:
            destination: ${pubsub.topic:temp-topic}
            group: ${pubsub.subscription:temp-sub}
            consumer:
              autoStartup: false
        gcp:
          pubsub:
            binder:
              auto-provision: false
  

• 当确定主题和订阅后，更新pubsub.topic和pubsub.subscription的真实值，然后调用/actuator/refresh端点刷新上下文，再通过配置开启autoStartup: true。

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