加桌切换redis_queue

app/Modules/User/Services/UserService.php

@@ -85,7 +85,7 @@ class UserService
 //                QappAddDeskTopService::incrAddDeskTop($uid, QuickConst::FIELD_ADD_DESKTOP);
                 $start  = time();
                 $job = new UserAddDeskJob($uid);
-                dispatch($job)->onConnection('redis')->onQueue('{qapp_user_add_desk}')->delay(now()->addMinutes(3));
+                dispatch($job)->onConnection('redis_queue')->onQueue('{qapp_user_add_desk}')->delay(now()->addMinutes(3));
                 $time = time() - $start;
                 if ($time >= 1 ){
                     myLog('mq-put-timeout')->info("加桌队列-mq-投递超过1耗时".$time."s;路径：app/Modules/User/Services/UserService.php-qappAddDesktop方法 88行");
@@ -108,7 +108,7 @@ class UserService
 
                 $job = new UserAddDeskJob($uid);
                 $start = time();
-                dispatch($job)->onConnection('redis')->onQueue('{qapp_user_add_desk}')->delay(now()->addMinutes(3));
+                dispatch($job)->onConnection('redis_queue')->onQueue('{qapp_user_add_desk}')->delay(now()->addMinutes(3));
                 $time = time() - $start;
                 if ($time >= 1 ){
                     myLog('mq-put-timeout')->info("加桌队列-mq-投递超过1耗时".$time."s;路径：app/Modules/User/Services/UserService.php-qappAddDesktop方法 111行");

config/database.php

@@ -190,7 +190,12 @@ return [
             'port' => env('REDIS_PORT', 6379),
             'database' => 10
         ],
-
+        'redis_queue_new' => [//专门处理队列的服务器
+            'host' => env('REDIS_HOST_QUEUE', 'localhost'),
+            'password' => env('REDIS_PASSWORD_QUEUE', null),
+            'port' => env('REDIS_PORT_QUEUE', 6379),
+            'database' => 2,
+        ],
     ],
 
 ];

config/queue.php

@@ -64,6 +64,13 @@ return [
             'expire' => 60,
         ],
 
+        'redis_queue' => [
+            'driver' => 'redis',
+            'connection' => 'redis_queue_new',
+            'queue' => 'default',
+            'expire' => 60,
+        ]
+
     ],
 
     /*