Laravel 延迟队列

bestcyt 的个人博客 / 1938 / 4 / 创建于 4年前 / 更新于 4年前

场景示例：发布一篇文章或者任务，设定了上架时间，那么当上架时间到的时候，自动改变文章状态

思路：使用laravel延迟队列

Demo：文章状态改变(可直接复制代码运行)

1.准备：

使用Redis做队列驱动，开启Redis-server redis.conf
创建任务文件php artisan make:job endTask

2.编码：

web.php 路由

Route::get('/index', 'PostController@index');
Route::post('/posts', 'PostController@store');

PostController

    public function index()
    {
        return view('index');
    }

    public function store(Request $request)
    {
        $request->validate([
            'title'=>'required',
            'body'=> 'required',
        ]);
        $post['title'] = $request->title;
        $post['body'] = $request->body;
        $post['beginTime'] = Carbon::now()->addMinutes(1);
        $resPost = Post::create($post);

        //延时队列 更新文章状态
        endTask::dispatch($resPost)->delay($resPost->beginTime);
        return redirect()->back()->with('status', 'Your post has been submitted successfully');
    }

Post.php 模型文件

class Post extends Model
{
    //
    protected $table = 'posts';
    protected $fillable = ['title','body','beginTime','endTime'];
}

inde.blade.php 表单

<!DOCTYPE html>
<html>
<head>
    <meta name="viewport" content="width=device-width">
    <title>Laravel Queues</title>
    <meta name="description" content="">
    <link rel="stylesheet" href="https://maxcdn.bootstrapcdn.com/bootstrap/3.3.5/css/bootstrap.min.css">
</head>

<body>
<div class="container">
    <div class="col-md-5">
        <h4 class="page-header">Laravel Queues </h4>
        @foreach ($errors->all() as $error)
            <p class="alert alert-danger">{{ $error }}</p>
        @endforeach
        @if (session('status'))
            <div class="alert alert-success">
                {{ session('status')}}
            </div>
        @endif
        <form class="form-vertical" role="form" method="post" action="/posts">
            {{csrf_field()}}
            <div class="form-group">
                <input type="text" name="title" class="form-control" placeholder="Title">
            </div>
            <div class="form-group">
                <textarea class="form-control" rows="5" name="body" class="form-control" placeholder="Content"></textarea>
            </div>
            <div class="form-group">
                <button type="submit" class="btn btn-info">Submit Post</button>
            </div>
        </form>
    </div>
</div>
</body>
</html>

endTask队列

    public $post ;
    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct(Post $post)
    {
        //
        $this->post = $post;
        Log::info('post handel postId __construct: '.$this->post->id);
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        $res = Post::where('id',$this->post->id)->update(['status'=>2]); //更新文章的状态
        Log::info('post handel '.$this->post->id.'-status:'.$res);
    }