在 Kubernetes 中轻松测试 NATS 流

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

我想在 kubernetes 上测试一个非常基本的 nats 流应用程序。为此，我遵循了官方 nats 文档中的命令。

它基本上归结为跑步

kubectl apply -f https://raw.githubusercontent.com/nats-io/k8s/master/nats-server/single-server-nats.yml
kubectl apply -f https://raw.githubusercontent.com/nats-io/k8s/master/nats-streaming-server/single-server-stan.yml

在可以访问集群的终端中（在我的例子中它是一个种类集群）。

我使用 stan.go 作为 nats 流客户端。这是我尝试连接到 nats-streaming-server 的代码：

package main

import stan "github.com/nats-io/stan.go"

func main() {
    sc, err := stan.connect("stan", "test-client")

    if err != nil {
        panic(err)
    }
    if err := sc.publish("test-subject", []byte("this is a test-message!")); err != nil {
        panic(err)
    }
}

这是我收到的错误：

panic: nats: no servers available for connection

goroutine 1 [running]:
main.main()
    /Users/thilt/tmp/main.go:9 +0x15d
exit status 2

所以我认为集群使用了另一个名称或其他名称。如果我将提供的示例与上面 docs.nats-link 中的 nats-box 一起使用，它也不起作用！我哪里出错了？

如果需要，我很乐意提供更多信息。

正确答案

有一个great example in stan.go docs：

// connect to nats
nc, err := nats.connect(url, opts...)
if err != nil {
    log.fatal(err)
}
defer nc.close()

sc, err := stan.connect(clusterid, clientid, stan.natsconn(nc))
if err != nil {
    log.fatalf("can't connect: %v.\nmake sure a nats streaming server is running at: %s", err, url)
}
defer sc.close()

发生错误是因为默认情况下 stan 连接到本地主机地址 (source code)：

// defaultnatsurl is the default url the client connects to
defaultnatsurl = "nats://127.0.0.1:4222"

请注意，上面提供的示例会覆盖此默认连接。

stan 源代码简短且易于分析。我强烈建议您尝试分析它并弄清楚它的作用。

现在让我们把它们放在一起；这是一个工作示例：

package main

import (
    nats "github.com/nats-io/nats.go"
    stan "github.com/nats-io/stan.go"
)

func main() {
    // Create a NATS connection 
    nc, err := nats.Connect("nats://nats:4222")
    if err != nil {
        panic(err)
    }

    // Then pass it to the stan.Connect() call.
    sc, err := stan.Connect("stan", "me", stan.NatsConn(nc))
    if err != nil {
        panic(err)
    }
    if err := sc.Publish("test-subject", []byte("This is a test-message!")); err != nil {
        panic(err)
    }
}

好了，本文到此结束，带大家了解了《在 Kubernetes 中轻松测试 NATS 流》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！