laravel8+队列发送邮件之订阅推文邮件功能-侯体宗的博客

laravel8+队列发送邮件之订阅推文邮件功能
管理员发布于 3年前 401

功能：订阅网站后通过邮箱网站会定期或不定期推送一篇或几篇网站博文。

驱动程序说明和先决条件：数据库，Beanstalkd，Amazon SQS，Redis，和一个同步驱动程序（供本地使用）,laravel可以用这些驱动实现队列，我这里就用database。

我通过数据库驱动队列发送

1.要使用 database 队列驱动程序，你需要一个数据库表来保存任务。要生成创建此表的迁移，请运行 queue:table Artisan 命令。一旦迁移已经创建，你可以使用 migrate 命令迁移你的数据库:

php artisan queue:table
php artisan migrate

2. .env 中改成数据库

QUEUE_CONNECTION=database

3. 创建任务类

php artisan make:job SendEmail

该命令会在App\Jobs目录下生成该文件

<?php
namespace App\Jobs;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use App\Mail\subscribe;
use Illuminate\Support\Facades\Mail;
class SendEmail implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
    protected $name;
    protected $email;
    /**
     * Create a new job instance.
     * @return void
     */
    public function __construct($name, $email)
    {
        //
        $this->name = $name;
        $this->email = $email;
    }
    /**
     * Execute the job.
     * @return void
     */
    public function handle()
    {
        // 如果参试大于三次
        if ($this->attempts() > 3) {
            return;
        }else{
            // 每次进来休息3秒钟
            sleep(3);
            Mail::to($this->email)->send(new subscribe());
            echo $this->name;
        }
    }
}

4.添加路由创建添加队列方法的路由 (位置自行安排)

5.创建添加队列方法把已经订阅的邮箱添加入队列里面定时发送邮件

use App\Jobs\SendEmail;
//需要发邮件的订阅 插入队列
public function addqueuesubscribe()
{
     $user = DB::table('users')->where('subscribe',1)->get();
     //dd($user);
     foreach($user as $data){
        dispatch(new SendEmail($data->name,$data->email));
        echo $data->name.'<br>';
     }
}

6.测试看看效果

1.执行添加队列路由：http://larabg.com/addqueuesubscribe

添加完队列会在jobs表生成发送队列信息队列执行成功会删除队列执行失败也会删除同时会在failed_jobs表生成队列失败信息

2.运行队列处理器：监听队列表有数据就执行

D:\phpStudy\WWW\larabg>php artisan queue:listen

admin[2020-10-16 03:49:12][15] Processed: App\Jobs\SendEmail

[2020-10-16 03:49:12][16] Processing: App\Jobs\SendEmail

ç«™é•¿å°å[2020-10-16 03:49:16][16] Processed: App\Jobs\SendEmail

我用两个账号订阅网站一个是QQ邮箱，一个是钉钉邮箱

qq邮箱：