laravel使用mysql队列

太过爱你忘了你带给我的痛 2022-08-19 13:14 8阅读 0赞

首先配置队列的使用mysql数据库而不是同步的sync队列找到config文件夹下面的queue.php里面的

//'default' => env('QUEUE\_DRIVER', 'sync'),

'default'=>'database',

default修改成database。

使用命令创建队列:

php artisan queue:table
    
    php artisan migrate

执行完毕之后数据库会有一个jobs表，这个就是存放队列任务的表。

php artisan make:job SendReminderEmail

执行完毕之后找到app下面的Jobs文件夹下面多了一个SendReminderEmail.php文件。

内容如下：

<?php
    
    namespace App\Jobs;
    
    use App\Jobs\Job;
    use App\models\Users;
    use Illuminate\Contracts\Mail\Mailer;
    use Illuminate\Queue\SerializesModels;
    use Illuminate\Queue\InteractsWithQueue;
    use Illuminate\Contracts\Bus\SelfHandling;
    use Illuminate\Contracts\Queue\ShouldQueue;
    use Mail;
    class SendReminderEmail extends Job implements SelfHandling, ShouldQueue
    {
        
        use InteractsWithQueue, SerializesModels;
        private $user;
        /**
         * Create a new job instance.
         *
         * @return void
         */
        public function __construct(Users $user)
    
        {
        
            $this->user = $user;
        }
    
        /**
         * Execute the job.
         *
         * @return void
         */
        public function handle()
        {
        
    
            $user = $this->user;
            Mail::send('emails.reminder', ['user' => $user], function ($m) use ($user) {
        
                $m->from('xxxx@163.com', 'MyName');
    
                $m->to($user->email, $user->name)->subject('Your Reminder!');

//附件,在public文件夹下面的images文件夹下面的图片
                $m->attach(public_path().'/images/bg.jpg',[]);
                //$message->to('foo@example.com')->cc('bar@example.com');抄送
            });
    
        }
    }

发邮件我们还需要配置一个发送邮件的配置找到config文件夹下面的mail.php或者.env文件都可以进行配置

MAIL_DRIVER=smtp
    MAIL_HOST=smtp.163.com
    MAIL_PORT=25
    MAIL_USERNAME=xxxx@163.com
    MAIL_PASSWORD=xxx

还需要创建一个发送邮件的模版文件,上面写的是emails.reminder,在resources文件夹下面创建emails文件夹并创建 reminder.blade.php模版文件随便写点内容 <p>
        图片: <a href="#">你好</a> </p>

配置完毕之后找到控制器来进行执行队列任务。

<?php

namespace App\Http\Controllers;

use App\Commands\PushMessage;

use App\Http\Controllers\Controller;

use App\Jobs\SendReminderEmail;

use App\models\Users;

use Cache;

use Log;

use Event;

use Illuminate\Http\Request;

use App\Services\IUserService;

use App\Events\PupUserchange;

use Queue;

/**

* 控制器

class UserController extends Controller{

public function getSendmail(){

//传递一个Users对象

$this->dispatch(new \App\Jobs\SendReminderEmail(Users::find(2)));

延时执行

$job=(newSendReminderEmail($user))->delay(60);$this->dispatch($job);        */

//视图

return view('email.sendmail');

}

视图文件在email文件夹下面创建sendmail.blade.php即可

配置路由:

Route::get('user/sendmail',' [UserController@][UserController] `getSendmail` ');

监听队列：

![Center][]

访问这个控制器的方法触发发邮件事件:

![Center 1][]

![Center 2][]

[UserController]: mailto:UserController@getAddUser
[Center]: /images/20220731/02a07ed6b89146bc8779345749b9c15e.png
[Center 1]: /images/20220731/19237f04967944dbb367c4f278d19d6b.png
[Center 2]: /images/20220731/f87874e071f04c438b6e807e2d4ccebf.png