rabbit改redis

app/Console/Kernel.php

@@ -60,4 +60,14 @@ class Kernel extends ConsoleKernel
         // 每天的推送统计
         $schedule->command('push:stats')->dailyAt('00:30');
     }
+
+    /**
+     * Register the commands for the application.
+     *
+     * @return void
+     */
+    protected function commands()
+    {
+        $this->load(__DIR__.'/Commands');
+    }
 }

app/Modules/User/Services/QappUserService.php

@@ -267,7 +267,7 @@ class QappUserService
             $start = time();
             // 回传业务
             $job = new QappTikTokUser($tikTokRegisterRequest);
-            dispatch($job->onConnection('rabbitmq')->onQueue('qapp_tiktok_user_register_queue'));
+            dispatch($job->onConnection('redis')->onQueue('{qapp_tiktok_user_register_queue}'));
             $time = time() - $start;
             if ($time >= 1 ){
                 myLog('mq-put-timeout')->info("注册qapp_tiktok_user_register_queue-mq-投递超过1耗时".$time."s;路径：app/Modules/User/Services/QappUserService.php 270行");
@@ -276,7 +276,7 @@ class QappUserService
             UserTaskService::addUserTaskQueue($user->id, BaseTask::register, UserTaskService::add_trigger);
 
             $job = new NewUserPushMsgDelay($user->id);
-            dispatch($job->onConnection('rabbitmq')->onQueue('new_user_push_msg'));
+            dispatch($job->onConnection('redis')->onQueue('{new_user_push_msg}'));
             $time = time() - $start;
             if ($time >= 1 ){
                 myLog('mq-put-timeout')->info("注册new_user_push_msg-mq-投递超过1耗时".$time."s;路径：app/Modules/User/Services/QappUserService.php 279行");

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('rabbitmq')->onQueue('qapp_user_add_desk')->delay(now()->addMinutes(3));
+                dispatch($job)->onConnection('redis')->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('rabbitmq')->onQueue('qapp_user_add_desk')->delay(now()->addMinutes(3));
+                dispatch($job)->onConnection('redis')->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行");

app/Modules/UserTask/Services/UserTaskService.php

@@ -89,7 +89,7 @@ class UserTaskService
     public static function addUserTaskQueue(int $uid, string $type, string $trigger_type)
     {
         $job = new UserTaskJob($uid, $type, $trigger_type);
-        dispatch($job)->onConnection('rabbitmq')->onQueue('qapp_user_task_queue');
+        dispatch($job)->onConnection('redis')->onQueue('{qapp_user_task_queue}');
     }
 
     /**