msgqueue

type NATSConsumer struct {
	CallBack func(msg *nats.Msg) //处理消息的回调函数
	// contains filtered or unexported fields
}

type NATSProducer struct {
	ServerUrls string //消息队列服务地址，多个用","分割  例如 "nats://192.168.168.195:4222，nats://192.168.168.195:4223"

	Subject string //主题
}

type QcpConsumer struct {
	NATSConsumer
}