NSQ记录
特性
开始
安装
cd /usr/local/src
wget https://s3.amazonaws.com/bitly-downloads/nsq/nsq-1.2.0.linux-amd64.go1.12.9.tar.gz
tar -zxf nsq-1.2.0.linux-amd64.go1.12.9.tar.gz
mv nsq-1.2.0.linux-amd64.go1.12.9 /usr/local/nsq
## 将/usr/local/nsq/bin加入环境变量
配置文件
cd /usr/local/nsq
mkdir conf
cd conf
mkdir /data/nsq
vim nsqd.cfg
1、nsqd.cfg
tcp_address="172.16.0.182:4150"
http_address="172.16.0.182:4151"
nsqlookupd_tcp_addresses = [
"172.16.0.182:4160"
]
broadcast_address="172.16.0.182"
data_path="/data/nsq/"
msg_timeout="10m"
2、nsqlookupd.cfg
tcp_address="172.16.0.182:4160"
http_address="172.16.0.182:4161"
启动
nsqlookupd -config=/usr/local/nsq/conf/nsqlookupd.cfg &
nsqd -config=/usr/local/nsq/conf/nsqd.cfg &
nsqadmin -lookupd-http-address=172.16.0.182:4161
源码
config := nsq.NewConfig()
//最大允许向两台NSQD服务器接受消息,默认是1,要特别注意
config.MaxInFlight=2
c1, err1 := nsq.NewConsumer("test", "test-channel1", nsq.NewConfig()) // 新建一个消费者
nsq requeue and backoff