使用Java中的Google Cloud PubSub模拟器

Question

我已经设置了PubSub.builder，其根url指向本地PubSub模拟器（在我的例子中localhost:8036)。它似乎工作，我看到模拟器正在接收我的测试推送，但给我错误400错误的请求。

auth = GoogleCredential.getApplicationDefault(HTTP_TRANSPORT, JSON_FACTORY)
         .createScoped(PubsubScopes.all());
client = new Pubsub.Builder(HTTP_TRANSPORT, JSON_FACTORY, auth)
         .setApplicationName "test"
         .setRootUrl("http://localhost:8036/")
         .build();
msg = new PubsubMessage().encodeData("{\"a\": 1, \"b\": 2}".getBytes());
req = new PublishRequest().setMessages(Arrays.asList(msg));
client.projects()
  .topics()
  .publish("projects/GCLOUD-DEFAULT-PROJECT/topics/test-topic", req)
  .execute();

[pubsub] jan 27, 2016 9:03:20 PM com.google.cloud.pubsub.testing.v1.FakePubsubGrpcServer$2 operationComplete
[pubsub] INFO: Adding handler(s) to newly registered Channel.
[pubsub] jan 27, 2016 9:03:20 PM com.google.cloud.pubsub.testing.v1.NettyUtil$HttpVersionDecider channelRead
[pubsub] INFO: Detected non-HTTP/2 connection.
[pubsub] jan 27, 2016 9:03:20 PM com.google.cloud.pubsub.testing.v1.NettyUtil$HttpJsonAdapter channelRead
[pubsub] INFO: Invalid input: Expect message object but got: "\u001f�\b\u0000\u0000\u0000\u0000\u0000\u0000\u0000�V�M-.NLO-V���VJI"
[pubsub] com.google.protobuf.InvalidProtocolBufferException: Expect message object but got: "\u001f�\b\u0000\u0000\u0000\u0000\u0000\u0000\u0000�V�M-.NLO-V���VJI"
[pubsub]    at com.google.protobuf.util.JsonFormat$ParserImpl.mergeMessage(JsonFormat.java:1099)
[pubsub]    at com.google.protobuf.util.JsonFormat$ParserImpl.merge(JsonFormat.java:1075)
[pubsub]    at com.google.protobuf.util.JsonFormat$ParserImpl.merge(JsonFormat.java:973)
[pubsub]    at com.google.protobuf.util.JsonFormat$Parser.merge(JsonFormat.java:201)
[pubsub]    at com.google.cloud.pubsub.testing.v1.PubsubJsonGrpcAdapters$PublisherAdapter.handleRequest(PubsubJsonGrpcAdapters.java:231)
[pubsub]    at com.google.cloud.pubsub.testing.v1.NettyUtil$HttpJsonAdapter.channelRead(NettyUtil.java:94)
[pubsub]    at io.netty.channel.ChannelHandlerInvokerUtil.invokeChannelReadNow(ChannelHandlerInvokerUtil.java:83)

如何将com.google.apis：google-api-services-pubsub库与本地模拟器一起使用？

Answer 1

模拟器不要求或处理身份验证或授权；我猜这就是问题所在。可以尝试将null作为最后一个参数传递给生成器吗？

此外，似乎必须显式禁用Gzip压缩。请在生成器上设置这个：

.setGoogleClientRequestInitializer(new GoogleClientRequestInitializer() {
  @Override
  public void initialize(AbstractGoogleClientRequest<?> request) throws IOException {
    request.setDisableGZipContent(true);
  }
})