nats 官网 https://nats.io/documentation/server/gnatsd-intro/
使用go get拉取
go get github.com/nats-io/gnatsd
demo代码
package main
import (
"fmt"
"github.com/nats-io/go-nats"
)
const (
natsurl="nats://192.168.2.140:4222"
natsubj="wilson"
)
var (
nconn *nats.Conn
errs error
)
func init(){
nconn, errs= nats.Connect(natsurl)
}
func main() {
go nconn.Subscribe(natsubj, func(msg *nats.Msg) {
fmt.Println("----------"+string(msg.Data)+"121")
})
go nconn.Publish(natsubj,[]byte("wilson is coming!!"))
fmt.Println("---")
for ; ; {
;
}
}