欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

laravel5.6 框架邮件队列database驱动简单demo示例

程序员文章站 2023-10-30 17:23:34
本文实例讲述了laravel5.6 框架邮件队列database驱动。分享给大家供大家参考,具体如下:一: 邮件初始参数配置配置 .env (demo示例是163邮箱,开启pop3和smtp服务,获取...

本文实例讲述了laravel5.6 框架邮件队列database驱动。分享给大家供大家参考,具体如下:

一: 邮件初始参数配置

配置 .env  (demo示例是163邮箱,开启pop3和smtp服务,获取授权密码)

mail_driver=smtp
mail_host=smtp.163.com
mail_port=465
mail_username=你的163邮箱地址
mail_password=你的163邮箱地址对应的授权密码(不是登录密码)
mail_encryption=ssl
mail_from_address=你的163邮箱地址

修改 .env 中的 queue_driver 值   (配置文件 config/queue.php  默认是同步'sync', demo配置'database'驱动)

queue_driver=database

二: 数据库建表

//队列任务表
php artisan queue:table
//任务执行失败表
php artisan queue:failed-table
//执行数据库迁移
php artisan migrate

三: 生成任务类

php artisan make:job sendemail

生成之后,在handle方法中处理发送队列邮件

<?php
namespace app\jobs;
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;
  private $email;
  private $content;
  private $subject;
  /**
   * create a new job instance.
   *
   * @return void
   */
  public function __construct( $email, $content, $subject)
  {
    $this->email = $email;
    $this->content = $content;
    $this->subject = $subject;
  }
  /**
   * execute the job.
   *
   * @return void
   */
  public function handle()
  {
    $email = $this->email;
    $subject = $this->subject;
    mail::send(
      'admin.emails.test',
      ['content' => $this->content],
      function ($message) use($email, $subject) {
        $message->to($email)->subject($subject);
      }
    );
    // mail::failures() 返回的错误邮件信息,判断是否发送成功. (无错误信息,返回空数组)
    if(empty(mail::failures())){
      dd('发送成功');
    }else{
      dd('发送失败');
    }
  }
}

四: 对应邮件发送的控制器,任务加到队列中

<?php
namespace app\http\controllers\admin;
use app\http\controllers\controller;
use app\jobs\sendemail;
/**
 * description of bookedcontroller
 */
class bookedcontroller extends controller {
  public function queuesend()
  {
    //邮件发送demo数据
    $data =[
      0=>[
        'email'=>'xxxxxx@qq.com',
        'content'=>'hello world one',
        'subject'=>'测试标题一',
      ],
      1=>[
        'email'=>'xxxxxx@qq.com',
        'content'=>'hello world two',
        'subject'=>'测试标题二',
      ]
    ];
    foreach ($data as $item){
      //数据循环,插入表jobs中,队列初始化数据
      dispatch(new sendemail($item['email'],$item['content'],$item['subject']));
    }
  }
}

五:  执行队列里的任务

//默认只执行一次队列请求,当请求执行完成后就终止
php artisan queue:work
//监听队列请求,只要运行着,就能一直接受请求,除非手动终止
php artisan queue:listen