1. 生产者

运行Nsq服务集群

首先启动nsqlookud，在一个shell中，开始nsqlookupd：

$ nsqlookupd

在另一个shell中，开始nsqd：

$ nsqd —lookupd-tcp-address=127.0.0.1:4160

在另一个shell中，开始nsqadmin：

$ nsqadmin —lookupd-http-address=127.0.0.1:4161

发布初始消息（也在集群中创建主题）：

$ curl -d 'hello world 1' 'http://127.0.0.1:4151/pub?topic=test'

最后，在另一个shell中，开始nsq_to_file：

$ nsq_to_file —topic=test —output-dir=/tmp —lookupd-http-address=127.0.0.1:4161

验证事物按预期工作，在Web浏览器中打开http://127.0.0.1:4171/ 以查看nsqadminUI并查看统计信息。另外，检查test.*.log写入的日志文件（）的内容/tmp。

链接nsq 并创建生产者：

  1. package main
  3. import (
  4.     "fmt"
  6.     nsq "github.com/nsqio/go-nsq"
  7. )
  9. func main() {
  10.     // 定义nsq生产者
  11.     var producer *nsq.Producer
  12.     // 初始化生产者
  13.     // producer, err := nsq.NewProducer("地址:端口", nsq.*Config )
  14.     producer, err := nsq.NewProducer("127.0.0.1:4150", nsq.NewConfig())
  15.     if err != nil {
  16.         panic(err)
  17.     }
  19.     err = producer.Ping()
  20.     if nil != err {
  21.         // 关闭生产者
  22.         producer.Stop()
  23.         producer = nil
  24.     }
  26.     fmt.Println("ping nsq success")
  27. }

生产者创建topic并写入nsq：

  1. package main
  3. import (
  4.     "fmt"
  6.     nsq "github.com/nsqio/go-nsq"
  7. )
  9. func main() {
  10.     // 定义nsq生产者
  11.     var producer *nsq.Producer
  12.     // 初始化生产者
  13.     // producer, err := nsq.NewProducer("地址:端口", nsq.*Config )
  14.     producer, err := nsq.NewProducer("127.0.0.1:4150", nsq.NewConfig())
  15.     if err != nil {
  16.         panic(err)
  17.     }
  19.     err = producer.Ping()
  20.     if nil != err {
  21.         // 关闭生产者
  22.         producer.Stop()
  23.         producer = nil
  24.     }
  26.     // 生产者写入nsq,10条消息，topic = "test"
  27.     topic := "test"
  28.     for i := 0; i < 10; i++ {
  29.         message := fmt.Sprintf("message:%d", i)
  30.         if producer != nil && message != "" { //不能发布空串，否则会导致error
  31.             err = producer.Publish(topic, []byte(message)) // 发布消息
  32.             if err != nil {
  33.                 fmt.Printf("producer.Publish,err : %v", err)
  34.             }
  35.             fmt.Println(message)
  36.         }
  37.     }
  39.     fmt.Println("producer.Publish success")
  41. }