Laravel
话题列表 社区 Wiki 优质外文 招聘求职 Laravel 实战教程 社区文档
登录
注册
《Laravel 5.6 中文文档》 队列
同学分享

队列的简单 demo

分享 / 28 / 3 / 创建于 5年前 / 更新于 5年前

基于文档稍微写一个很小的 demo 然后面的新手直接能用

    1：创建model 和 数据库

         php artisan make:model Podcast -m

        我就创建两个字段 id & status ，database目录下新建表的 run 方法：
             public function up()
                {
                    Schema::create('podcasts', function (Blueprint $table) {
                        $table->increments('id');
                        $table->tinyInteger('status')->unsigned();
                        $table->timestamps();
                    });
                }

    2：创建控制器，增加 story 方法  
        php artisan make:controller:API\PodcastController
        增加一个 
        public function store(  ) {
            $model = new Podcast();
            $model->status = 0;
            $model->save();
            ProcessPodcast::dispatch($model)->delay(now()->addMinutes(3));
        }

    3：修改 Job / ProcessPodcast.php  类,

        protected $podcast ;
        public function __construct(Podcast $podcast)\
        {
            $this->podcast = $podcast;
        }

         public function handle()\
        {
            $this->podcast->status = 1;
            $this->podcast->update();
        }

    3：配置 .env 
        QUEUE_DRIVER=redis

    4：job 怎么创建文档上已经写的很清楚了，就只是差控制器 & 数据库 & 模型 没有创建。

    5：在 routes/api.php 增加路由
        Route::get('queue','API\PodcastController@store');

    6：在服务器上执行 php artisan queue:work

总结下 虽然很简单 但是对于还是有同学看文档 我之前也看不懂 现在看懂了 所以想帮助没有看懂的人

执行结果和过程

队列的简单 demo

队列的简单 demo

郎中航
课程读者 188 声望
暂无个人描述~
《L05 电商实战》
《L05 电商实战》
从零开发一个电商项目，功能包括电商后台、商品 & SKU 管理、购物车、订单管理、支付宝支付、微信支付、订单退款流程、优惠券等
《L04 微信小程序从零到发布》
《L04 微信小程序从零到发布》
从小程序个人账户申请开始，带你一步步进行开发一个微信小程序，直到提交微信控制台上线发布。
讨论数量: 3

高认可度评论：

liuyuit
29 声望

基于楼主的demo，重新写了一份详细点的

队列的简单demo

references

队列《Laravel 5.2 中文文档》

分享：队列的简单 demo

model

$ php artisan make:model podcast
Model created successfully.

创建表

