laravel5.6 基於redis，使用消息隊列（郵件推送）

郵件發送如何配置參考：https://www.cnblogs.com/clubs/p/10640682.html

用到的用戶表：

CREATE TABLE `recruit_users` (
  `id` int(10) unsigned NOT NULL AUTO_INCREMENT,
  `name` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,
  `phone` varchar(50) CHARACTER SET utf8 DEFAULT NULL COMMENT '手機號碼',
  `email` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,
  `password` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL,
  `remember_token` varchar(100) COLLATE utf8mb4_unicode_ci DEFAULT NULL,
  `status` tinyint(4) DEFAULT '1' COMMENT '帳戶狀態(0失效 1正常)',
  `created_at` timestamp NULL DEFAULT NULL,
  `updated_at` timestamp NULL DEFAULT NULL,
  `lastlogintime` timestamp NULL DEFAULT NULL COMMENT '最后登陸時間',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;

1.在 Laravel 中使用 Redis 你需用通過 Composer 來安裝 predis/predis 包文件，不然會報錯Class 'Predis\Client' not found

composer require predis/predis ^1.1

2. laravel隊列配置（配置文件 .env 和 config/queue.php）

優先配置.env 文件如下：

QUEUE_DRIVER=redis

REDIS_HOST=127.0.0.1
REDIS_PASSWORD=******
REDIS_PORT=6379

當.env 文件沒有配置 或者 設置變量為空時，會按照 config/queue.php 文件的配置信息運行laravel，一般只配置.env文件，不修改queue.php文件
config/queue.php 文件如下：

return [
    'default' => env('QUEUE_DRIVER', 'redis'),//修改隊列驅動，使用redis

    'connections' => [
        'sync' => [
            'driver' => 'sync',
        ],

        'database' => [
            'driver' => 'database',
            'table' => 'jobs',
            'queue' => 'default',
            'retry_after' => 90,
        ],

        'beanstalkd' => [
            'driver' => 'beanstalkd',
            'host' => 'localhost',
            'queue' => 'default',
            'retry_after' => 90,
        ],

        'sqs' => [
            'driver' => 'sqs',
            'key' => env('SQS_KEY', 'your-public-key'),
            'secret' => env('SQS_SECRET', 'your-secret-key'),
            'prefix' => env('SQS_PREFIX', 'https://sqs.us-east-1.amazonaws.com/your-account-id'),
            'queue' => env('SQS_QUEUE', 'your-queue-name'),
            'region' => env('SQS_REGION', 'us-east-1'),
        ],

        'redis' => [
            'driver' => 'redis',
            'connection' => 'default',
            'queue' => 'default',
            'retry_after' => 90,
            'block_for' => null,
        ],
    ],

    'failed' => [
        'database' => env('DB_CONNECTION', 'mysql'),//隊列執行失敗 存放的數據庫
        'table' => 'failed_jobs',//隊列執行失敗 存放的表
    ],
];

Redis 在應用中的配置文件存儲在 config/database.php，在這個文件中，你可以看到一個包含了 Redis 服務信息的 redis 數組:

'redis' => [
    'client' => 'predis',
    'default' => [
        'host' => env('REDIS_HOST', '127.0.0.1'),
        'password' => env('REDIS_PASSWORD', null),
        'port' => env('REDIS_PORT', 6379),
        'database' => 0,//選擇使用的redis庫
    ],
],

3. 創建隊列任務類（app/Jobs/xxx.php）

使用artisan命令 在app/Jobs 目錄下創建執行隊列任務的類：
php artisan make:job SendEmail
app/Jobs/SendEmail.php 代碼如下：

<?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;
use App\Models\RecruitUser as User;

class SendEmail implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    protected $user;

    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct(User $user)
    {
        $this->user = $user;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        $user = $this->user;
        Mail::raw('這里填寫郵件的內容', function ($message) {
            // 收件人的郵箱地址
            $message->to($this->user->email);
            // 郵件主題
            $message->subject('隊列發送郵件');
        });
    }
}

4. 控制器將數據添加到隊列中

<?php

namespace App\Http\Controllers\Home;

use App\Jobs\SendEmail;
use App\Http\Controllers\Controller;
use Illuminate\Http\Request;
use App\Models\RecruitUser as User;

class MessageController extends Controller
{
    public function index()
    {
        $user = User::find(2);
        $res = $this->dispatch(new SendEmail($user));
        dd($res);
    }
}

5. 啟動、監聽隊列

5.1 php artisan queue:work —queue=sendEmail
指定啟動sendEmail隊列

5.2 php artisan queue:restart
重啟隊列

5.3 php artisan queue:work —timeout=60
隊列進程 queue:work 可以設定超時 —timeout 項。該 —timeout 控制隊列進程執行每個任務的最長時間，如果超時，該進程將被關閉。
注：參數項 —timeout 的值應該始終小於配置項 retry_after 的值，這是為了確保隊列進程總在任務重試以前關閉。如果 —timeout 比retry_after 大，那么你的任務可能被執行兩次。

5.4 php artisan queue:work —sleep=3
休眠時間，每執行一個任務后休眠3秒

 

監聽三種情況：

 queue:work 默認只執行一次隊列請求, 當請求執行完成后就終止；

 queue:listen 監聽隊列請求，只要運行着，就能一直接受請求，除非手動終止；

 queue:work --daemon 同listen一樣，不同的是work不需要再次加載框架，直接運行任務，一般推薦使用這個來處理隊列監聽。

 注意: 使用 queue:work —daemon , 當更新代碼的時候, 需要停止, 然后重新啟動, 這樣才能把修改的代碼應用上

6. 設置API路由，執行請求，執行隊列任務

Route::post('messageindex', ['uses' => $namespaces . 'MessageController@index', 'as' => 'messageIndex']);

使用postman發送post請求即可以測試發送郵件隊列

 

 查看redis是否有隊列數據

 

命令行監聽界面：

 

查看郵箱發件箱，郵件已發出

7. 使用Supervisor將隊列任務啟動 添加到守護進程中

推薦安裝Supervisor，將 php artisan queue:work —queue sendEmail 等一系列隊列進程，添加到進程保護中，防止中途崩潰時候，可以自救，哈哈~😄
關於Supervisor，可以參考《centos安裝Supervisor以及簡單配置（添加進程守護）》

總結

1. 引入 predis/predis 包
2. laravel隊列配置（配置文件 .env 和 config/queue.php）
3. 創建隊列任務類（app/Jobs/xxx.php）
4. 控制器將數據添加到隊列中
5. 啟動、監聽隊列
6. 設置API路由，執行請求，執行隊列任務
7. 使用Supervisor將隊列任務啟動 添加到守護進程中