这是基于nsq的一个封装，能方便的基于nsq构筑一个服务系统。
借鉴（抄袭）了rafaeljesus/nsq-event-bus。
import "github.com/LYY/nsqs"
config := &nsqs.SimpleConfig{}
// 初始化
nsqs.InitConfig(config)
// 注册监听
nsqs.Register("test_topic", "test_channel", testFunc, 10)
// 运行server
nsqs.Run()其中testFunc为一个符合func (m *nsq.Message) error的方法。
方法返回error的时候或者panic的时候会自动重试。
nsqs.PostTopic("topic", payload)例如，与echo共用
import "github.com/LYY/nsqs"
e := echo.New()
config := &nsqs.SimpleConfig{}
// 初始化
nsqs.InitConfig(config)
// 注册监听
nsqs.Register("test_topic", "test_channel", testFunc, 10)
// 启动nsqs
nsqs.Start()
// 等待echo退出
quit := make(chan os.Signal)
signal.Notify(quit, syscall.SIGUSR1, syscall.SIGINT, syscall.SIGTERM)
<-quit
// 停止nsqs，并等待执行完成
nsqs.Stop()
// echo退出
e.Shutdown(ctx)