golang-nsq消息队列应用

1. 安装nsq

brew install nsq

2.启动nsq

https://nsq.io/overview/quick_start.html

3.golang client

var producer *nsq.Producer

var consumer *nsq.Consumer

type t struct {

}

func (this *t)HandleMessage(message *nsq.Message) error{

    fmt.Println(string(message.Body))

    return nil

}

func init()  {

    producer,_ = nsq.NewProducer("127.0.0.1:4150",nsq.NewConfig()) // 初始化生产者

    consumer,_ = nsq.NewConsumer("fwd","ch1",nsq.NewConfig())

    consumer.AddHandler(new(t))

    consumer.ConnectToNSQD("127.0.0.1:4150")

}

func main() {

    go func() {

    }()

    for{

        time.Sleep(time.Second)

        producer.Publish("fwd",[]byte("哈哈哈哈哈"))

    }

}

输出:

2018/07/30 12:14:27 INF 2 [fwd/ch1] (127.0.0.1:4150) connecting to nsqd
2018/07/30 12:14:28 INF 1 (127.0.0.1:4150) connecting to nsqd
哈哈哈哈哈
哈哈哈哈哈
哈哈哈哈哈