接收 NATS Jetstream 服务器的心跳消息的方法

目前golang学习网上已经有很多关于Golang的文章了，自己在初次阅读这些文章中，也见识到了很多学习思路；那么本文《接收 NATS Jetstream 服务器的心跳消息的方法》，也希望能帮助到大家，如果阅读完后真的对你学习Golang有帮助，欢迎动动手指，评论留言并分享~

我有一个正在运行的本地 nats 服务器，其中包含一个名为 events 的流和多个主题。

在 golang 中，我尝试使用idleheartbeat 选项向推送消费者订阅，如此处所述。

我在网上搜索了很多，但找不到接收这些心跳的方法。最初，我以为我会以常规消息的形式接收它们（正如我从这里理解的那样），但是当运行下面的代码时，我只收到我发布的消息，没有心跳。即使在收到我发布的所有消息并等待几秒钟后，没有再发送消息，也会发生这种情况。

我还需要做其他配置吗？我应该收听其他订阅或特定主题的内容吗？

我非常感谢任何关于如何在 golang 中接收这些心跳消息并以某种方式处理它们的指导。

这是我的代码：

func main() {

    url := os.Getenv("NATS_URL")
    if url == "" {
        url = nats.DefaultURL
    }

    nc, _ := nats.Connect(url)
    defer nc.Drain()

    js, _ := nc.JetStream()

    streamName := "EVENTS"

    js.AddStream(&nats.StreamConfig{
        Name:     streamName,
        Subjects: []string{"events.>"},
    })

    js.Subscribe("events.*", func(msg *nats.Msg) {
        fmt.Printf("monitor service subscribes from subject:%s\n", msg.Subject)
        fmt.Printf("received %q from my subscription\n", msg.Subject)
        msg.Ack()
    }, nats.IdleHeartbeat(1*time.Second), nats.DeliverLast(), nats.ManualAck())

    for {

    }
}

提前致谢！

正确答案

在您链接的文章中，消费者的创建和对消费者的订阅是通过 CLI 进行的。在 CLI 中，客户端仅接收所有消息，甚至是心跳。

NATS Go 客户端的工作方式有所不同。当您调用 Subscribe 函数时，它会创建一个使用者（因为您之前没有定义它）并订阅它。发布到流（和消费者）的消息将传递到您的消息处理程序，但心跳会自动处理（检查 source code）。您链接的文档中也对此进行了描述：

请注意，此心跳机制全部由受支持的客户端透明处理，不需要由应用程序处理。

总而言之，CLI 客户端显示通过订阅主题发送的所有消息，而 NATS Go 客户端会自动处理心跳，并且您在消息处理程序中看不到它们。

理论要掌握，实操不能落！以上关于《接收 NATS Jetstream 服务器的心跳消息的方法》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！