65 lines
1.8 KiB
PHP
65 lines
1.8 KiB
PHP
|
<?php
|
||
|
|
/**
|
||
|
|
* This file is part of webman.
|
||
|
|
*
|
||
|
|
* Licensed under The MIT License
|
||
|
|
* For full copyright and license information, please see the MIT-LICENSE.txt
|
||
|
|
* Redistributions of files must retain the above copyright notice.
|
||
|
|
*
|
||
|
|
* @author walkor<walkor@workerman.net>
|
||
|
|
* @copyright walkor<walkor@workerman.net>
|
||
|
|
* @link http://www.workerman.net/
|
||
|
|
* @license http://www.opensource.org/licenses/mit-license.php MIT License
|
||
|
|
*/
|
||
|
|
namespace Webman\RedisQueue;
|
||
|
|
|
||
|
|
use support\Log;
|
||
|
|
use Workerman\RedisQueue\Client as RedisClient;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Class RedisQueue
|
||
|
|
* @package support
|
||
|
|
*
|
||
|
|
* Strings methods
|
||
|
|
* @method static void send($queue, $data, $delay=0)
|
||
|
|
*/
|
||
|
|
class Client
|
||
|
|
{
|
||
|
|
/**
|
||
|
|
* @var Client[]
|
||
|
|
*/
|
||
|
|
protected static $_connections = null;
|
||
|
|
|
||
|
|
|
||
|
|
/**
|
||
|
|
* @param string $name
|
||
|
|
* @return RedisClient
|
||
|
|
*/
|
||
|
|
public static function connection($name = 'default') {
|
||
|
|
if (!isset(static::$_connections[$name])) {
|
||
|
|
$config = config('redis_queue', config('plugin.webman.redis-queue.redis', []));
|
||
|
|
if (!isset($config[$name])) {
|
||
|
|
throw new \RuntimeException("RedisQueue connection $name not found");
|
||
|
|
}
|
||
|
|
$host = $config[$name]['host'];
|
||
|
|
$options = $config[$name]['options'];
|
||
|
|
$client = new RedisClient($host, $options);
|
||
|
|
if (method_exists($client, 'logger')) {
|
||
|
|
$client->logger(Log::channel('plugin.webman.redis-queue.default'));
|
||
|
|
}
|
||
|
|
static::$_connections[$name] = $client;
|
||
|
|
}
|
||
|
|
return static::$_connections[$name];
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* @param $name
|
||
|
|
* @param $arguments
|
||
|
|
* @return mixed
|
||
|
|
*/
|
||
|
|
public static function __callStatic($name, $arguments)
|
||
|
|
{
|
||
|
|
return static::connection('default')->{$name}(... $arguments);
|
||
|
|
}
|
||
|
|
}
|