go - nats：流没有响应

Question

当我想在 nats-server -js 中使用 golang 发布味精时， nats-server -js 出现错误，我有这样的错误：nats: no response from stream i want to publish video to 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)
    }
}

我该如何解决这个问题？提前感谢您的回复。

Answer 1

我认为您需要在发布功能中指定子主题（ORDERS.*）示例：ORDERS.category、ORDERS.abc、....（不是：ORDERS）

这是我的 NATS STREAMING JS Pub/Sub 消息示例：

在此处输入图像描述

package main

import (
    "fmt"
    "github.com/test/global"
    "github.com/nats-io/nats.go"
)

func main() {
    nc, err := nats.Connect(global.GetURL())
    if err != nil {
        fmt.Println(err)
    }
    js, err := nc.JetStream()
    if err != nil {
        fmt.Println(err)
    }
    _, err = js.Publish("ORDERS.abc", []byte("abc"))
    if err != nil {
        fmt.Println(err)
    }
}