一、确认nats开启jstream
nats的启动命令应该为 nats-server -js
-js表示开启jstream
二、nats stream添加stream和subject
在nats安装服务器,运行nats stream add命令,
Stream Name选择自己代码中消费者配置的stream名称
sub, err := js.PullSubscribe("", "", nats.BindStream("streamname"))
Subjects选择自己消息发送的主题
msg := &nats.Msg{Subject: "subjectname",Header: make(nats.Header),Data: []byte("Hello nats"),
}
_, err = js.PublishMsg(msg)
其余的选项直接回车即可。
以上为nats服务端命令行添加,只需要执行一次,也可以在代码中添加。
_, err = js.AddStream(&nats.StreamConfig{Name: "",Subjects: []string{""}, })
推荐在服务器上执行