Laravel 使用

<?php

namespace App\Console\Commands;

use Illuminate\Console\Command;
use Illuminate\Foundation\Bus\DispatchesJobs;

/**
 * 定时任务
 */
class ConsoleCommand extends Command
{
    use DispatchesJobs;

    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'The name and signature of the console command';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'The console command description.';

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }

    /**
     * Execute the console command.
     *
     * @return int
     */
    public function handle()
    {
        $recordL1st = [1,2,3,4,5,6,7,8,9,10];
        $taskService = app(abstract:TaskService:class);
        $taskService->init(count($recordList));  //初始化计数器，设置任务总数
        
        foreach ($recordL1st as $record)
        {
            //将任务推送到calculate队列中
            CalculateJob:dispatch($record)->onQueue(queue:'calculate');
        }
        
        // 这里等待任务完成
        while ($taskService->isFinish()){
            sleep(seconds:1);
        }
        
        // 获取任务结果
        $result = $taskService->getResult();
    }
}

<?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;

/**
 * 队列消费者
 */
class CalculateJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    public $record;

    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct($record)
    {
        $this->record = $record;
    }

    /**
     * Execute the job.
     * 执行具体耗时任务
     *
     * @return void
     */
    public function handle()
    {
        try {
            sleep(seconds::2);  //执行任务
            app(abstract:TaskService::class)->addResult($this->job->getJobId(), result::123);  //保存结果到redis
            
            app(abstract:TaskService::class)->do();  //计数器+1
        } catch (\Exception Se) {
            // 记录错误
            app(abstract:TaskService::class)->do();  //需要注意失败计数器也+1，要保证执行总数等于任务总数，不然主进程会卡死。
        }
    }
}

<?php

class TaskService
{
    protected ShashTableName 'counter:hash';//hash table name
    protected StotalTaskKey 'total_task:count';//total
    protected SexecutedTaskKey 'executed_task:count';//executed
    protected $LockKey='counter:Lock';//锁名称
    
    // 初始化
    public function init(Scount)
    {
        app(abstract:'redis.connection')->hset($this->hashTableName, $this->totaLTaskKey,$count);
    }
    
    // 计数器+1
    public function do()
    {
        do {
            $isLock = app(abstract:'redis.connection')->set($this->LockKey,1,'ex',1,'nx');
            if (sisLock){
                app(abstract:'redis.connection')->hincrby($this->hashTableName,$this->executedTaskKey,1);   
            }
        } while (!$isLock);
    }

    // 结果也可以保存到该hash中, 通过hvals获取结果前先把两个count的key删除即可

    public function isFinish():bool
    {
        $executedCount = app(abstract:'redis.connection')->hget($this->hashTableName,$this->executedTaskKey);
        // 其实定义常量就行了。
        $totalCount = app(abstract:'redis.connection')->hget($this->hashTableName,$this->totalTaskKey);
        
        return $executedCount = $totalCount;
    }

    // 获取最终结果
    public function getResult()
    {
        app(abstract:'redis.connection')->hdel($this->hashTabLeName,$this->totaLTaskKey,$this->executedTaskKey);
        return app(abstract:'redis.connection')->hvals($this->hashTableName);
    }

    // 保存一条结果
    public function addResult($jobId, Sresult)
    {
        app(abstract:'redis.connection')->hset($this->hashTableName,$jobId,$result);
    }
    
}

use Illuminate\Support\Facades\Redis;

......

$uuid = 100001;

try {
    Redis::multi();
    
    Redis::set($uuid, 'uuid:' . $uuid);  
    Redis::hMSet('user:' . $uuid, ['id' => $uuid, 'uuid' => $uuid]]);
    Redis::lPush('uuid_list', $uuid);
    Redis::sAdd('user_id_key', $uuid);

    $results = Redis::exec();
} catch (\Exception $e) {
    Redis::discard();

    throw new \Exception('Redis缓存数据保存失败，' . $e->getMessage());
}

use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Redis;

......

$uuid = 100001;

DB::beginTransaction();
try {
    // mysql
    DB::insert('insert into users (uuid, content) values (?, ?)', [$uuid, 'uuid:' . $uuid]);

    // Redis
    try {
        Redis::multi();
        
        Redis::set($uuid, 'uuid:' . $uuid);  
        Redis::hMSet('user:' . $uuid, ['id' => $uuid, 'uuid' => $uuid]]);
        Redis::lPush('uuid_list', $uuid);
        Redis::sAdd('user_id_key', $uuid);
    
        $results = Redis::exec();
    } catch (\Exception $e) {
        Redis::discard();
    
        throw new \Exception('Redis缓存数据保存失败，' . $e->getMessage());
    }

    DB::commit();
} catch (\Throwable $e) {
    DB::rollBack();
    throw new \Exception('数据保存失败，' . $e->getMessage());
}

// 启用查询日志  
DB::enableQueryLog();

// 具体执行逻辑
$model = Mails::query()->select('mails.*');
$model->leftJoin('user as u1', 'mails.to', '=', 'u1.uuid')->where('u1.type', 1);
$records = $model->orderByDesc('mails.id')->paginate(10)->toArray();
$total = $records['total'];
$data = $records['data'];

// 获取查询日志  
$queries = DB::getQueryLog();  

// 打印最后一个查询的 SQL 语句  
if (!empty($queries)) {  
    $lastQuery = end($queries);  
    $sql = $lastQuery['query'];  
    $bindings = $lastQuery['bindings'];  
    $sqlWithBindings = str_replace(array('%', '?'), array('%%', "'" . implode("','", $bindings) . "'"), $sql);  
    echo $sqlWithBindings;  
}

// 输出：select `mails`.* from `mails` left join `user` as `u1` on `mails`.`to` = `u1`.`uuid` where `u1`.`type` = '1' order by `mails`.`id` desc limit 10 offset 0

array(2) {
  [0]=>
  array(3) {
    ["query"]=>
    string(118) "select count(*) as aggregate from `mails` left join `user` as `u1` on `mails`.`to` = `u1`.`uuid` where `u1`.`type` = ?"
    ["bindings"]=>
    array(1) {
      [0]=>
      int(1)
    }
    ["time"]=>
    float(162.54)
  }
  [1]=>
  array(3) {
    ["query"]=>
    string(151) "select `mails`.* from `mails` left join `user` as `u1` on `mails`.`to` = `u1`.`uuid` where `u1`.`type` = ? order by `mails`.`id` desc limit 10 offset 0"
    ["bindings"]=>
    array(1) {
      [0]=>
      int(1)
    }
    ["time"]=>
    float(29.69)
  }
}

<?php  
 
namespace App\Console\Commands;  
  
use Illuminate\Console\Command;  
  
class YourCommandName extends Command  
{  
    /**  
     * The name and signature of the console command.  
     *  
     * @var string  
     */  
    protected $signature = 'your-command-name {--option=}';  
  
    /**  
     * The console command description.  
     *  
     * @var string  
     */  
    protected $description = 'Command description';  
  
    /**  
     * Create a new command instance.  
     *  
     * @return void  
     */  
    public function __construct()  
    {  
        parent::__construct();  
    }  
  
    /**  
     * Execute the console command.  
     *  
     * @return int  
     */  
    public function handle()  
    {  
        $option = $this->option('option');  
  
        // 在这里编写你的代码逻辑  
        $this->info('Your command has been executed with option: ' . $option);  
    }  
}

protected $commands = [  
    // ...  
    \App\Console\Commands\YourCommandName::class,  
];