《Laravel 5.6 中文文档》队列

同学分享

队列的简单 demo

基于文档稍微写一个很小的 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

郎中航

课程读者 187 声望

暂无个人描述~

2 人点赞

从零开发一个电商项目，功能包括电商后台、商品 & SKU 管理、购物车、订单管理、支付宝支付、微信支付、订单退款流程、优惠券等

从小程序个人账户申请开始，带你一步步进行开发一个微信小程序，直到提交微信控制台上线发布。

队列的简单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年前评论

golang练习生

课程读者 49 声望

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

4年前评论

威尔

是的。给新手的话，更要每个步骤说的清清楚楚没有歧义。不然对新手来说，都是一个个大坑。最后点赞作者的分享精神。

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年前评论

de_bug

0 声望

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

3年前评论

讨论应以学习和精进为目的。请勿发布不友善或者负能量的内容，与人为善，比聪明更重要！

帮助

队列的简单 demo

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

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

执行结果和过程

推荐文章：

高认可度评论：

队列的简单demo

references

model

job

Controller

routes

运行

队列的简单demo

references

model

job

Controller

routes

运行

社区赞助商

关于 LearnKu

资源推荐

服务提供商

其他信息

队列的简单 demo

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

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

执行结果和过程

推荐文章：

高认可度评论：

队列的简单demo

references

model

job

Controller

routes

运行

队列的简单demo

references

model

job

Controller

routes

运行

社区赞助商

关于 LearnKu

资源推荐

服务提供商

其他信息

请登录

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