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 ; ;  {
    ;
  }
}