laravel8+队列发送邮件之订阅推文邮件功能
管理员 发布于 4年前   440
功能:订阅网站后通过邮箱网站会定期或不定期推送一篇或几篇网站博文。
驱动程序说明和先决条件:数据库,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邮箱:
钉钉邮箱:
官网一段文字 (网上很多这种文章,后面有时间会写一遍守护进程的文章)
技巧:为了让 queue:work 进程永久地在后台运行,您应该使用一个进程监视器,如 Supervisor,以确保队列 worker 不会停止运行。
请勿发布不友善或者负能量的内容。与人为善,比聪明更重要!
该博客于2020-12-7日,后端基于go语言的beego框架开发
前端页面使用Bootstrap可视化布局系统自动生成
是我仿的原来我的TP5框架写的博客,比较粗糙,底下是入口
侯体宗的博客
文章标签
友情链接