Java客户端作为SBT依赖调用Cloud Pub/Sub发布消息超时如何解决？

该问题是Maven包引入SBT项目后出现的阻塞/超时，核心原因集中在依赖版本冲突、类加载器异常、线程池冲突三个方向，对应解决方法如下：

1. 强制对齐依赖版本 #

Google Pub/Sub Java客户端强依赖Guava、gRPC、Protobuf等公共组件，SBT（尤其是Play框架）项目通常会自带这些组件的内置版本，版本不兼容会导致底层发送链路初始化失败，线程无响应，进而触发超时或无限阻塞。

你需要在SBT项目的build.sbt中添加依赖强制覆盖配置，对齐Pub/Sub客户端v1.108.1对应的依赖版本：

dependencyOverrides ++= Seq(
  "com.google.guava" % "guava" % "31.1-jre",
  "io.grpc" % "grpc-netty-shaded" % "1.49.0",
  "io.grpc" % "grpc-protobuf" % "1.49.0",
  "io.grpc" % "grpc-stub" % "1.49.0",
  "com.google.protobuf" % "protobuf-java" % "3.21.7"
)

配置完成后执行sbt clean reload update重新拉取依赖。

2. 修复类加载器异常 #

SBT/Play运行时会使用自定义类加载器实现热部署等能力，会导致gRPC的SPI服务提供者加载逻辑找不到对应实现类，发送链路初始化失败。

在你初始化Publisher的方法开头，手动设置当前线程的上下文类加载器为Pub/Sub客户端使用的类加载器即可：

public static Publisher getPublisher(String projectId, String topicId) throws IOException {
    // 新增这一行，手动指定类加载器
    Thread.currentThread().setContextClassLoader(Publisher.class.getClassLoader());
    TopicName topicName = TopicName.of(projectId, topicId);
    return Publisher.newBuilder(topicName).build();
}

3. 显式指定独立线程池 #

默认情况下Publisher会使用JVM全局的共享线程池，可能和SBT/Play项目的线程池配置产生冲突，你可以显式给Publisher分配独立的线程池，完全隔离执行环境：

public static Publisher getPublisher(String projectId, String topicId) throws IOException {
    Thread.currentThread().setContextClassLoader(Publisher.class.getClassLoader());
    TopicName topicName = TopicName.of(projectId, topicId);
    // 创建独立的调度线程池给Publisher专用
    ScheduledExecutorService publisherExecutor = Executors.newScheduledThreadPool(4);
    return Publisher.newBuilder(topicName)
            .setExecutorProvider(FixedExecutorProvider.create(publisherExecutor))
            .build();
}

4. 排查底层异常 #

如果以上操作后问题仍然存在，开启com.google.cloud.pubsub和io.grpc包的DEBUG日志，查看初始化阶段是否有Credentials加载失败、网络连接被拒绝等底层异常，这类异常通常会被Future的超时逻辑吞掉，不会直接抛出。

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