如何解决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 消息的示例:
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)
}
}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。