PHP が Redis に接続するための predis 操作の完全なコレクション-PHPチュートリアル-php.cn

predis は、PHP が Redis に接続するための操作ライブラリです。完全に PHP で書かれており、多くの名前空間とクロージャーを使用するため、PHP5.3 以降のみをサポートします。そのため、測定されたパフォーマンスは平均で 25,000 回の読み取りと書き込みです。毎秒 c に変更されると思います。この言語で書かれた PHP は、拡張後 (たとえば、C を使用して phpredis https://github.com/owlient/phpredis を拡張する) にパフォーマンスが大幅に向上します。

セッションデータを Redis に保存するのも非常に簡単です:
session.save_handler = redis
session.save_path = “tcp://127.0.0.1:6379”

以下はいくつかの操作の概要であり、継続的に更新されます。

//autoload を使用して関連ライブラリをロードします。ここでの焦点は $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);
//通常の set/get 操作
$redis->set('library', 'predis');
$retval = $redis- > ;get('library');
echo $retval; //'predis' を表示
//setex 保存時間制限を設定します
$redis->setex('str', 10, 'bar');ストレージの有効期間が 10 秒であることを示します
//setnx/msetnx は add 操作と同等であり、既存の値を上書きしません
$redis->setnx('foo',12); //true
$redis ->setnx( 'foo',34); //false
//set の変形である getset 操作、結果は置換前の値を返します
$redis->getset('foo',56);/ /returns 34
// incrby/incr/decrby/decr 値を増減します
$redis->incr('foo') //foo は 57
$redis->incrby('foo',2) ); //foo は 59
//exists は特定の値が存在するかどうかを検出します
$redis->exists('foo');//true
//del は削除します
$redis->del('foo ');//true
//型の検出、文字列は文字列を返し、リストはリストを返し、セットテーブルはset/zsetを返し、ハッシュテーブルはハッシュを返します
$redis->type('foo');//ではありません存在し、なしを返します
$redis ->set('str','test');
$redis->type('str'); //文字列、文字列を返します
//既存の文字列に接続を追加します
$redis-> ;append('str','_123'); //蓄積された文字列長 8 を返します、今回は str は 'test_123' です
//setrange 部分置換操作
$redis->setrange(' str', 0,'abc'); //Return 3、パラメータ 2 が 0 の場合、set 操作と同等
$redis->setrange('str',2,'cd');//Return 4、つまり、文字の後の 2 番目の Replace から開始すると、'str' は 'abcd' になります
//取得操作の substr 部分
$redis->substr('str',0,2);// 0番目から始まり0番目までの2文字、合計3個を取得するという意味です return 'abc'
//strlen 文字列の長さを取得します
$redis->strlen('str'); //Return 4
/ /setbit/getbit ビットの保存と取得
$redis->setbit('binary',31,1); // ビッグエンディアンまたはスモールエンディアンの問題があることを示します。問題はありません。getbit では問題ありません。
$redis-> ;getbit('binary',31); //return 1
//keys は * 記号と ? 記号をサポートします。 Character)
$redis->set('foo1',123);
$redis->set('foo2',456);
$redis->keys('foo*'); // を返します。 foo1 と foo2 の配列
$redis->keys('f?o?' ); //上記と同じ
//randomkey はランダムにキーを返します
$redis->randomkey(); //返される場合もあります'foo1' または 'foo2'、または redis に存在するその他のキー
//rename /renamenx キーの名前を変更します。違いは、renamenx では既存のキーへの変更が許可されていないことです
$redis->rename('str' ,'str2'); //もともと 'str' という名前のキーを 'str2' に変更します
//expire はキーと値の適時性を設定し、ttl は残りの有効期間を取得し、persist は永続ストレージにリセットされます
$redis- >expire('foo', 1); //有効期間を 1 秒に設定します
$redis->ttl('foo'); //有効期間の値 1s を返します
$redis->expire(' foo'); //期限切れ動作をキャンセルします
//dbsize 現在の Redis データベース内のレコードの総数を返します
$redis->dbsize();
/*
Queue オペレーション
*/
// rpush/rpushx 順序付きリスト操作、キューから要素を挿入します
//lpush/lpushx rpush/rpushx の違いは挿入です。上記と同じようにキューの先頭に移動します。「x」は既存のキーのみを操作することを意味します
$ redis->rpush('fooList', 'bar1'); //長さ 1 のリストを返します
$redis->lpush('fooList', 'bar0'); //リストの長さ 2 を返します
$redis->rpushx('fooList', 'bar2'); //3 を返します。rpushx は既存のキューでのみ機能します。加算、それ以外の場合は 0 を返します
//llen は現在のリストの長さを返します
$redis->llen(' fooList');//3
//lrange はキュー内の範囲の要素を返します
$redis->lrange( 'fooList',0,1); //返される配列には、次の合計 2 つの要素が含まれます。 0 番目から 1 番目まで
$redis->lrange('fooList',0,-1); // 0 番目から最後のものを返すことは、redis では負の数値がよく使用されることに注意してください。以下同様
//lindexは指定されたシーケンス位置のリスト要素を返します
$redis->lindex('fooList',1); //Return 'bar1'
//lset の指定された位置の値を変更しますthe queue
$redis->lset('fooList',1,'123');//位置 1 の要素を変更し、true を返します
/ /lrem キューの左から指定された数の文字を削除します
$redis->lrem('fooList',1,'_'); //キュー (存在する場合) の左から 1 文字 '_' を削除します (右から -1 を使用します)
//lpop/ rpop はスタック構造と同様に左端または右端の要素をポップ (および削除) します
$redis->lpop('fooList'); //'bar0'
$redis- >rpop('fooList'); //' bar2'
//ltrim キューの変更、左からいくつかの要素を保持し、残りを削除
$redis->ltrim('fooList', 0,1) //左から0番目から1番目の要素を保持する
//rpoplpush は、あるキューから要素をポップし、別のキューにプッシュします
$redis->rpush('list1','ab0');
$redis-> ;rpush('list1','ab1');
$redis->rpush('list2','ab2');
$redis->rpush('list2','ab3');
$redis->rpoplpush('list1','list2');//結果 list1 =>array('ab0'),list2 =>array('ab1','ab2','ab3')
$ redis->rpoplpush('list2','list2');//同じキューにも適用され、最後の要素を先頭に移動 list2 =>array('ab3','ab1','ab2')
//linsert はキューの途中で指定された要素の前または後に要素を挿入します
$redis->linsert('list2', 'before','ab1','123') //要素 'ab1 の前を示します' Insert '123'
$redis->linsert('list2', 'after','ab1','456') //要素 'ab1' の後に '456' を挿入することを示します
//blpop/brpop のブロックそして、キューが空でなくなるまで待ってから、左端または右端の要素をポップアウトします (この関数は、PHP 以外では非常に便利であると言えます)
//brpoplpush もブロックして操作を待ちます。結果は次と同じです。 rpoplpush
$redis ->blpop('list3',10); //list3 が空の場合、空でない場合は最初の要素がポップされるまで待機します
/**
テーブル操作の設定
*/
/ /sadd は要素を追加し、true を返し、false を繰り返し返します
$redis->sadd('set1','ab');
$redis->sadd('set1','cd');
$ redis->sadd('set1','ef');
//srem 指定された要素を削除します
$redis->srem('set1','cd') //「cd」要素を削除します
//spop 最初の要素をポップします
$redis->spop('set1');
//smove 現在のセットテーブルの指定された要素を別のセットテーブルに移動します
$redis->sadd('set2' ,'123');
$redis->smove('set1','set2','ab');//'set1' の 'ab' を 'set2' に移動し、true または false を返します
// scard は現在のセットテーブルを返します要素の数
$redis->scard('set2');//2
//sismember 要素が現在のテーブルに属しているかどうかを判断します
$redis->sismember('set2' ,'123'); //true または false
//smembers は現在のテーブルのすべての要素を返します
$redis->smembers('set2'); //array('123','ab');
//sinter/sunion/sdiff は、テーブル内の要素の交差/和集合/補数を 2 つ返します
$redis->sadd('set1','ab');
$redis->sinter('set2' ,'set1'); //配列 ('ab') を返します
//sinterstore/sunionstore/sdiffstore 2 つのテーブルの交差/和集合/補要素を 3 番目のテーブルにコピーします
$redis->set('foo) ',0);
$ redis->sinterstore('foo','set1'); //これは、'set1' の内容を 'foo' にコピーし、'foo' を set テーブルに変換することと同等です
$ redis->sinterstore ('foo',array('set1','set2')); //'set1' と 'set2' の同じ要素を 'foo' テーブルにコピーし、'foo' の元の内容を上書きします。 '
// srandmember はテーブル内のランダムな要素を返します
$redis->srandmember('set1');
/**
オーダーセットテーブルオペレーション
*/
//sadd は要素を追加し、シリアル番号を設定します、 true を返し、繰り返し false を返します
$ redis->zadd('zset1',1,'ab');
$redis->zadd('zset1',2,'cd');
$redis-> ;zadd('zset1',3, 'ef');
//zincrby は、指定された要素のインデックス値を増減し、要素の順序を変更します
$redis->zincrby('zset1',10, 'ab');//11 を返します
// zrem は指定された要素を削除します
$redis->zrem('zset1','ef'); //true または false
//zrange は、テーブル内の指定された範囲を位置順に並べます
$redis->zrange( 'zset1',0,1); //位置 0 と 1 の間の要素を返します (2 つ)
$redis->zrange('zset1', 0,-1); //位置 0 と最後の要素を返します 1 つの要素の間の要素 (すべての要素に相当)
//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 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 の間の要素を返します。 true はインデックス値を含むことを意味し、'limit'=>array(1, 2) は最大 2 つの項目を返すことを意味し、結果は array(array('ef',3),array('gh',5)) になります。
//zunionstore/zinterstore 複数のテーブルの結合/交差を別のテーブルに格納します
$redis-> 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' => は、結合後の同じ要素は大きい値または小さい値を取ります
//zcount はインデックス範囲内の要素の数をカウントします
$redis ->zcount('zset1',3,5);//2
$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 は、指定された位置範囲の要素を削除しますtable
$redis- >zremrangebyrank('zset1',0,10); //位置 0 ～ 10 の要素を削除し、削除された要素の数 2 を返します
/**
ハッシュテーブル操作
*/
//hset /hget ハッシュテーブルのデータにアクセス
$redis->hset('hash1','key1','v1'); //キー 'key1' と値 'v1' を持つ要素をハッシュ 1 テーブルに保存します
$redis-> ; hset('hash1','key2','v2');
$redis->hget('hash1','key1'); // テーブル 'hash1' のキー 'key1' の値を取得して返します。 ' v1'
//hexists 指定されたキーがハッシュテーブルに存在するかどうかを返します
$redis->hexists ('hash1','key1'); //true または false
//hdel で指定されたキーを削除しますハッシュテーブル要素
$redis->hdel('hash1','key2'); //true または false
//hlen はハッシュテーブル要素の数を返します
$redis->hlen('hash1') ; //1
//hsetnx は要素を追加しますが、繰り返すことはできません
$redis->hsetnx('hash1','key1','v2') //false
$redis->hsetnx(' hash1','key2 ','v2'); //true
//hmset/hmget ハッシュテーブルの複数の要素にアクセスします
$redis->hmset('hash1',array('key3'=>') v3',' key4'=>'v4'));
$redis->hmget('hash1',array('key3','key4')); //対応する値を返します array('v3') ,'v4' )
//hincrby は指定されたキーを蓄積します
$redis->hincrby('hash1','key5',3); //3 を返します
$redis->hincrby('hash1',' key5', 10); //Return 13
//hkeys ハッシュテーブル内のすべてのキーを返します
$redis->hkeys('hash1') //Return array('key1','key2','key3); ',' key4','key5')
//hvals ハッシュテーブル内のすべての値を返します
$redis->hvals('hash1') //Return array('v1','v2', 'v3',' v4',13)
//hgetall はハッシュテーブル要素全体を返します
$redis->hgetall('hash1') //array('key1'=>'v1',' を返します) key2'=>' v2','key3'=>v3','key4'=>'v4','key5'=>13)
/**
並べ替え操作
*/
/ /sort ソート
$redis ->rpush('tab',3);
$redis->rpush('tab',2);
$redis->rpush('tab',17);
$ redis->sort( 'tab'); //配列(2,3,17)を返します
//パラメータを使用できます、array('sort' => 'desc','limit' => 配列(1, 2))
$redis->sort('tab',array('sort' => 'desc')) //降順に並べて、array(17,3,2)を返します
$ redis->sort('tab ',array('limit' => array(1, 2))); //連続した位置にある 1 の 2 つの要素を返します (ここでの 2 は位置ではなく数値を指します)、 return array(3,17 )
$redis->sort('tab',array('limit' => array('alpha' => true))); // 最初の文字でソートして return array( 17,2,3), 17 の最初の文字が '1' なので、1 位になります
$redis->sort('tab',array('limit' => array('store' => 'owned'))); // 永続的なソートを表し、要素の数を返します
$redis->sort('tab',array('limit' => array('get' => 'pre_*') ))); //ワイルドカードが使用されます '*' フィルター要素は 'pre_' で始まる要素のみを返すことを意味します
/**
redis 管理操作
*/
//select は操作するデータベースを指定します
$redis-> select('mydb'); / /mydb として指定し、存在しない場合は作成します
//flushdb 現在のライブラリをクリアします
$redis->flushdb();
//move の要素を移動します現在のライブラリを他のライブラリに移動
$redis->set('foo ', 'bar');
$redis->move('foo', 'mydb2') //'mydb2' ライブラリが存在する場合
//info はサービスのステータス情報を表示します
$redis->info( ; //サーバーをクリアします
//サーバーのデータをディスクに同期的に保存します
$redis->save();
//サーバーのデータをディスクに保存します非同期的に
$redis->bgsave();
//??
$redis->gt;bgrewriteaof();
//ディスクが最後に更新された時刻を返します
$redis->lastsave();
//複数の Key-Value を設定/取得します
$mkv = array(
'usr: 0001' => '最初のユーザー',
'usr:0002' => '2 番目のユーザー',
'usr:0003' = > '3 番目のユーザー'
);
$redis->mset($mkv ); //複数のキーに対応するストレージ値
$retval = $redis->mget(array_keys($mkv)) / /複数のキーに対応する値を取得
print_r($retval);
//バッチ操作
$replies = $redis->pipeline(function($pipe) {
$pipe->ping();
$pipe->flushdb();
$pipe->incrby('counter', 10); //インクリメント操作
$pipe->incrby('counter', 30);
$pipe->exists ('カウンター');
$pipe->get('カウンター');
$pipe->mget('does_not_exist', 'counter');
});
print_r($replies);
//CAS,事务性操作
function zpop($client, $zsetKey) {
$element = null;
$options = array(
'cas' => true , // CAS 操作をサポートして初期化します
'watch' => $zsetKey, // 変更を検出するために監視する必要があるキー
'retry' => 3, // 中止されたトランザクションの再試行回数
; // クライアントは例外で救済します。
);
$txReply = $client->multiExec($options, function($tx)
use ($zsetKey, &$element) {
@list($ element) = $tx->zrange($zsetKey, 0, 0);
if (isset($element)) {
$tx->multi(); // CAS では、MULTI を明示的に呼び出す必要があります。 .
$tx->zrem($zsetKey, $element);
}
});
return $element;
}
$zpopped = zpop($redis, 'zset');
echo isset($zpopped) ? "ZPOPed $zpopped" : "ZPOP には何もありません!", "n";
//对存取的キー加前缀,如: 'nrk:'
$redis->getProfile()->setPreprocessor(new KeyPrefixPreprocessor('nrk:'));
// 分散形式で保存されるいくつかの方法
$multiple_servers = array(
array(
'host' => '127.0.0.1',
'port' => 6379,
'データベース' => 15,
'エイリアス' => '最初',
),
'ホスト' => '127.0.0.1',
'ポート' => 6380,
'データベース' => 15,
'エイリアス' => 'セカンド',
),
);
PredistributionIDistributionStrategy;
class NaiveDistributionStrategy は IDistributionStrategy {
private $_nodes, $_nodesCount;
public function __constructまたは( ) {
$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('接続なし');
}
return $this->_nodes[$count > 1? abs(crc32($key) % $count) : 0];
}
public functiongenerateKey($value) {
return crc32($value);
}
}
//構成键分布戦略略
$options = array(
'key_distribution' => new NaiveDistributionStrategy(),
);
$redis = new PredisClient($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("サーバー '%s' には %d 個のキーがありますが、サーバー '%s ' には %d 個のキーがあります。n",
'first', $server1['db15']['keys'], 'first', $server2['db15']['keys']
);

复制代コード

php、redis、predis

本主题由小贝 2015-11-12 08:43 移動