34 lines
896 B
PHP
34 lines
896 B
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;
|
|
}
|
|
}
|
|
}
|
|
|
|
?>
|