Laravel 通知外观队列响应时间

Question

Laravel 文档解释说，在调度/发送通知时，您可能希望将它们排队以加快应用程序响应时间。

https://laravel.com/docs/5.5/notifications#queueing-notifications

这正是我想要做的，但是我使用通知外观而不是通知特性来调用它。我担心的是前者是绕过队列，我需要它来一次通知一组用户。

正如文档中所说：

或者，您可以通过 Notification 门面发送通知。 这主要在您需要向 多个应通知实体，例如用户集合。

但是当我通过外观调用我的通知时，它不会排队。我知道这一点是因为当我监控我的网络请求并注释掉外观调用时，我的请求会从超过 2 秒（使用通知调用）到不到 0.5 秒（当我注释掉它时）。

这是我使用队列的通知类的开始 (NewAsset)：

<?php

namespace App\Notifications;

use Illuminate\Bus\Queueable;
use Illuminate\Notifications\Notification;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Notifications\Messages\MailMessage;

class NewAsset extends Notification implements ShouldQueue
{
    use Queueable;

来电：

$asset = new Asset;
$asset->user_id = Auth::user()->id;
$asset->type = "Text";
$asset->content = $content;
$asset->forum_id = 1;
$asset->save();
$users = User::where("id","!=",Auth::user()->id)->get();
Notification::send($users, new NewAsset($asset,Auth::user()));
//if i comment out the notification call above, response time decreases dramatically 
return;

我做错了什么？

哦……好像触发了队列：

php artisan queue:listen
[2018-03-31 15:48:22] Processing: App\Notifications\NewAsset
[2018-03-31 15:48:22] Processed:  App\Notifications\NewAsset
[2018-03-31 15:48:23] Processing: App\Notifications\NewAsset
[2018-03-31 15:48:23] Processed:  App\Notifications\NewAsset
[2018-03-31 15:48:24] Processing: App\Notifications\NewAsset
[2018-03-31 15:48:24] Processed:  App\Notifications\NewAsset
[2018-03-31 15:48:25] Processing: App\Notifications\NewAsset
[2018-03-31 15:48:25] Processed:  App\Notifications\NewAsset

那为什么这么慢呢？ :(

Answer 1

Notification::send 很慢（> 2 秒），很有可能您有数千个通知实体推送到数据库队列，这很慢，因为在数据库上执行了数千个插入语句。要改进，您可以：

1. 使用其他队列驱动程序，例如 Amazon SQS、Beanstalkd、Redis 等。它们针对低延迟的工作队列进行了优化。与作为工作队列的数据库相比，它们快如闪电。

2. 再创建一个job，让worker将所有通知排队，例如：

   php artisan make:job QueueUserNotificationsJob
   

   YourController.php

   dispatch(new QueueUserNotificationsJob(Auth::user()->id));
   

   QueueUserNotificationsJob.php

   public $authUserId = null;
   
   public function __construct($authUserId) {
   
       $this->authUserId = $authUserId;
   
   }
   
   public function handle() {
   
       $users = User::where("id", "!=", $this->authUserId)->get();
   
       Notification::send($users, new NewAsset($asset, $this->authUserId));
   
   }