一、确认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{""},
})

推荐在服务器上执行