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

));

}

}