go - nats:流没有响应
问题描述
当我想在 nats-server -js 中使用 golang 发布味精时, nats-server -js 出现错误,我有这样的错误:nats: no response from stream i want to publish video to 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)
}
}
我该如何解决这个问题?提前感谢您的回复。
解决方案
我认为您需要在发布功能中指定子主题(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)
}
}
推荐阅读
- javascript - 如何返回和解析从 Firebase 服务器返回给客户端的文档?
- ubuntu - 无法在 Ubuntu 中设置颤振环境变量
- c++ - 从 6 个补丁重建一个球体
- python - 如何使用 ffmpeg-python 创建 Webm 动画图像
- c++ - 同时写入和读取哈希表
- python - 根据 Pandas DataFrame 列中的值序列查找行的索引
- java - 1 个 JFrame 中有 2 个不同大小的 JPanel
- python-3.x - 在 CentOS 8 上使用 Ansible 安装 Python 的首选方法是什么
- node.js - 如何让我的 Dicord 机器人在 Azure 上工作?
- android - 在任意点显示 MPAndroidChart Linechart X 和 Y 轴值