# jynsq  
> nsq工具类

### 实现功能  

- 生产者，发布消息，支持配置nsqd地址，主题，是否json序列化（默认不序列化）

- 消费者，消费消息，支持配置nsqd或nsqlookupd，主题，通道，并发，是否json序列化

#### start

```
//使用go get
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) //nsqd地址，主题，是否进行json序列化与消费都配置对应、否则[]byte截取出错
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
	ConnectType:  0,//默认连接nsqd
	Topic:        "tt", //主题
	Channel:      "cc", //通道
	Concurrent:   1,    //并发数
})
for {
	select {
	case obj := <-c.Ch:  //从通道读取即可
		log.Println("ccc", obj)
	}
}
```


### docker启动nsq 
- 在docker目录有 docker-compose.yml 文件，直接下载启动 `docker-compose up -d`   
  
> 一个nsqd 一个nsqlookupd 一个nsqadmin，如果需要增加nsqd直接单独启nsqd即可，使用docker时用消费者连nsqlookupd返回的是docker内部地址，连接有问题