Merge branch 'dev' into v1.1.0

framework/core/infrastructure/message_queue/message_queue.go

@@ -5,7 +5,7 @@ import "git.sxidc.com/go-framework/baize/framework/core/infrastructure/message_q
 // Subscribe 订阅
 // 参数:
 // - queue: 消息队列
-// - group: 消息组
+// - group: 消息组，不同的消息组的订阅者都能收到某一个主题的消息，同一个消息组的消费者只有一个能够消费消息
 // - topic: 主题
 // - handler: 消息处理函数
 // 返回值:
@@ -17,7 +17,7 @@ func Subscribe(messageQueue common.MessageQueue, group string, topic string, han
 // UnSubscribe 取消订阅
 // 参数:
 // - queue: 消息队列
-// - group: 消息组
+// - group: 消息组，不同的消息组的订阅者都能收到某一个主题的消息，同一个消息组的消费者只有一个能够消费消息
 // - topic: 主题
 // 返回值:
 // - 错误