nats-server -js有錯誤，當我想要在nats-server -js中使用golang發布msg時，我有這樣的錯誤：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) }}如何解決此問題？提前感謝您的回復。
2 回答
皈依舞
TA貢獻1851條經驗 獲得超3個贊
代碼的問題是，您忘記添加 .您的 nats 服務器可在以下位置連接（默認）。但是您必須添加一個流來發布并獲取數據，這是go中的代碼stream4222
_, err = js.AddStream(&nats.StreamConfig{
Name: "orders",
Subjects: []string{"ORDERS.*"},
})
有關詳細信息，請參閱文檔
慕的地6264312
TA貢獻1817條經驗 獲得超6個贊
我認為您需要在發布函數（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 關注
- 152 瀏覽
添加回答
舉報
0/150
提交
取消