nats-server -js有錯(cuò)誤，當(dāng)我想要在nats-server -js中使用golang發(fā)布msg時(shí)，我有這樣的錯(cuò)誤：nats：沒有來自流的響應(yīng)，我想將視頻發(fā)布到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) }}如何解決此問題？提前感謝您的回復(fù)。
2 回答
皈依舞
TA貢獻(xiàn)1851條經(jīng)驗(yàn) 獲得超3個(gè)贊
代碼的問題是，您忘記添加 .您的 nats 服務(wù)器可在以下位置連接（默認(rèn)）。但是您必須添加一個(gè)流來發(fā)布并獲取數(shù)據(jù)，這是go中的代碼stream4222
_, err = js.AddStream(&nats.StreamConfig{
Name: "orders",
Subjects: []string{"ORDERS.*"},
})
有關(guān)詳細(xì)信息，請參閱文檔
慕的地6264312
TA貢獻(xiàn)1817條經(jīng)驗(yàn) 獲得超6個(gè)贊
我認(rèn)為您需要在發(fā)布函數(shù)（ORDERS.*）中指定子主題 示例：ORDERS.category，ORDERS.abc,....（不是：訂單）
這是我使用NATS STREAMING JS Pub/Sub Message的示例：
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)
}
}
- 2 回答
- 0 關(guān)注
- 166 瀏覽
添加回答
舉報(bào)
0/150
提交
取消