Spring Boot部署GCP Cloud Run后，一段时间无法订阅PubSub求助

问题根源 #

Cloud Run的无服务器特性（自动缩容、闲置实例回收）与PubSubInboundChannelAdapter的流式拉取机制存在适配冲突：当实例闲置或连接长时间无消息时，适配器可能主动关闭连接且未自动重启；同时Cloud Run的缩容策略可能直接终止实例，导致消息监听中断。

具体修复方案 #

1. 调整流式拉取核心配置 #

修改适配器初始化代码，强制开启自动重启、设置保持活跃参数，避免连接因闲置断开：

@Bean
public PubSubInboundChannelAdapter inboundChannelAdapter(
        @Qualifier("pubsubInputChannel") MessageChannel inputChannel,
        PubSubTemplate pubSubTemplate) {
    PubSubInboundChannelAdapter adapter =
            new PubSubInboundChannelAdapter(pubSubTemplate, "你的订阅名称");
    adapter.setOutputChannel(inputChannel);
    adapter.setAckMode(AckMode.MANUAL); // 根据业务需求选择确认模式
    adapter.setStreamingPull(true);
    // 每5分钟发送一次保活请求，防止云端关闭连接
    adapter.setKeepAliveInterval(Duration.ofMinutes(5));
    // 单次流式拉取最长持续时间，到期自动重启连接
    adapter.setMaxDuration(Duration.ofHours(1));
    // 开启自动启动，连接断开后30秒自动重试
    adapter.setAutoStartup(true);
    adapter.setRecoveryInterval(Duration.ofSeconds(30));
    return adapter;
}

2. 配置Cloud Run实例策略 #

• 部署时设置最小实例数为1：确保至少有一个实例持续运行，不会因闲置被缩容到0
• 调整容器请求超时：根据消息处理的实际耗时延长超时时间，避免容器因处理超时被强制重启

3. 规范消息确认逻辑 #

如果使用手动确认模式，必须确保消息处理完成后调用ack()或nack()，避免未确认消息堆积阻塞连接：

@Service
public class PubSubMessageHandler {
    @ServiceActivator(inputChannel = "pubsubInputChannel")
    public void handleMessage(Message<ByteString> message) {
        try {
            // 业务处理逻辑
            System.out.println("Received message: " + message.getPayload().toStringUtf8());
            // 手动确认消息
            PubSubMessageHeaders headers = message.getHeaders().get(PubSubMessageHeaders.PUBSUB_MESSAGE_HEADERS, PubSubMessageHeaders.class);
            headers.ack();
        } catch (Exception e) {
            // 处理失败时拒绝消息，触发重试
            message.getHeaders().get(PubSubMessageHeaders.PUBSUB_MESSAGE_HEADERS, PubSubMessageHeaders.class).nack();
        }
    }
}

4. 确保Spring容器生命周期管理正常 #

• 检查是否有自定义Bean销毁逻辑误关闭适配器
• 确认application.properties中没有禁用Pub/Sub自动配置的参数（如spring.cloud.gcp.pubsub.enabled=false）

5. 日志排查定位异常 #

在application.properties中开启Pub/Sub调试日志：

logging.level.org.springframework.cloud.gcp.pubsub=DEBUG
logging.level.com.google.cloud.pubsub.v1=DEBUG

通过Cloud Logging查看适配器的连接建立、关闭、重试日志，定位具体异常（如权限问题、网络中断）。

内容的提问来源于stack exchange，提问作者karthik kannan B