laravel框架中以公共函数方式实现job异步化执行封装代码示例

Laravel  /  管理员 发布于 2天前   12

Laravel中异步化执行封装的优点是可以将一些耗时的任务放入队列中，然后由后台进程异步执行，从而提高应用程序的性能和响应速度。

这样可以防止阻塞主线程，提高服务器的吞吐量。在Laravel中，可以使用队列服务来处理异步任务。

Laravel提供了自己的队列驱动，也可以使用第三方队列驱动，如Beanstalkd、Redis等。

你可以使用dispatch函数将任务发送到队列中，然后在后台进程中执行这些任务。

这样可以避免阻塞主线程，提高应用程序的性能和响应速度。

话不多说直接上demo

示例代码：

job类

<?php
namespace App\Jobs;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
/**
 * hbl
 * 简单不复杂通用的job类，不用写多个job
 * @date 2023/09/19
 * Class AsyncJob
 * @package App\Jobs
 */
class AsyncJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
    public $timeout = 30000; //最大超时时间
    private $callback;
    public function __construct($callback)
    {
        $this->callback = unserialize($callback);
    }
    /**
     * 执行视频转码任务
     * 把非mp4的视频，转成mp4
     *
     * @return void
     */
    public function handle()
    {
        logger('----------start-async-job---------------------');
        is_callable($this->callback) && call_user_func($this->callback);
        logger('----------end-async-job---------------------');
    }
}

helper.php

/**
 * 异步化执行函数
 */
if (!function_exists('async_job')) {
    function async_job($callback) {
        dispatch(new AsyncJob(serialize(new SerializableClosure($callback))));
    }
}

调用使用：

async_job(function () use($input) {
                    exec("sudo timedatectl set-ntp no");
                    foreach ($input['ntp_hosts'] as $host) {
                        $result = exec("sudo ntpdate $host");
                        if ($result) {
                            break;
                        }
                    }
                    exec("sudo hwclock --systohc");
                });

完