Predis — это операционная библиотека для подключения php к redis. Поскольку она полностью написана на php, она использует множество функций, таких как пространства имен и замыкания. Она поддерживает только php5.3 и выше. Она проста в использовании, но ее производительность средний. Если вы будете следовать производительности этой части, вы можете изменить ее. Производительность php, написанного на языке C, будет значительно улучшена (например, использование C для расширения phpredis)GitHub.com/owl IE NT/PHP…).
Используйте автозагрузку для загрузки связанных библиотек, основное внимание здесь уделяется требованию $file;
spl_autoload_register ( function ( $class ) {
$file = __DIR__ . '/lib/Predis/' . $class . '.php' ;
if ( file_exists ( $file ) ) {
require $file ;
return true ;
}
} ) ;
Настройте IP, порт и соответствующую базу данных соединения.
$server = array (
'host' => '127.0.0.1' ,
'port' => 6379 ,
'database' => 15
) ;
$redis = new Client ( $server ) ;
Связанные операции
Основная операция
Обычные операции установки/получения
retval = retval ; // показать 'предис'
setex установить продолжительность хранения
$redis -> setex('str', 10, 'bar') ; // Указывает, что срок действия хранилища составляет 10 секунд
setnx/msetnx эквивалентна операции добавления и не перезапишет существующее значение.
redis -> setnx ( 'foo' , 34 ) ; //false
операция getset, вариант set, результат возвращает значение до замены
$redis -> getset('foo', 56);//возврат 34
incrby/incr/decrby/decr значения увеличения и уменьшения
redis -> incrby('foo', 2);//foo равно 59
exists проверяет, существует ли значение
$redis -> exists ( 'foo' ) ; //true
удалить удалить
$redis -> del ( 'foo' ) ; //true
определение типа типа, строка возвращает строку, список возвращает список, набор таблиц возвращает набор/zset, хэш-таблица возвращает хэш
Redis -> установить ('str', 'test'); $redis -> тип ('str');//строка, возвращаемая строка
добавить соединения к существующей строке
$redis -> append('str', '_123') ;//возвращаем накопленную длину строки 8, эта входная строка равна 'test_123'
setrange операция частичной замены
redis -> setrange ('str', 2, 'cd') ; // Возвращаем 4, что означает замену после второго символа, тогда 'str' будет 'abcd'
substr часть получить операцию
$redis -> substr ('str', 0, 2) ; // Указывает, что начиная с 0-го, получить 2-й символ, всего 3, вернуть 'abc'
strlen получает длину строки
$redis -> strlen('str');//вернуть 4
хранение и извлечение битов setbit/getbit
Redis -> getbit('binary', 31);//возврат 1
клавиши Функция нечеткого поиска, поддержка * и ? (совпадение с символом)
redis -> set ( 'foo2' , 456 ) ; redis -> keys('f?o?'); // то же, что и выше
randomkey возвращает случайный ключ
$redis -> randomkey(); //может вернуть 'foo1' или 'foo2' и любой другой ключ, существующий в redis
rename/renamenx переименовать ключ, разница в том, что renamenx не может измениться на существующий ключ
$redis -> rename ('str', 'str2') ; // Изменяем ключ, первоначально названный 'str', на 'str2'
######expire устанавливает своевременность ключ-значение, ttl получает оставшийся срок действия, persist сбрасывает его в постоянное хранилищеRedis -> ttl('foo');//возвращаем допустимое значение 1 с $redis -> expire ('foo'); // отменяем поведение с истекающим сроком действия
######dbsize возвращает общее количество записей в текущей базе данных Redis $redis->dbsize();
####Операции с очередью
rpush/rpushx — это операция с упорядоченным списком, вставляющая элементы из конца очереди, разница между lpush/lpushx и rpush/rpushx в том, что она вставляется в начало очереди, как и выше, «x» означает операцию только на существующих ключах
redis -> lpush('fooList', 'bar0') ;//возвращает список длины 2 $redis -> rpushx('fooList', 'bar2') ;//возвращаем 3, rpushx только добавляет в существующую очередь, иначе возвращает 0
llen возвращает текущую длину списка
$redis -> llen ( 'fooList' ) ; //3
######lrange возвращает элементы диапазона в очередиredis -> lrange('fooList', 0,- 1) ; // Возвращаем 0-й к последнему, что эквивалентно возврату всех элементов. Обратите внимание, что в redis часто используются отрицательные числа, то же самое ниже
lindex возвращает элемент списка в указанной порядковой позиции
$redis -> lindex ('fooList', 1);//возврат 'bar1'
lset изменяет значение в указанной позиции в очереди
$redis -> lset('fooList', 1, '123') ;//Изменяем элемент в позиции 1, возвращаем true
lrem удаляет указанное количество символов слева в очереди
$redis -> lrem ( 'fooList' , 1 , '' ) ; //Удалить 1 символ слева (используйте -1) из очереди'' (если есть)
lpop/rpop извлекает (и удаляет) самый левый или самый правый элемент, как стек
redis -> rpop ( 'fooList' ) ; //'bar2'
Обрезать модификацию очереди, сохранить некоторые элементы слева и удалить остальные
$redis -> ltrim('fooList', 0, 1); // сохраняем элементы с 0-го по 1-й слева
rpoplpush извлекает элементы из одной очереди и помещает их в другую очередь
redis -> rpush ( 'list1' , 'ab1' ) ; redis -> rpush ( 'list2' , 'ab3' ) ; redis -> rpoplpush('list2', 'list2') ; // также относится к той же очереди, перемещаем последний элемент в начало list2 =>array('ab3','ab1','ab2')
linsert вставляет элемент до или после указанного элемента в середине очереди
redis -> linsert('list2', 'after', 'ab1', '456'); // означает вставку '456' после элемента 'ab1'
blpop/brpop блокирует и ждет, пока очередь не станет пустой, а затем выталкивает самый левый или самый правый элемент (можно сказать, что эта функция очень полезна вне php), brpoplpush также блокирует и ждет операции, результат то же, что и рпоплпуш
$redis -> blpop ( 'list3' , 10 ) ;
Если list3 пуст, подождите, пока первый элемент не будет извлечен, если он не пуст, тайм-аут через 10 секунд.
установить табличную операцию
sadd добавляет элементы, возвращает true, repeats возвращает false
redis -> sadd ( 'set1' , 'cd' ) ; $redis -> sadd ( 'set1' , 'ef' ) ;
srem удаляет указанный элемент
$redis -> srem('set1', 'cd') ; // удаляем элемент 'cd'
spop удаляет и возвращает случайный элемент в коллекции
$redis -> spop ( 'set1' ) ;
Smove перемещает указанный элемент текущей таблицы набора в другую таблицу набора
redis->smove('set1', 'set2', 'ab'); //переместить 'ab' в 'set1' на 'set2', вернуть true или false
scard возвращает количество элементов в текущей таблице набора
$redis -> scard ( 'set2' ) ; //2
######sismember Определяет, принадлежит ли элемент к текущей таблице $redis -> sismember('set2', '123');//правда или ложь
smembers возвращает все элементы текущей таблицы
$redis -> smembers ( 'set2' ) ; //array('123','ab');
sinter/sunion/sdiff возвращает пересечение/объединение/дополнение элементов в двух таблицах
Redis -> спекать ('set2', 'set1');//вернуть массив ('ab')
sinterstore/sunionstore/sdiffstore скопировать элементы пересечения/объединения/дополнения двух таблиц в третью таблицу
$redis -> set ( 'foo' , 0 ) ;
$redis -> sinterstore ( 'foo' , 'set1' ) ; //这边等同于将'set1'的内容copy到'foo'中，并将'foo'转为set表
$redis -> sinterstore ( 'foo' , array ( 'set1' , 'set2' ) ) ; //将'set1'和'set2'中相同的元素copy到'foo'表中,覆盖'foo'原有内容
srandmember возвращает случайный элемент в списке
$redis -> srandmember ( 'set1' ) ;
Операции с упорядоченным набором таблиц
Добавьте элементы и установите серийный номер, верните true, повторите, верните false
redis -> zadd ( 'zset1' , 2 , 'cd' ) ; $redis -> zadd ( 'zset1' , 3 , 'ef' ) ;
Zincrby увеличивает или уменьшает значение индекса указанного элемента, изменяя порядок элементов
$redis -> цинкrby('zset1', 10, 'ab') ;//вернуть 11
zrem удаляет указанный элемент
$redis -> zrem ( 'zset1' , 'ef' ) ; //true or false
zrange возвращает элементы указанного диапазона в таблице в позиционном порядке
redis -> zrange('zset1', 0,- 1);//возвращает элемент между позицией 0 и последним элементом (эквивалентно всем элементам)
zrevrange То же, что и выше, возвращает элементы указанного диапазона в таблице в обратном порядке.
$redis -> zrevrange('zset1', 0,- 1);//Порядок элементов противоположен zrange
zrangebyscore/zrevrangebyscore возвращает элементы указанного диапазона индексов в таблице в последовательном/убывающем порядке
$redis -> zadd ( 'zset1' , 3 , 'ef' ) ;
$redis -> zadd ( 'zset1' , 5 , 'gh' ) ;
$redis -> zrangebyscore ( 'zset1' , 2 , 9 ) ; //返回索引值2-9之间的元素 array('ef','gh')
//参数形式
$redis -> zrangebyscore ( 'zset1' , 2 , 9 , 'withscores' ) ; //返回索引值2-9之间的元素并包含索引值 array(array('ef',3),array('gh',5))
$redis -> zrangebyscore ( 'zset1' , 2 , 9 , array ( 'withscores' => true , 'limit' => array ( 1 , 2 ) ) ) ; //返回索引值2-9之间的元素,'withscores' =>true表示包含索引值; 'limit'=>array(1, 2),表示最多返回2条,结果为array(array('ef',3),array('gh',5))
zunionstore/zinterstore сохраняет объединение/пересечение нескольких таблиц в другую таблицу
$redis -> zunionstore ( 'zset3' , array ( 'zset1' , 'zset2' , 'zset0' ) ) ; //将'zset1','zset2','zset0'的并集存入'zset3'
//其它参数
$redis -> zunionstore ( 'zset3' , array ( 'zset1' , 'zset2' ) , array ( 'weights' => array ( 5 , 0 ) ) ) ; //weights参数表示权重，其中表示并集后值大于5的元素排在前，大于0的排在后
$redis -> zunionstore ( 'zset3' , array ( 'zset1' , 'zset2' ) , array ( 'aggregate' => 'max' ) ) ; //'aggregate' => 'max'或'min'表示并集后相同的元素是取大值或是取小值
zcount подсчитывает количество элементов в интервале индекса
redis -> zcount ( 'zset1' , '(3' , 5 ) ) ;//'(3' означает, что значение индекса находится в диапазоне от 3 до 5, но исключает 3. Аналогично, '(5') также может означать, что верхний предел 5, но не включая 5
zcard подсчитывает количество элементов
$redis -> zcard ( 'zset1' ) ; //4
индекс элемента запроса zscore
$redis -> zscore ( 'zset1' , 'ef' ) ; //3
zremrangebyscore удаляет элементы диапазона индекса
$redis -> zremrangebyscore('zset1', 0, 2) ;//Удаляем элементы с индексами от 0 до 2 ('ab', 'cd'), возвращаем количество удаленных элементов 2
zrank/zrevrank возвращает позицию элемента в порядке таблицы/в порядке убывания (не по индексу)
$redis -> zrank('zset1', 'ef') ;//возвращаем 0, потому что это первый элемент; zrevrank возвращает 1 (последний)
zremrangebyrank удаляет элементы в указанном диапазоне позиций в таблице
$redis -> zremrangebyrank('zset1', 0, 10) ;//Удаляем элементы в позициях 0-10 и возвращаем количество удаленных элементов 2
операции с хэш-таблицей
hset/hget получить доступ к данным хеш-таблицы
Redis -> hset('хэш1', 'ключ2', 'v2'); $redis -> hget('hash1', 'key1') ; // Получить значение ключа key1 в таблице hash1 и вернуть v1
hexists возвращает, существует ли указанный ключ в хеш-таблице.
$redis -> hexists ( 'hash1' , 'key1' ) ; //true or false
hdel удаляет элемент с указанным ключом в хеш-таблице
$redis -> hdel ( 'hash1' , 'key2' ) ; //true or false
hlen возвращает количество элементов в хэш-таблице
$redis -> hlen ( 'hash1' ) ; //1
hsetnx добавляет элемент, но не может повторяться
redis -> hsetnx ( 'hash1' , 'key2' , 'v2' ) ; //true
hmset/hmget доступ к нескольким элементам хеш-таблицы
redis -> hmget('hash1', array('key3', 'key4')); //возврат соответствующего массива значений('v3','v4')
hincrby накапливает указанный ключ
Redis -> hincrby('hash1', 'key5', 10);//возврат 13
hkeys возвращает все ключи в хеш-таблице
$redis -> hkeys ('hash1'); // возвращаемый массив ('key1','key2','key3','key4','key5')
//hvals возвращает все значения в хеш-таблице $redis -> hvals ('hash1'); // возвращаемый массив ('v1', 'v2', 'v3', 'v4', 13)
hgetall возвращает весь элемент хэш-таблицы
$redis -> hgetall ('hash1'); // возвращаемый массив ('key1'=>'v1','key2'=>'v2','key3'=>'v3','key4'=>'v4 ','key5'=>13)
Сортировка
сортировать сортировать
$redis -> rpush ( 'tab' , 3 ) ;
$redis -> rpush ( 'tab' , 2 ) ;
$redis -> rpush ( 'tab' , 17 ) ;
$redis -> sort ( 'tab' ) ; //返回array(2,3,17)
//使用参数,可组合使用 array('sort' => 'desc','limit' => array(1, 2))
$redis -> sort ( 'tab' , array ( 'sort' => 'desc' ) ) ; //降序排列,返回array(17,3,2)
$redis -> sort ( 'tab' , array ( 'limit' => array ( 1 , 2 ) ) ) ; //返回顺序位置中1的元素2个(这里的2是指个数,而不是位置),返回array(3,17)
$redis -> sort ( 'tab' , array ( 'limit' => array ( 'alpha' => true ) ) ) ; //按首字符排序返回array(17,2,3),因为17的首字符是'1'所以排首位置
$redis -> sort ( 'tab' , array ( 'limit' => array ( 'store' => 'ordered' ) ) ) ; //表示永久性排序,返回元素个数
$redis -> sort ( 'tab' , array ( 'limit' => array ( 'get' => 'pre_*' ) ) ) ; //使用了通配符'*'过滤元素,表示只返回以'pre_'开头的元素
операции управления Redis
select указывает базу данных для работы
$redis -> select ('mydb') ; // Указываем как mydb, если не существует, создаем
flushdb очищает текущую библиотеку
$redis -> flushdb ( ) ;
move перемещает элементы библиотеки в другую библиотеку
redis -> move('foo', 'mydb2') ;//если существует библиотека 'mydb2'
info показывает информацию о статусе службы
$redis -> info ( ) ;
slaveof настроить подчиненный сервер
redis -> slaveof() ; //Очищаем подчиненный сервер
Синхронно сохранять данные сервера на диск
$redis -> save ( ) ;
Асинхронно сохранять данные сервера на диск
$redis -> bgsave ( ) ;
сохранить данные на диск
$redis -> bgrewriteaof ( ) ;
Возвращает время последнего обновления диска
$redis -> lastsave ( ) ;
установить/получить несколько ключей-значений
$mkv = array (
'usr:0001' => 'First user' ,
'usr:0002' => 'Second user' ,
'usr:0003' => 'Third user'
) ;
$redis -> mset ( $mkv ) ; //存储多个key对应的value
$retval = $redis -> mget ( array_keys ( $mkv ) ) ; //获取多个key对应的value
print_r ( $retval ) ;
Массовые операции
$replies = $redis -> pipeline ( function ( $pipe ) {
$pipe -> ping ( ) ;
$pipe -> flushdb ( ) ;
$pipe -> incrby ( 'counter' , 10 ) ; //增量操作
$pipe -> incrby ( 'counter' , 30 ) ;
$pipe -> exists ( 'counter' ) ;
$pipe -> get ( 'counter' ) ;
$pipe -> mget ( 'does_not_exist' , 'counter' ) ;
} ) ;
print_r ( $replies ) ;
CAS, транзакционная операция
function zpop ( $client , $zsetKey ) {
$element = null ;
$options = array (
'cas' => true , // Initialize with support for CAS operations
'watch' => $zsetKey , // Key that needs to be WATCHed to detect changes
'retry' => 3 , // Number of retries on aborted transactions, after
// which the client bails out with an exception.
) ;
$txReply = $client -> multiExec ( $options , function ( $tx )
use ( $zsetKey , & $element ) {
@ list ( $element ) = $tx -> zrange ( $zsetKey , 0 , 0 ) ;
if ( isset ( $element ) ) {
$tx -> multi ( ) ; // With CAS, MULTI *must* be explicitly invoked.
$tx -> zrem ( $zsetKey , $element ) ;
}
} ) ;
return $element ;
}
$zpopped = zpop ( $redis , 'zset' ) ;
echo isset ( $zpopped ) ? "ZPOPed $zpopped" : "Nothing to ZPOP!" , "\n" ;
Добавьте префикс к ключу доступа, например: 'nrk:'
$redis -> getProfile ( ) -> setPreprocessor ( new KeyPrefixPreprocessor ( 'nrk:' ) ) ;
Некоторые методы распределенного хранения
$multiple_servers = array (
array (
'host' => '127.0.0.1' ,
'port' => 6379 ,
'database' => 15 ,
'alias' => 'first' ,
) ,
array (
'host' => '127.0.0.1' ,
'port' => 6380 ,
'database' => 15 ,
'alias' => 'second' ,
) ,
) ;
use Predis\Distribution\IDistributionStrategy ;
class NaiveDistributionStrategy implements IDistributionStrategy {
private $_nodes , $_nodesCount ;
public function __constructor ( ) {
$this ->_nodes = array ( ) ;
$this ->_nodesCount = 0 ;
}
public function add ( $node , $weight = null ) {
$this ->_nodes [ ] = $node ;
$this ->_nodesCount ++;
}
public function remove ( $node ) {
$this ->_nodes = array_filter ( $this ->_nodes , function ( $n ) use ( $node ) {
return $n !== $node ;
} ) ;
$this ->_nodesCount = count ( $this ->_nodes ) ;
}
public function get ( $key ) {
$count = $this ->_nodesCount ;
if ( $count === 0 ) {
throw new RuntimeException ( 'No connections' ) ;
}
return $this ->_nodes [ $count > 1 ? abs ( crc32 ( $key ) % $count ) : 0 ] ;
}
public function generateKey ( $value ) {
return crc32 ( $value ) ;
}
}
Настройка политики распространения ключей
$options = array (
'key_distribution' => new NaiveDistributionStrategy ( ) ,
) ;
$redis = new Predis\Client ( $multiple_servers , $options ) ;
for ( $i = 0 ; $i set ( "key:$i" , str_pad ( $i , 4 , '0' , 0 ) ) ;
$redis -> get ( "key:$i" ) ;
}
$server1 = $redis -> getClientFor ( 'first' ) -> info ( ) ;
$server2 = $redis -> getClientFor ( 'second' ) -> info ( ) ;
printf ( "Server '%s' has %d keys while server '%s' has %d keys.\n" ,
'first' , $server1 [ 'db15' ] [ 'keys' ] , 'second' , $server2 [ 'db15' ] [ 'keys' ]
) ;