通过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("连接失…

前提 安装好docker 安装好docker-compose 机器 192.168.0.101 主节点 192.168.0.102 子节点 开放端口 4150 nsqd端口 TCP 4151 nsqd端口 HTTP 4160 nsqlookupd端口 子节点通讯端口 4161 nsqlookupd端口 消费者通讯端口 4171 管理端口 主节点 docker-compose.yml version: '2' services: nsqlookupd: image: nsqio/nsq command: /nsqlookupd networks: – nsq-network hostname: nsqlookupd ports: – "4161:4161" – "4160:4160" nsqd: image: nsqio/nsq command: /nsqd –lookupd-tcp-address=nsqlookupd:4160 -broadcast-address=192.168.0.101 # command: /nsq…