mongo数据库增加是否重缓存查询数据，增加随机修改删除状态接口；redis增加-队列消息读取封装方法

redis/redis.go

@@ -81,7 +81,7 @@ func GetReadStream(ctx context.Context, msg ...QueueMessage) error {
 	return nil
 }
 
-// GetReadFromStream 读取ReadFromStream数据
+// GetReadFromStream  读取ReadFromStream数据
 func GetReadFromStream(ctx context.Context, streamKey, groupName, consumerName string, count, blockMs int64, Block bool, fn func(ctx context.Context, message map[string]interface{}) error) (err error) {
 	glog.Infof(ctx, "初始化 Stream: %s, 消费者组: %s", streamKey, groupName)
 	err = InitStreamGroup(ctx, streamKey, groupName)