Installing

# install nsq (see https://nsq.io/deployment/installing.html)
brew install nsq

# start nsqlookup daemon
nsqlookupd

# start nsq daemon
nsqd --lookupd-tcp-address=127.0.0.1:4160 --broadcast-address=127.0.0.1

# (optional) start browser-based admin ui at http://127.0.0.1:4171
nsqadmin --lookupd-http-address=127.0.0.1:4161

# (optional) dump messages to file (automatically creates `test` topic)
nsq_to_file --topic=test --output-dir=/tmp --lookupd-http-address=127.0.0.1:4161

# send messages to `test` topic
curl -d 'test 1' 'http://127.0.0.1:4151/pub?topic=test'
curl -d 'test 2' 'http://127.0.0.1:4151/pub?topic=test'
curl -d 'test 3' 'http://127.0.0.1:4151/pub?topic=test'
curl -d 'test 4' 'http://127.0.0.1:4151/pub?topic=test'
curl -d 'test 5' 'http://127.0.0.1:4151/pub?topic=test'

# install dependencies
go get github.com/nsqio/go-nsq

Testing

# run nsq subscriber (use `nsq-subscriber/tail.go` with TailHandler)
go run nsq-subscriber/main.go nsq-subscriber/disk.go

# run http server
go run http-server/main.go http-server/nsq.go http-server/page.go

# visit normal route http://localhost:4001/view/asdf
# visit nsq publisher route http://localhost:4001/nsq

# if http-server refuses to quit...
netstat -vanp tcp | grep 4001 # OR `sudo lsof -i tcp:4001`
kill -9 <pid>

jordanpatton/go-nsq-sandbox

Installing

Testing

Links