consul注册客户端.

nsq客户端，目前只实现了消息的发送，使用FAN-OUT模型mainChan为主chan为发现的每个nsqd启动一个go routine，从mainCh 读取读取数据并且写入子routine的inCh(带缓冲默认128) /----- nsq_publisher.publish(inCh)mainChan --- ------ nsq_publisher.publishAsync(inCh) \----- nsq_publisher.publishMultiAsync(inCh).

rocket 对producer和consumer进行了封装实现了线程安全.