Laravel中利用队列发送邮件的方法示例

https://www.jb51.net/article/121647.htm

本文主要给大家介绍了关于Laravel中队列发送邮件的相关内容，分享出来供大家参考学习，下面话不多说了，来一起看看详细的介绍：

批量处理任务的场景在我们开发中是经常使用的，比如邮件群发，消息通知，短信，秒杀等等，我们需要将这个耗时的操作放在队列中来处理，从而大幅度缩短Web请求和相应的时间。下面讲解下Laravel中队列的使用

1、配置文件 config/queue.php

          <?php
         
          return

          [
         
          'default'

          => env(

          'QUEUE_DRIVER'

          , 

          'sync'

          ),
         
          'connections'

          => [
         
          'sync'

          => [
         
          'driver'

          => 

          'sync'

          ,
         
          ],
         
          'database'

          => [
         
          'driver'

          => 

          'database'

          ,
         
          'table'

          => 

          'jobs'

          ,
         
          'queue'

          => 

          'default'

          ,
         
          'retry_after'

          => 90,
         
          ],
         
          'beanstalkd'

          => [
         
          'driver'

          => 

          'beanstalkd'

          ,
         
          'host'

          => 

          'localhost'

          ,
         
          'queue'

          => 

          'default'

          ,
         
          'retry_after'

          => 90,
         
          ],
         
          'sqs'

          => [
         
          'driver'

          => 

          'sqs'

          ,
         
          'key'

          => 

          'your-public-key'

          ,
         
          'secret'

          => 

          'your-secret-key'

          ,
         
          'prefix'

          => 

          'https://sqs.us-east-1.amazonaws.com/your-account-id'

          ,
         
          'queue'

          => 

          'your-queue-name'

          ,
         
          'region'

          => 

          'us-east-1'

          ,
         
          ],
         
          'redis'

          => [
         
          'driver'

          => 

          'redis'

          ,
         
          'connection'

          => 

          'default'

          ,
         
          'queue'

          => 

          'default'

          ,
         
          'retry_after'

          => 90,
         
          ],
         
          ],
         
          'failed'

          => [
         
          'database'

          => env(

          'DB_CONNECTION'

          , 

          'mysql'

          ),
         
          'table'

          => 

          'failed_jobs'

          ,
         
          ],
         
          ];

配置文件默认使用的是同步驱动sync，每一种队列驱动的配置都可以在该文件中找到，包括数据库， Beanstalkd， Amazon SQS， Redis。其中还包含了一个null队列驱动用于那些放弃队列的任务。failed配置项用于配置失败队列任务存放的数据库及数据表。接下来我们需要创建一个队列任务类。具体配置可以参考文档队列驱动配置

2、创建队列任务类，之后会在app/Jobs目录下生成一个SendEmail.php的文件

1	`php artisan make:job SendEmail`

          <?php
         
          namespace

          App\Jobs;
         
          use

          App\User;
         
          use

          Illuminate\Bus\Queueable;
         
          use

          Illuminate\Queue\SerializesModels;
         
          use

          Illuminate\Queue\InteractsWithQueue;
         
          use

          Illuminate\Contracts\Queue\ShouldQueue;
         
          use

          Illuminate\Foundation\Bus\Dispatchable;
         
          use

          Illuminate\Support\Facades\Mail;
         
          class

          SendEmail 

          implements

          ShouldQueue
         
          {

          use

          Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
         
          protected

          $user

          ;
         
          /**
         
          * Create a new job instance.
         
          *
         
          * @return void
         
          */
         
          public

          function

          __construct(User 

          $user

          )
         
          {

          $this

          ->user = 

          $user

          ;
         
          }
         
          /**
         
          * 执行队列的方法 比如发送邮件
         
          *
         
          * @return void
         
          */
         
          public

          function

          handle()
         
          {

          $user

          = 

          $this

          ->user;
         
          Mail::raw(

          '这里填写邮件的内容'

          ,

          function

          (

          $message

          ){

          // 发件人（你自己的邮箱和名称）
         
          $message

          ->from(

          'your_email@163.com'

          , 

          'yourname'

          );
         
          // 收件人的邮箱地址
         
          $message

          ->to(

          $this

          ->user);
         
          // 邮件主题
         
          $message

          ->subject(

          '队列发送邮件'

          );
         
          });
         
          }
         
          }

任务类创建完之后到控制器把数据加入到队列

3、创建发送消息的控制器使用dispatch方法手动分发任务,方法里传一个任务类的实例

          <?php
         
          namespace

          App\Http\Controllers;
         
          use

          App\Jobs\SendEmail;
         
          use

          App\User;
         
          class

          MessageController 

          extends

          Controller
         
          {

          public

          function

          index()
         
          {

          $user

          = User::find(1);
         
          $this

          ->dispatch(

          new

          SendEmail(

          $user

          ));
         
          }
         
          }