如何在Go中测试pubsub消息确认功能？

最近发现不少小伙伴都对Golang很感兴趣，所以今天继续给大家介绍Golang相关的知识，本文《如何在Go中测试pubsub消息确认功能？》主要内容涉及到等等知识点，希望能帮到你！当然如果阅读本文时存在不同想法，可以在评论中表达，但是请勿使用过激的措辞~

如何编写一个单元测试来验证消息是否确实被确认？

我想模拟 pubsub 消息并验证 ack 是否被调用，但不知道如何调用。

func processMessage(ctx context.Context, msg *pubsub.Message) {
    log.Printf("Processing message, data: %s", msg.Data)
    msg.Ack()
}

解决方案

您可以通过使用接口和模拟来做到这一点，如下所示。

// Create an interface that'll be implemented by *pubsub.Message
type message interface{
    Ack()
}

// Accept the interface instead of the concrete struct
func processMessage(ctx context.Context, msg message) {
    log.Printf("Processing message, data: %s", msg.Data)
    msg.Ack()
}

现在，在测试文件中，创建一条模拟消息并确认是否正在调用 ack。您可以使用 testify/mock。

终于介绍完啦！小伙伴们，这篇关于《如何在Go中测试pubsub消息确认功能？》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！