Spring Cloud StreamBridge集成多GCP PubSub遇Binder缺失问题求助

1. 补全核心依赖 #

确保项目同时引入Spring Cloud Stream核心依赖与PubSub Stream Binder，在pom.xml中添加：

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-stream</artifactId>
</dependency>
<dependency>
    <groupId>com.google.cloud</groupId>
    <artifactId>spring-cloud-gcp-pubsub-stream-binder</artifactId>
</dependency>

同时通过dependencyManagement锁定兼容版本（Spring Boot 2.7.3对应Spring Cloud 2021.0.x）：

<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>2021.0.5</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
        <dependency>
            <groupId>com.google.cloud</groupId>
            <artifactId>spring-cloud-gcp-dependencies</artifactId>
            <version>3.3.0</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

2. 完善多Binder配置 #

每个Google PubSub集群需配置独立的Binder实例，明确指定Binder实现类、项目ID和凭证路径：

# 第一个PubSub集群的Binder配置
spring.cloud.stream.binders.pubsub-gcp-1.type=pubsub
spring.cloud.stream.binders.pubsub-gcp-1.class=com.google.cloud.spring.stream.binder.pubsub.PubSubMessageChannelBinder
spring.cloud.stream.binders.pubsub-gcp-1.environment.spring.cloud.stream.gcp.pubsub.project-id=你的项目ID1
spring.cloud.stream.binders.pubsub-gcp-1.environment.spring.cloud.stream.gcp.pubsub.credentials.location=classpath:service-account-1.json

# 第二个PubSub集群的Binder配置（示例）
spring.cloud.stream.binders.pubsub-gcp-2.type=pubsub
spring.cloud.stream.binders.pubsub-gcp-2.class=com.google.cloud.spring.stream.binder.pubsub.PubSubMessageChannelBinder
spring.cloud.stream.binders.pubsub-gcp-2.environment.spring.cloud.stream.gcp.pubsub.project-id=你的项目ID2
spring.cloud.stream.binders.pubsub-gcp-2.environment.spring.cloud.stream.gcp.pubsub.credentials.location=classpath:service-account-2.json

3. 修正输出绑定配置 #

将输出通道与对应Binder关联，无需预定义output-bindings（StreamBridge可直接使用绑定名发送）：

# 绑定到第一个PubSub集群的输出通道
spring.cloud.stream.bindings.update-out-0.binder=pubsub-gcp-1
spring.cloud.stream.bindings.update-out-0.destination=abc

# 绑定到第二个PubSub集群的输出通道（示例）
spring.cloud.stream.bindings.notify-out-0.binder=pubsub-gcp-2
spring.cloud.stream.bindings.notify-out-0.destination=def

4. 验证StreamBridge调用 #

确保调用时使用的绑定名与配置完全一致：

// 发送到第一个PubSub集群
streamBridge.send("update-out-0", data);

// 发送到第二个PubSub集群（示例）
streamBridge.send("notify-out-0", otherData);

5. 排查常见错误点 #

• 检查credentials.location格式：用classpath:加载项目内凭证，file:加载本地文件，确保文件存在且权限正常。
• 确认项目ID与Google Cloud控制台完全匹配，无拼写错误。
• 若项目中同时存在Kafka和PubSub Binder，需确保每个输出/输入通道明确指定对应的binder属性，避免自动绑定冲突。

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