|
|
@@ -20,7 +20,7 @@ import "bp.jydev.jianyu360.cn/BP/jynsq/gonsq"
|
|
|
|
|
|
#### 生产者
|
|
|
```
|
|
|
-p, err := NewProducer("192.168.3.207:4150", "tt", true)
|
|
|
+p, err := NewProducer("192.168.3.207:4150", "tt", true) //nsqd地址，主题，是否进行json序列化与消费都配置对应、否则[]byte截取出错
|
|
|
p.Publish("test")
|
|
|
p.Publish(123)
|
|
|
p.Publish(map[string]interface{}{"key":1})
|
