nats:流没有响应

mah*_*get 5 go nats-streaming-server nats.io

当我想在 nats-server -js 中使用 golang 发布消息时,nats-server -js 出现错误,我有这样的错误:nats:没有来自流的响应 我想将视频发布到 nats-server -js 这是我的 pub 文件:

    nc, _ := nats.Connect(nats.DefaultURL)

js, _ := nc.JetStream()

webcam, _ := gocv.VideoCaptureDevice(0)
img := gocv.NewMat()
defer img.Close()
for {
    webcam.Read(&img)
    _, err := js.Publish("ORDERS", img.ToBytes())
    if err != nil {
        fmt.Println(err)
    }
}
Run Code Online (Sandbox Code Playgroud)

我该如何解决这个问题?预先感谢您的回复。

Shu*_*ubh 5

您的代码的问题是,您忘记添加一个。stream您的 nats 服务器可以在4222(默认)连接。但是您必须添加一个流来发布并获取数据,这是 go 中的代码

_, err = js.AddStream(&nats.StreamConfig{
        Name:     "orders",
        Subjects: []string{"ORDERS.*"},
    })
Run Code Online (Sandbox Code Playgroud)

请参阅文档了解更多信息