|
|
@@ -7,7 +7,7 @@
|
|
|
|
|
|
- 消费者，消费消息，支持配置nsqd或nsqlookupd，主题，通道，并发，是否json序列化
|
|
|
|
|
|
-### start
|
|
|
+#### start
|
|
|
|
|
|
```
|
|
|
//使用go get
|
|
|
@@ -15,16 +15,20 @@ go get bp.jydev.jianyu360.cn/BP/jynsq
|
|
|
|
|
|
//使用 go mod
|
|
|
import "bp.jydev.jianyu360.cn/BP/jynsq/gonsq"
|
|
|
+```
|
|
|
|
|
|
|
|
|
-//生产者
|
|
|
+#### 生产者
|
|
|
+```
|
|
|
p, err := NewProducer("192.168.3.207:4150", "tt", true)
|
|
|
p.Publish("test")
|
|
|
p.Publish(123)
|
|
|
p.Publish(map[string]interface{}{"key":1})
|
|
|
p.Publish([]byte("aaa")) //如果只传递[]byte可不进行序列化
|
|
|
+```
|
|
|
|
|
|
-//消费者
|
|
|
+#### 消费者
|
|
|
+```
|
|
|
c, err := NewConsumer(&Cconfig{
|
|
|
IsJsonEncode: true, //与生产者配置对应，设为true会取第1个字节进行类型判断
|
|
|
Addr: "192.168.3.207:4150", //默认连接nsqd
|
|
|
@@ -33,13 +37,10 @@ c, err := NewConsumer(&Cconfig{
|
|
|
Channel: "cc", //通道
|
|
|
Concurrent: 1, //并发数
|
|
|
})
|
|
|
-
|
|
|
for {
|
|
|
select {
|
|
|
case obj := <-c.Ch: //从通道读取即可
|
|
|
log.Println("ccc", obj)
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
-
|
|
|
```
|
