zmq

Overview ¶

* 用来内部消息处理的订阅和处理，通过go 通道来实现 ,相当于内部的消息总线

	异步处理消息消费，通过go 的并发处理
	没有持久化功能,程序关闭，所有的订阅和消费都会消失。
	没有消息处理超时处理，消息消费也没有做异常处理。
  没有超时或消费异常，再次消费。