79 lines
2.3 KiB
PHP
79 lines
2.3 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 Workerman\Timer;
|
|
|
|
/**
|
|
* Class RedisQueue
|
|
* @package support
|
|
*
|
|
* Strings methods
|
|
* @method static bool send($queue, $data, $delay=0)
|
|
*/
|
|
class Redis
|
|
{
|
|
/**
|
|
* @var RedisConnection[]
|
|
*/
|
|
protected static $_connections = [];
|
|
|
|
/**
|
|
* @param string $name
|
|
* @return RedisConnection
|
|
*/
|
|
public static function connection($name = 'default') {
|
|
if (!isset(static::$_connections[$name])) {
|
|
$configs = config('redis_queue', config('plugin.webman.redis-queue.redis', []));
|
|
if (!isset($configs[$name])) {
|
|
throw new \RuntimeException("RedisQueue connection $name not found");
|
|
}
|
|
$config = $configs[$name];
|
|
static::$_connections[$name] = static::connect($config);
|
|
}
|
|
return static::$_connections[$name];
|
|
}
|
|
|
|
protected static function connect($config)
|
|
{
|
|
if (!extension_loaded('redis')) {
|
|
throw new \RuntimeException('Please make sure the PHP Redis extension is installed and enabled.');
|
|
}
|
|
|
|
$redis = new RedisConnection();
|
|
$address = $config['host'];
|
|
$config = [
|
|
'host' => parse_url($address, PHP_URL_HOST),
|
|
'port' => parse_url($address, PHP_URL_PORT),
|
|
'db' => $config['options']['database'] ?? $config['options']['db'] ?? 0,
|
|
'auth' => $config['options']['auth'] ?? '',
|
|
'timeout' => $config['options']['timeout'] ?? 2,
|
|
'ping' => $config['options']['ping'] ?? 55,
|
|
'prefix' => $config['options']['prefix'] ?? '',
|
|
];
|
|
$redis->connectWithConfig($config);
|
|
return $redis;
|
|
}
|
|
|
|
/**
|
|
* @param $name
|
|
* @param $arguments
|
|
* @return mixed
|
|
*/
|
|
public static function __callStatic($name, $arguments)
|
|
{
|
|
return static::connection('default')->{$name}(... $arguments);
|
|
}
|
|
}
|