diff --git a/CoreCms.Net.Core/Config/RedisMessageQueueSetup.cs b/CoreCms.Net.Core/Config/RedisMessageQueueSetup.cs
index 33499b9a..57532c5c 100644
--- a/CoreCms.Net.Core/Config/RedisMessageQueueSetup.cs
+++ b/CoreCms.Net.Core/Config/RedisMessageQueueSetup.cs
@@ -23,6 +23,21 @@ namespace CoreCms.Net.Core.Config
         {
             if (services == null) throw new ArgumentNullException(nameof(services));
 
+            var dbIndex = 0;
+            var ConnectionString = AppSettingsConstVars.RedisConfigConnectionString;
+            if (!string.IsNullOrEmpty(ConnectionString))
+            {
+                var arr = ConnectionString.ToLower().Split(',');
+                if (arr.Length > 1)
+                {
+                    var defaultDataBaseStr = arr.FirstOrDefault(p => p.Contains("defaultdatabase"));
+                    if (!string.IsNullOrEmpty(defaultDataBaseStr))
+                    {
+                        dbIndex = defaultDataBaseStr.Split('=').LastOrDefault("0").ObjToInt(0);
+                    }
+                }
+            }
+
             services.AddInitQ(m =>
             {
                 //没消息时挂起时长(毫秒)
@@ -51,6 +66,8 @@ namespace CoreCms.Net.Core.Config
                 };
                 //显示日志
                 m.ShowLog = false;
+                //新增自定redis驱动器
+                m.DbIndex = dbIndex;
             });
         }