0
点赞
收藏
分享

微信扫一扫

nats

unadlib 2022-06-20 阅读 42

nats 官网 ​​https://nats.io/documentation/server/gnatsd-intro/​​

使用go get拉取
go get ​​​github.com/nats-io/gnatsd​​​nats_官网

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


举报

相关推荐

0 条评论