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)
我该如何解决这个问题?预先感谢您的回复。
您的代码的问题是,您忘记添加一个。stream
您的 nats 服务器可以在4222
(默认)连接。但是您必须添加一个流来发布并获取数据,这是 go 中的代码
_, err = js.AddStream(&nats.StreamConfig{
Name: "orders",
Subjects: []string{"ORDERS.*"},
})
Run Code Online (Sandbox Code Playgroud)
请参阅文档了解更多信息
归档时间: |
|
查看次数: |
6818 次 |
最近记录: |