point_mall_admin/extend/mall/queue/QueueClient.php

<?php
namespace mall\queue;
use app\common\logic\Queue;
use think\facade\Cache;
class QueueClient {


    /**
     * 入列
     * @param string $key
     * @param array $value
     */
    public static function push($key, $value) {
        if(config('cache.stores.file.type') == 'redis'){
            //Redis 直接写入缓存
            $num=Cache::get('QueueClientNum');
            if(!$num){
                $num=1;
            }else{
                $num++;
            }
            $QueueClientNum = Cache::set('QueueClientNum',$num);#缓存的数量
            cache('QueueClient_'.$QueueClientNum, serialize(array($key=>$value)));#写入缓存
        }
        if (config('cache.stores.file.type') == 'File') {
            //当前缓存类型为本地文件,则直接执行
            $QueueLogic = new Queue();
            $QueueLogic->$key($value);return;
        }
    }
}

?>