文章 39
评论 417
浏览 59946
高性能消息队列NSQ---GO--demo

高性能消息队列NSQ---GO--demo

前言   关于NSQ是什么,NSQ是做什么的,怎么启动,网上的资料太多太多,详情请移步分布式实时消息平台NSQ,里面讲的很详细,还附带demo。 客户端/生产者(producer)   NSQ发送消息非常简单,分两步完成: 创建Producer实例 调用Publish发送一个新的消息到指定的topic中 具体实现如下所示 func main(){ cfg := nsq.NewConfig() nsqd := "127.0.0.1:4150" producer, err := nsq.NewProducer(nsqd, cfg) if err != nil { log.Fatal(err) } if err := producer.Publish("test", []byte("Hello NSQ")); err != nil { log.Fatal("publish error:" + err.Error()) } } 服务端/消费者(consumer)   消费者用于接收指定topic中的消息,实现需分为3步: 调用NewConsumer为指定的主题/渠道创建消费者的新实例 ....

凡打不倒我的,必使我强大!!!—— 墨殇的技术博客