如何使用 GCP 在 pubsub 模型中一次向所有订阅者发送消息

来到golang学习网的大家，相信都是编程学习爱好者，希望在这里学习Golang相关编程知识。下面本篇文章就来带大家聊聊《如何使用 GCP 在 pubsub 模型中一次向所有订阅者发送消息》，介绍一下，希望对大家的知识积累有所帮助，助力实战开发！

使用google云平台实现pubsub模型，并使用函数创建主题、订阅者、发布和拉取消息函数。

func pullMsgs(projectID, subID string, jsonPath string) error {
    ctx := context.Background()
    client, err := pubsub.NewClient(ctx, projectID, option.WithCredentialsFile(jsonPath))
    if err != nil {
        return fmt.Errorf("pubsub.NewClient: %v", err)
    }

    // Consume 10 messages.
    var mu sync.Mutex
    received := 0
    sub := client.Subscription(subID)
    cctx, cancel := context.WithCancel(ctx)
    err = sub.Receive(cctx, func(ctx context.Context, msg *pubsub.Message) {
        mu.Lock()
        defer mu.Unlock()
        // fmt.Fprintf(w, "Got message: %q\n", string(msg.Data))
        fmt.Println("Got message: n", string(msg.Data))
        msg.Ack()
        received++
        if received == 10 {
            cancel()
        }
    })
    if err != nil {
        return fmt.Errorf("Receive: %v", err)
    }
    return nil
}

pullmsg 函数使用订阅 id 从发布者处获取已发布的消息。 假设该模型有 3 个特定主题的订阅者。如果发布者发布了该主题的消息。 pullmsg 函数必须执行 3 次才能为所有订阅者获取该消息。是否有任何方法可以一次向所有订阅者获取已发布的消息。

解决方案

我不明白你为什么要同时提取 3 个订阅。因为这些消息可能不会同时/大约同时到达。因此，如果您想合并这些消息，您的代码必须等到收到所有消息。这并不是 Pub/Sub 的真正目的。另一方面，如果您不想想要合并这三个消息，我建议您为每个订阅创建一段单独的代码。

话虽这么说，您可以使用同步拉取机制或异步拉取机制来拉取所有消息。如果您不希望代码阻塞，以便它基本上同时侦听所有订阅，则可以使用异步拉取。

代码流程可以是：

• 创建非阻塞订阅者函数。
• 当 x 条消息到达时，让这个拉取函数停止（打破 while 循环）。
• 创建该函数的三个实例，并传递三个主题 ID。
• 创建另一个函数供您处理。

更多信息请拨打here。

今天关于《如何使用 GCP 在 pubsub 模型中一次向所有订阅者发送消息》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！