网站地图    收藏    合作   

主页 > 后台 > Golang >

golang nsq简明入门教程

来源:未知    时间:2020-01-03 23:25 作者:小飞侠 阅读:

[导读] 1.安装 https://nsq.io/deployment/installing.html 2.快速入门 在一个终端中,运行nsqlookupd 在另一个终端中,运行nsqd --lookupd-tcp-address=127.0.0.1:4160 如果想开启在web UI查看整个节点状况,可以在另一...

1.安装

https://nsq.io/deployment/installing.html

2.快速入门

在一个终端中,运行nsqlookupd
在另一个终端中,运行nsqd --lookupd-tcp-address=127.0.0.1:4160
如果想开启在web UI查看整个节点状况,可以在另一个终端中,运行nsqadmin --lookupd-http-address=127.0.0.1:4161
此时,打开http://127.0.0.1:4171,并没有任何的组件,我们首先发布一个消息到 一个topic,此时,topic未建立的,待执行发送后,会新建topic
测试发送curl -d 'hello world 1' 'http://127.0.0.1:4151/pub?topic=baoer'


image.png

topic


可以看到已经有一个topic了,但topic中的channel并不会自动创建,web页面上也会显示,没有channel,此时我们可以创建一个channel测试看一下

image.png

image.png


channel创建好了以后,消息发送后,channel可自动获取到,此时并没有消费者从channel中获取消息,我们可以写一个简易的客户端来消费channel中的消息

package mainimport (
    "fmt"
    "sync"

    "github.com/nsqio/go-nsq")func main() {
    testNSQ()}type NSQHandler struct {}func (this *NSQHandler) HandleMessage(msg *nsq.Message) error {
    fmt.Println("receive", msg.NSQDAddress, "message:", string(msg.Body))
    return nil}func testNSQ() {
    url := "127.0.0.1:4150"

    waiter := sync.WaitGroup{}
    waiter.Add(1)

    go func() {
        defer waiter.Done()
        config := nsq.NewConfig()
        config.MaxInFlight = 9

        for i := 0; i < 10; i++ {
            consumer, err := nsq.NewConsumer("baoer", "test", config)
            if nil != err {
                fmt.Println("err", err)
                return
            }

            consumer.AddHandler(&NSQHandler{})
            err = consumer.ConnectToNSQD(url)
            if nil != err {
                fmt.Println("err", err)
                return
            }
        }
        select {}
    }()

    waiter.Wait()}

这样,当有消息发送到topic中的时候,客户端就可以消费相应的消息了


image.png

两个消息队列.png


image.png

整个节点状况.png



自学PHP网专注网站建设学习,PHP程序学习,平面设计学习,以及操作系统学习

京ICP备14009008号-1@版权所有www.zixuephp.com

网站声明:本站所有视频,教程都由网友上传,站长收集和分享给大家学习使用,如由牵扯版权问题请联系站长邮箱904561283@qq.com

添加评论