CREATE TABLE `podcast` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `status` tinyint(1) NOT NULL,
  `updated_at` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00' ON UPDATE CURRENT_TIMESTAMP COMMENT 'CURRENT_TIMESTAMP',
  `created_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
<?php

namespace App;

use Illuminate\Database\Eloquent\Model;

class Podcast extends Model
{
    protected $connection = '34w';
    protected $table = 'podcast';
}

job

$ php artisan make:job ProcessPodcast
Job created successfully.
<?php

namespace App\Jobs;

use App\Jobs\Job;
use App\Podcast;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;

class ProcessPodcast extends Job implements ShouldQueue
{
    use InteractsWithQueue, SerializesModels;

    protected $podcast;

    public function __construct(Podcast $podcast)
    {
        $this->podcast = $podcast;
    }

    public function handle()
    {
        $this->podcast->status = 1;
        $this->podcast->update();
    }
}

Controller

$ php artisan make:controller API/PodcastController
Controller created successfully.
<?php

namespace App\Http\Controllers\Api;

use App\Podcast;
use App\Jobs\ProcessPodcast;
use App\Http\Controllers\Controller;

class PodcastController extends Controller
{
    public function store(  ) {
        $model = new Podcast();
        $model->status = 0;
        $model->save();
        $job = new ProcessPodcast($model);
        $job->delay(10);;
        $this->dispatch($job);
    }
}

routes

在route文件中新增

Route::get('queue','Api\PodcastController@store');

运行

请求api

http://www.newadminpk.abc/queue

运行命令

$ php artisan queue:work
[2020-02-24 17:55:28] Processed: App\Jobs\ProcessPodcast

或者监听

$ php artisan queue:listen
[2020-02-24 18:23:45] Processed: App\Jobs\ProcessPodcast
[2020-02-24 18:23:46] Processed: App\Jobs\ProcessPodcast
[2020-02-24 18:23:47] Processed: App\Jobs\ProcessPodcast
[2020-02-24 18:23:48] Processed: App\Jobs\ProcessPodcast

数据库

id    status    updated_at    created_at
1    1    2020-02-24 17:49:06    2020-02-24 17:49:00
7    0    2020-02-24 18:00:52    2020-02-24 18:00:52
8    0    2020-02-24 18:00:54    2020-02-24 18:00:54
4年前 评论
7
排序：
时间 投票
golang练习生
课程读者 49 声望

写得真乱，让人家越看不明白

5年前 评论
威尔 5年前
是的。给新手的话，更要每个步骤说的清清楚楚没有歧义。不然对新手来说，都是一个个大坑。最后点赞作者的分享精神。
liuyuit
29 声望

基于楼主的demo，重新写了一份详细点的

队列的简单demo

references

队列《Laravel 5.2 中文文档》

分享：队列的简单 demo

model

$ php artisan make:model podcast
Model created successfully.

创建表

CREATE TABLE `podcast` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `status` tinyint(1) NOT NULL,
  `updated_at` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00' ON UPDATE CURRENT_TIMESTAMP COMMENT 'CURRENT_TIMESTAMP',
  `created_at` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
<?php

namespace App;

use Illuminate\Database\Eloquent\Model;

class Podcast extends Model
{
    protected $connection = '34w';
    protected $table = 'podcast';
}

job

$ php artisan make:job ProcessPodcast
Job created successfully.
<?php

namespace App\Jobs;

use App\Jobs\Job;
use App\Podcast;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;

class ProcessPodcast extends Job implements ShouldQueue
{
    use InteractsWithQueue, SerializesModels;

    protected $podcast;

    public function __construct(Podcast $podcast)
    {
        $this->podcast = $podcast;
    }

    public function handle()
    {
        $this->podcast->status = 1;
        $this->podcast->update();
    }
}

Controller

$ php artisan make:controller API/PodcastController
Controller created successfully.
<?php

namespace App\Http\Controllers\Api;

use App\Podcast;
use App\Jobs\ProcessPodcast;
use App\Http\Controllers\Controller;

class PodcastController extends Controller
{
    public function store(  ) {
        $model = new Podcast();
        $model->status = 0;
        $model->save();
        $job = new ProcessPodcast($model);
        $job->delay(10);;
        $this->dispatch($job);
    }
}

routes

在route文件中新增

Route::get('queue','Api\PodcastController@store');

运行

请求api

http://www.newadminpk.abc/queue

运行命令

$ php artisan queue:work
[2020-02-24 17:55:28] Processed: App\Jobs\ProcessPodcast

或者监听

$ php artisan queue:listen
[2020-02-24 18:23:45] Processed: App\Jobs\ProcessPodcast
[2020-02-24 18:23:46] Processed: App\Jobs\ProcessPodcast
[2020-02-24 18:23:47] Processed: App\Jobs\ProcessPodcast
[2020-02-24 18:23:48] Processed: App\Jobs\ProcessPodcast

数据库

id    status    updated_at    created_at
1    1    2020-02-24 17:49:06    2020-02-24 17:49:00
7    0    2020-02-24 18:00:52    2020-02-24 18:00:52
8    0    2020-02-24 18:00:54    2020-02-24 18:00:54
4年前 评论
7
de_bug
0 声望

大佬们有没有碰到过laravel队列同步可以执行，换成database异步就只是添加到jobs表里了，不执行任务。 :cry: :cry:

4年前 评论

讨论应以学习和精进为目的。请勿发布不友善或者负能量的内容，与人为善，比聪明更重要！
支持 MD 帮助
郎中航 188 声望
TA 的博客
社区赞助商
成为赞助商

关于 LearnKu

LearnKu 是终身编程者的修道场
做最专业、严肃的技术论坛
LearnKu 诞生的故事

资源推荐

  • 《社区使用指南》
  • 《文档撰写指南》
  • 《LearnKu 社区规范》
  • 《提问的智慧》

    • 服务提供商

    其他信息

  • 成为版主
  • 所有测验
  • 联系站长（反馈建议）

    • 粤ICP备18099781号-6 | 粤公网安备 44030502004330号 | 违法和不良信息举报

    由 Summer 设计和编码 ❤

    请登录

    内容举报
    匿名举报，为防止滥用，仅管理员可见举报者。

    我要举报该，理由是：

    取消