這篇文章主要介紹Laravel如何讓程序在后臺(tái)執(zhí)行超長(zhǎng)時(shí)間，文中介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們一定要看完！

成都創(chuàng)新互聯(lián)公司網(wǎng)站建設(shè)公司提供網(wǎng)站設(shè)計(jì)和自適應(yīng)建站服務(wù)。團(tuán)隊(duì)由有經(jīng)驗(yàn)的網(wǎng)頁(yè)設(shè)計(jì)師、程序員和市場(chǎng)專家組成，能夠提供從H5網(wǎng)站設(shè)計(jì)，網(wǎng)站制作，廣告投放，模板建站到小程序設(shè)計(jì)等全方位服務(wù)。 以客戶為中心，致力于為客戶提供創(chuàng)新、高效的解決方案，幫助您打造成功的企業(yè)網(wǎng)站。

解決的問(wèn)題：

● 耗時(shí)較長(zhǎng)

● 各端無(wú)法調(diào)取相關(guān)任務(wù)進(jìn)度進(jìn)行反饋

● 自定義任務(wù)過(guò)后反饋結(jié)果

● 請(qǐng)教下，Laravel 如何讓程序在后臺(tái)執(zhí)行超長(zhǎng)時(shí)間的代碼？

流程簡(jiǎn)述

● 使用異步隊(duì)列執(zhí)行相關(guān)任務(wù)

● 使用助手方法進(jìn)行任務(wù) / 進(jìn)度創(chuàng)建

● 通過(guò)暴露接口反饋相關(guān)進(jìn)度

助手類源碼如下

<?php
// +----------------------------------------------------------------------
// | Do what we can do
// +----------------------------------------------------------------------
// | Date  : 2019/9/11 - 9:25 AM
// +----------------------------------------------------------------------
// | Author: seebyyu <seebyyu@gmail.com> :)
// +----------------------------------------------------------------------
namespace App\Lib\Support;
trait MissionFrom
{
    /**
     * 標(biāo)記前綴 模塊名稱#業(yè)務(wù)模塊#板塊標(biāo)記
     *
     * @var string
     */
    public $prefix = 'school:task:default';
    /**
     * 任務(wù)詳情
     * @var array
     */
    public $original = [];
    /**
     * redis 鏈接
     *
     * The Redis factory implementation.
     *
     * @var \Illuminate\Redis\Connections\Connection
     */
    protected $redis;
    /**
     * 任務(wù)存在有效期
     *
     * @var int
     */
    protected $seconds = 600;
    /**
     * 創(chuàng)建任務(wù)
     *
     * @param string $sheet
     * @param int $len 總長(zhǎng)度
     * @return string
     */
    public function createTask($sheet = '', $len = 100)
    {
        $sheet = $sheet ?: $this->sheet();
        $detail = [
            //  開(kāi)始時(shí)間
            'begin' => time(),
            //  標(biāo)記號(hào)
            'sheet' => $sheet,
            //  總長(zhǎng)度
            'total_len' => $len,
            //  當(dāng)前長(zhǎng)度
            'schedule' => 0
        ];
        //  主體信息
        $this->connect()->setex($this->prefix. ':'. $sheet, $this->seconds, serialize($detail));
        //  初始化任務(wù)進(jìn)度
        $this->connect()->setex($this->prefix. ':schedule:'. $sheet, $this->seconds, 1);
        return $sheet;
    }
    /**
     * 設(shè)置任務(wù)內(nèi)容
     *
     * @param $sheet
     * @param $value
     * @return MissionFrom
     */
    public function setTaskContent($sheet, $value)
    {
        if( $this->connect()->exists($this->prefix. ':'. $sheet)){
            $this->connect()->setex($this->prefix. ':content:'. $sheet, $this->seconds, serialize($value));
        }
        return $this;
    }
    /**
     * 獲取任務(wù)內(nèi)容
     *
     * @param $sheet
     * @return MissionFrom
     */
    public function getTaskContent($sheet)
    {
        return empty($data = $this->connect()->get($this->prefix. ':content:'. $sheet)) ? null : unserialize($data);
    }
    /**
     * 設(shè)置任務(wù)前綴
     *
     * @param string $prefix
     * @return $this
     */
    public function setPrefix($prefix = '')
    {
        $this->prefix = 'school:task:'. ($prefix ?: 'default');
        return $this;
    }
    /**
     * 任務(wù)詳情
     *
     * @param string $sheet
     * @return array
     */
    public function taskDetail($sheet = '')
    {
        $detail = $this->connect()->get($key = ($this->prefix. ':'. $sheet));
        if( !empty($detail)){
            $this->original = array_merge( unserialize($detail), [
                'schedule' => (int)$this->getSchedule($sheet),
                'content' => $this->getTaskContent($sheet)
            ]);
        }
        return (array) $this->original;
    }
    /**
     * 進(jìn)度遞增
     *
     * @param string $sheet
     * @return int
     */
    public function increments($sheet = '')
    {
        $inc = 0;
        if( !empty($detail = $this->taskDetail($sheet)) &&
            $detail['schedule'] < $detail['total_len']){
            $inc = $this->connect()->incr($this->prefix. ':schedule:'. $sheet);
        }
        return $detail['schedule'] ?? $inc;
    }
    /**
     * 獲取任務(wù)進(jìn)度
     *
     * @param string $sheet
     * @return string
     */
    public function getSchedule($sheet = '')
    {
        return $this->connect()->exists($key = ($this->prefix. ':schedule:'. $sheet)) ? $this->connect()->get($key) : 0;
    }
    /**
     * 生成任務(wù)單號(hào)
     */
    private static function sheet()
    {
        return md5(\Hash::make(date('YmdHis')));
    }
    /**
     * 所有任務(wù)進(jìn)度
     *
     * @return array
     */
    public function taskAll()
    {
        $task_group_list = [];
        //  分組
        foreach( (array)$this->connect()->keys('school:task:*') as $task) {
            if( count($task_item = explode(':', $task)) == 4){
                list($model, $model_name, $business, $key) = $task_item;
                $task_group_list[$business][] = $this->setPrefix($business)->taskDetail($key);
            }
        }
        return $task_group_list;
    }
    /**
     * @return \Illuminate\Foundation\Application|mixed
     */
    public function connect()
    {
        return app('redis.connection');
    }
}

