PCF环境下Spring Boot应用连接Google Pub/Sub失败问题求助

看起来你遇到的问题是明明已经加载了credentials.json凭证并能打印Project ID，但创建Pub/Sub Subscriber时还是触发了默认凭证检测失败。这是因为你手动创建Subscriber的代码没有指定使用已加载的凭证，导致SDK默认去尝试检测GCE环境的凭证（而PCF环境并不在GCE上），最终抛出了“应用默认凭证不可用”的错误。

下面给你两种可行的解决方案：

方案一：手动将加载的凭证传入Subscriber构建器 #

你需要显式加载ServiceAccountCredentials，并将其配置到PubSubOptions中，再用这个Options来创建Subscriber。修改你的subscribeAsyncExample方法如下：

import com.google.auth.oauth2.ServiceAccountCredentials;
import com.google.cloud.pubsub.v1.Subscriber;
import com.google.pubsub.v1.ProjectSubscriptionName;
import java.io.FileInputStream;
import java.io.IOException;

public static void subscribeAsyncExample(String projectId, String subscriptionId) {
    ProjectSubscriptionName subscriptionName = ProjectSubscriptionName.of(projectId, subscriptionId);
    System.out.println("Processing messages...");
    
    // 显式加载凭证
    ServiceAccountCredentials credentials = null;
    try {
        // 在PCF中建议用环境变量指定路径，避免硬编码
        String credPath = System.getenv("GOOGLE_APPLICATION_CREDENTIALS");
        credentials = ServiceAccountCredentials.fromStream(new FileInputStream(credPath));
    } catch (IOException e) {
        e.printStackTrace();
        return;
    }

    MessageReceiver receiver = (message, consumer) -> {
        System.out.println("Id : " + message.getMessageId());
        System.out.println("Data : " + message.getData().toStringUtf8());
        consumer.ack();
    };

    Subscriber subscriber = null;
    try {
        // 使用指定的凭证构建Subscriber
        subscriber = Subscriber.newBuilder(subscriptionName, receiver)
                .setCredentialsProvider(() -> credentials)
                .build();
        subscriber.startAsync().awaitRunning();
        subscriber.awaitTerminated();
    } finally {
        if (subscriber != null) {
            subscriber.stopAsync();
        }
    }
}

在PCF环境中，你可以通过命令设置环境变量来指定凭证路径：

cf set-env YOUR_APP_NAME GOOGLE_APPLICATION_CREDENTIALS /app/credentials.json

（假设你已经把credentials.json打包到应用的根目录下）

方案二：使用Spring Cloud GCP的自动配置（更推荐） #

既然你已经引入了spring-cloud-gcp-starter-pubsub，完全可以利用Spring的自动配置来简化代码，避免手动处理凭证和Subscriber的创建。

1. 在application.properties中配置GCP相关参数：

spring.cloud.gcp.project-id=你的项目ID
spring.cloud.gcp.credentials.location=classpath:credentials.json

2. 在REST控制器中注入PubSubTemplate，用它来订阅消息：

import org.springframework.cloud.gcp.pubsub.core.PubSubTemplate;
import org.springframework.cloud.gcp.pubsub.support.BasicAcknowledgeablePubsubMessage;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class PubSubController {

    private final PubSubTemplate pubSubTemplate;

    // 构造注入PubSubTemplate，Spring会自动处理凭证加载
    public PubSubController(PubSubTemplate pubSubTemplate) {
        this.pubSubTemplate = pubSubTemplate;
    }

    @GetMapping("/start-subscribe")
    public String startSubscription() {
        this.pubSubTemplate.subscribe("你的订阅ID", message -> {
            System.out.println("收到消息ID: " + message.getHeaders().get("google_pubsub_message_id"));
            System.out.println("消息内容: " + message.getPayload());
            // 确认消息已处理
            ((BasicAcknowledgeablePubsubMessage) message).ack();
        });
        return "订阅已启动";
    }
}

这种方式的好处是Spring Cloud GCP会帮你管理Pub/Sub客户端的生命周期、凭证加载，无需手动创建Subscriber，更符合Spring Boot的开发习惯。

额外注意事项 #

• 版本兼容性：你使用的Spring Boot 2.3.2.RELEASE和spring-cloud-gcp.version 1.1.3.RELEASE可能存在版本不匹配的问题。Spring Boot 2.3.x对应的spring-cloud-gcp建议使用1.2.x.RELEASE版本，比如升级到1.2.8.RELEASE，避免潜在的兼容性问题。
• PCF网络配置：确保PCF环境能够访问Google Pub/Sub的API端点（pubsub.googleapis.com），如果有防火墙或代理，需要配置相应的出站规则。

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