使用 Azure SDK 中适用于 Golang v0.3.1 的工具，设置消费者以监听 Azure 服务总线上的消息

一分耕耘，一分收获！既然打开了这篇文章《使用 Azure SDK 中适用于 Golang v0.3.1 的工具，设置消费者以监听 Azure 服务总线上的消息》，就坚持看下去吧！文中内容包含等等知识点...希望你能在阅读本文后，能真真实实学到知识或者帮你解决心中的疑惑，也欢迎大佬或者新人朋友们多留言评论，多给建议！谢谢！

我一直在使用模块 azure-sdk-for-go/sdk/messaging/azservicebus v0.3.1 将我的消费者与 azure 服务总线连接，但实现的代码仅接收固定数量的消息，然后停止应用程序我想让消费者继续监听队列。按照我的代码：

client, err := azservicebus.NewClientFromConnectionString("Connection String", nil)
    
    if err != nil {
        log.Fatalf("Failed to create Service Bus Client: %s", err.Error())
    }

    receiver, err := client.NewReceiverForQueue("queue", nil)

    if err != nil {
        log.Fatalf("Failed to create Consumer: %s", err.Error())
    }

    messages, err := receiver.ReceiveMessages(context.TODO(), 10, nil)

    if err != nil {
        log.Fatalf("Failed to receive Messages: %s", err.Error())
    }

    for _, message := range messages {

        body, err := message.Body()

        if err != nil {
            log.Fatalf("Failed to parse message body: %s", err.Error())
        }

        fmt.Println("Message --->", string(body))

        err = receiver.CompleteMessage(context.TODO(), message)

        if err != nil {
            log.Fatalf("Failed to complete message: %s", err.Error())
        }

        fmt.Printf("Received and completed message\n")

    }

正确答案

您已经完成了 99% 的代码 - 正如您所指出的 receivemessages 仅返回您请求的金额。

因此，您只想将逻辑包装在循环中，以便可以连续运行它：

for {
    messages, err := receiver.ReceiveMessages(context.TODO(), 10, nil)
    if err != nil {
        log.Fatalf("Failed to receive Messages: %s", err.Error())
    }

    for _, message := range messages {
        body, err := message.Body()

        if err != nil {
            log.Fatalf("Failed to parse message body: %s", err.Error())
        }

        fmt.Println("Message --->", string(body))

        err = receiver.CompleteMessage(context.TODO(), message)

        if err != nil {
            log.Fatalf("Failed to complete message: %s", err.Error())
        }
    }
}

顺便说一句，0.3.2 刚刚发布，它包含一些您可能感兴趣的修复，因为它们确实会影响 receivemessages。

到这里，我们也就讲完了《使用 Azure SDK 中适用于 Golang v0.3.1 的工具，设置消费者以监听 Azure 服务总线上的消息》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！