調(diào)用過(guò)程如下

<?php
namespace App\Jobs;
use App\Lib\Support\MissionFrom;
use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
/**
 * Excel 導(dǎo)入
 *
 * Class importExcel
 * @package App\Jobs
 */
class importExcel implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels, MissionFrom;
    /**
     * 任務(wù)運(yùn)行的超時(shí)時(shí)間。
     *
     * @var int
     */
    public $timeout = 300;
    /**
     * @var string
     */
    public $sheet;
    /**
     * importExcel constructor.
     * @param $sheet
     */
    public function __construct($sheet = '')
    {
        $this->sheet = $sheet;
    }
    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        //  自定義業(yè)務(wù)前綴
        $prefix = 'export_students';
        //  創(chuàng)建任務(wù)進(jìn)度
        $this->sheet = $this->setPrefix($prefix)->createTask($this->sheet, 20);
        //  開(kāi)始執(zhí)行任務(wù)
        echo '任務(wù)開(kāi)始:'. $this->sheet. "\n";
        for ($i = 1; $i <= 20; $i++){
            //  延時(shí)模擬長(zhǎng)時(shí)間任務(wù)
            sleep(rand(1, 2));
            //  進(jìn)度 +1
            echo '任務(wù)進(jìn)度:'. ($this->setPrefix($prefix)->increments($this->sheet)). "\n";
        }
        //  追加結(jié)果 任何類型
        $this->setPrefix($prefix)->setTaskContent($this->sheet, [
            'url' => 'http://www.baidu.com'
        ]);
    }
}

控制器部分

....
    /**
     * 學(xué)校pc端后臺(tái)任務(wù)進(jìn)度列表
     *
     * @return array
     */
    public function duties()
    {
        if( empty($key = request('key'))){
            $key = md5(\Hash::make(date('YmdHis')));
            //  創(chuàng)建任務(wù)
            $this->dispatch(new importExcel($key));
            return $key;
        }else{
            //  查詢單條任務(wù)信息
            //  $this->setPrefix('export_students')->taskDetail($key);
            return success(['data' => array_merge([
                //  導(dǎo)出每餐記錄列表
                'meal_records' => [],
                //  每日記錄列表
                'daily_records' => [],
                //  其他記錄列表
                'other_records' => [],
                //  照片庫(kù)
                'photo_gallery' => [],
                //  采購(gòu)計(jì)劃
                'purchasing_plan' => [],
                //  憑證記錄
                'voucher_records' => [],
                //  食材庫(kù)
                'ingredient_records' => [],
                //  導(dǎo)入學(xué)生
                'import_students' => [],
                //  導(dǎo)出學(xué)生
                'export_students' => []
            ], $this->taskAll())]);
        }
    }
    ....

達(dá)到的效果

注意事項(xiàng)

QUEUE_DRIVER=sync 變更為 redis

開(kāi)發(fā)階段強(qiáng)烈建議把 horizon 這玩意兒裝上，Laravel 自帶的報(bào)錯(cuò)異常我實(shí)在無(wú)力吐槽，不方便排錯(cuò).

以上是“Laravel如何讓程序在后臺(tái)執(zhí)行超長(zhǎng)時(shí)間”這篇文章的所有內(nèi)容，感謝各位的閱讀！希望分享的內(nèi)容對(duì)大家有幫助，更多相關(guān)知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！

文章名稱：Laravel如何讓程序在后臺(tái)執(zhí)行超長(zhǎng)時(shí)間
文章鏈接：http://www.js-pz168.com/article40/jhhjho.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站設(shè)計(jì)公司、定制網(wǎng)站、網(wǎng)站維護(hù)、企業(yè)建站、外貿(mào)網(wǎng)站建設(shè)、網(wǎng)站建設(shè)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)