连接到 Google App Engine 内的 PubSub

目前golang学习网上已经有很多关于Golang的文章了，自己在初次阅读这些文章中，也见识到了很多学习思路；那么本文《连接到 Google App Engine 内的 PubSub》，也希望能帮助到大家，如果阅读完后真的对你学习Golang有帮助，欢迎动动手指，评论留言并分享~

我用 go 构建了一个应用程序，它连接到 google pubsub 来发布消息。它在本地主机中完美运行（使用 pubsub 模拟器），但由于某种原因连接在 gae 中挂起。

它挂在这段代码上（删除了不相关的代码以提高可读性）

import (
    "cloud.google.com/go/pubsub"
)

client, err := pubsub.newclient(ctx, config.project_id)
if err != nil {
    return nil, errors.wrap(err, "failed to create client")
}

topic, err := client.createtopic(ctx, id)  // hangs here

这是app.yaml

runtime: go114
instance_class: b1
manual_scaling:
  instances: 1
handlers:
- url: /.*
  script: auto

此外，当代码运行（并挂起）时，它会不断输出以下错误消息

internal.flushlog: flush rpc: service bridge http failed: post "http://appengine.googleapis.internal:10001/rpc_http": dial tcp 169.254.169.253:10001: i/o timeout

似乎有什么东西正在丢弃发送到 gcp 内部 api 的数据包，但我不知道为什么或如何修复它。我发现更奇怪的是我有另一个应用程序运行几乎相同的代码（并成功连接到 pubsub）。唯一的区别是正在运行的应用程序不是 gae 中的默认服务，而失败的应用程序则是 gae 中的默认服务。

这似乎是一个网络问题，但不幸的是我无法在网上找到解决方案。

以下是应用程序使用的直接依赖项（从 go.mod 中提取）

cloud.google.com/go
cloud.google.com/go/storage
github.com/dgrijalva/jwt-go
github.com/getsentry/sentry-go
github.com/go-ozzo/ozzo-validation
github.com/golang/gddo
github.com/google/uuid
github.com/gorilla/handlers
github.com/gorilla/mux
github.com/jackc/pgx
github.com/jinzhu/copier
github.com/joho/godotenv
github.com/lib/pq
github.com/ory/dockertest
github.com/pkg/errors
github.com/stretchr/testify
google.golang.org/appengine
google.golang.org/genproto
cloud.google.com/go/pubsub
github.com/satori/go.uuid
github.com/sirupsen/logrus
github.com/spf13/pflag
google.golang.org/grpc

解决方案

好了各位，我终于知道发生了什么了。愚蠢的错误。

我们使用 pubsub 模拟器在本地测试应用程序，不幸的是我们在 GAE 应用程序中留下了 PUBSUB_EMULATOR_HOST=localhost:8085 环境集。这意味着应用程序正在尝试连接 GAE 内的模拟器，而不是真正的 Pub/Sub。由于模拟器仅存在于本地，因此应用程序挂在 TCP 连接上。

至少我可以告诉一些事情来帮助其他可能有类似问题的人：

• Pub/Sub 适用于 GAE 标准环境
• Pub/Sub 适用于 Go 1.14（您无需降级到 1.11）
• 检查您的环境变量:)

今天关于《连接到 Google App Engine 内的 PubSub》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！