laravel 队列之队列消息与发送邮件

前期准备：

1. 开发环境：homestead(Ubuntu 18.04 LTS+php 7.2.30+mysql 5.7.22)
   确保安装了redis扩展，如无安装，请执行：

   composer require predis/predis

2. 配置信息
   在config/queue.php的connections中配置：

   'redis' => [ 'driver' => 'redis', 'connection' => 'default', 'queue' => env('REDIS_QUEUE', 'default'), 'retry_after' => 90, 'block_for' => null, ],

   在.env文件中配置发送邮件的邮箱：

   MAIL_MAILER=smtp #邮箱服务器地址 MAIL_HOST=smtp.163.com MAIL_PORT=25 #邮箱账号 MAIL_USERNAME=XXX@163.com #POP3/SMTP服务密码 MAIL_PASSWORD=XXXX MAIL_ENCRYPTION=null #可以随便填写字符串，但是一定不能为空 MAIL_FROM_ADDRESS=null MAIL_FROM_NAME="${APP_NAME}"

   在此有个需要注意的地方，MAIL_PASSWORD不是邮箱的登录密码，而是POP3/SMTP服务密码（设置方法）。
   注意：本例子中使用的是网易邮箱和SMTP，不同驱动下的服务器地址、端口号均不同：

• 服务器地址：
  POP3服务器: pop.163.com
  SMTP服务器: smtp.163.com
  IMAP服务器: imap.163.com
  安全支持：
  POP3/SMTP/IMAP服务全部支持SSL连接
• 端口：
  

  开发阶段：

• 生成任务类

执行命令：

php artisan make:job SendEmail

运行成功在app/Jobs目录下生成SendEmail类。修改类的内容后如下：

namespace App\Jobs; use App\Models\UserInfo; use Illuminate\Bus\Queueable; use Illuminate\Contracts\Mail\Mailer; use Illuminate\Contracts\Queue\ShouldQueue; use Illuminate\Foundation\Bus\Dispatchable; use Illuminate\Queue\InteractsWithQueue; use Illuminate\Queue\SerializesModels; class SendEmail implements ShouldQueue { use Dispatchable, InteractsWithQueue, Queueable, SerializesModels; protected $user; /** * Create a new job instance. * * @return void */ public function __construct(UserInfo $user) { // $this->user = $user; } /** * Execute the job. * * @return void */ public function handle(Mailer $mailer) { // $user = $this->user; $mailer->send('emails.reminder',['user'=>$user],function($message) use ($user){ $message->to($user->email)->subject('新功能发布'); }); } }

参考资料：Laravel 队列系列 —— 基于 Redis 实现任务队列的基本配置和使用

• 编写调用函数：

  <?php namespace App\Admin\Controllers; use App\Http\Controllers\Controller; use App\Jobs\SendEmail; use App\Models\UserInfo; use Illuminate\Http\Request; use Illuminate\Support\Facades\Redis; class ApiController extends Controller { private $redis; public function __construct(){ $this->redis = Redis::connection('default'); } public function test(Request $request){ //方便测试，写死 $user = UserInfo::find(1); $this->dispatch(new SendEmail($user)); } }

  加上测试路由：

  Route::group([ 'prefix' => 'admin', 'middleware' => ['web'], ], function (Router $router) { $router->any('api/{action}', function ($action) { $ctrl = \App::make("\\App\\Admin\\Controllers\\ApiController"); return \App::call([$ctrl, $action]); }); });

  测试阶段：

  调用xxx.test/api/test
  得出结果：
  
  进入查看邮件：
  

至此，邮件发送成功完成！

本作品采用《CC 协议》，转载必须注明作者和本文链接