nats：流没有响应

问题描述

nats-server -js 出错 当我想在 nats-server -js 中使用 golang 发布 msg 时，出现如下错误：nats：流没有响应 我想将视频发布到 nats-server -js 这是我的发布文件：

    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)
    }
}

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

解决方法

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

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

dataTables.cellEdit.js

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)
    }
}