通过HTTP方式提交 生产 消息 使用GO SDK方式通过TCP提交消息和消费消息 直接上代码了 package main import ( "fmt" "github.com/nsqio/go-nsq" "io/ioutil" "log" "strconv" "time" ) var nullLogger = log.New(ioutil.Discard, "", log.LstdFlags) var nsqAddr = "192.168.0.101:4150" var nsqTopic = "test" // 生产者 func sendMessage() { config := nsq.NewConfig() // 1. 创建生产者 producer, err := nsq.NewProducer(nsqAddr, config) if err != nil { log.Fatalln("连接失…