redis在PHP中的基本使用案例

<p>下载http://www.oschina.net/p/redis</p><p>解压后里面有:lib 源文件 、examples 例子、test测试</p><p>将lib目录拷贝到你的项目中,就可以开始你的predis操作了。</p><p>//使用autoload加载相关库,这边重点就是为了require $file;</p><p>spl_autoload_register(function($class) {</p><p>$file = __DIR__.&#39;/lib/Predis/&#39;.$class.&#39;.php&#39;;</p><p>if (file_exists($file)) {</p><p>require $file;</p><p>return true;</p><p>}</p><p>});</p><p>//配置连接的IP、端口、以及相应的数据库</p><p>$server = array(</p><p>&#39;host&#39; =&gt; &#39;127.0.0.1′,</p><p>&#39;port&#39; =&gt; 6379,</p><p>&#39;database&#39; =&gt; 15</p><p>);</p><p>$redis = new Client($server);</p><p>//普通set/get操作</p><p>$redis-&gt;set(&#39;library&#39;, &#39;predis&#39;);</p><p>$retval = $redis-&gt;get(&#39;library&#39;);</p><p>echo $retval; //显示 &#39;predis&#39;</p><p>//setex set一个存储时效</p><p>$redis-&gt;setex(&#39;str&#39;, 10, &#39;bar&#39;); //表示存储有效期为10秒</p><p>//setnx/msetnx相当于add操作,不会覆盖已有值</p><p>$redis-&gt;setnx(&#39;foo&#39;,12); //true</p><p>$redis-&gt;setnx(&#39;foo&#39;,34); //false</p><p>//getset操作,set的变种,结果返回替换前的值</p><p>$redis-&gt;getset(&#39;foo&#39;,56);//返回34</p><p>// incrby/incr/decrby/decr 对值的递增和递减</p><p>$redis-&gt;incr(&#39;foo&#39;); //foo为57</p><p>$redis-&gt;incrby(&#39;foo&#39;,2); //foo为59</p><p>//exists检测是否存在某值</p><p>$redis-&gt;exists(&#39;foo&#39;);//true</p><p>//del 删除</p><p>$redis-&gt;del(&#39;foo&#39;);//true</p><p>//type 类型检测,字符串返回string,列表返回 list,set表返回set/zset,hash表返回hash</p><p>$redis-&gt;type(&#39;foo&#39;);//不存在,返回none</p><p>$redis-&gt;set(&#39;str&#39;,&#39;test&#39;);</p><p>$redis-&gt;type(&#39;str&#39;); //字符串,返回string</p><p>//append 连接到已存在字符串</p><p>$redis-&gt;append(&#39;str&#39;,&#39;_123′); //返回累加后的字符串长度8,此进str为 &#39;test_123′</p><p>//setrange 部分替换操作</p><p>$redis-&gt;setrange(&#39;str&#39;,0,&#39;abc&#39;); //返回3,参数2为0时等同于set操作</p><p>$redis-&gt;setrange(&#39;str&#39;,2,&#39;cd&#39;);//返回4,表示从第2个字符后替换,这时&#39;str&#39;为&#39;abcd&#39;</p><p>//substr 部分获取操作</p><p>$redis-&gt;substr(&#39;str&#39;,0,2);//表示从第0个起,取到第2个字符,共3个,返回&#39;abc&#39;</p><p>//strlen 获取字符串长度</p><p>$redis-&gt;strlen(&#39;str&#39;); //返回4</p><p>//setbit/getbit 位存储和获取</p><p>$redis-&gt;setbit(&#39;binary&#39;,31,1); //表示在第31位存入1,这边可能会有大小端问题?不过没关系,getbit 应该不会有问题</p><p>$redis-&gt;getbit(&#39;binary&#39;,31); //返回1</p><p>//keys 模糊查找功能,支持*号以及?号(匹配一个字符)</p><p>$redis-&gt;set(&#39;foo1′,123);</p><p>$redis-&gt;set(&#39;foo2′,456);</p><p>$redis-&gt;keys(&#39;foo*&#39;); //返回foo1和foo2的array</p><p>$redis-&gt;keys(&#39;f?o?&#39;); //同上</p><p>//randomkey 随机返回一个key</p><p>$redis-&gt;randomkey(); //可能是返回 &#39;foo1′或者是&#39;foo2′及其它任何一存在redis的key</p><p>//rename/renamenx 对key进行改名,所不同的是renamenx不允许改成已存在的key</p><p>$redis-&gt;rename(&#39;str&#39;,&#39;str2′); //把原先命名为&#39;str&#39;的key改成了&#39;str2′</p><p>//expire 设置key-value的时效性,ttl 获取剩余有效期,persist 重新设置为永久存储</p><p>$redis-&gt;expire(&#39;foo&#39;, 1); //设置有效期为1秒</p><p>$redis-&gt;ttl(&#39;foo&#39;); //返回有效期值1s</p><p>$redis-&gt;expire(&#39;foo&#39;); //取消expire行为</p><p>//dbsize 返回redis当前数据库的记录总数</p><p>$redis-&gt;dbsize();</p><p>/*</p><p>队列操作</p><p>*/</p><p>//rpush/rpushx 有序列表操作,从队列后插入元素</p><p>//lpush/lpushx 和rpush/rpushx的区别是插入到队列的头部,同上,&#39;x&#39;含义是只对已存在的key进行操作</p><p>$redis-&gt;rpush(&#39;fooList&#39;, &#39;bar1′); //返回一个列表的长度1</p><p>$redis-&gt;lpush(&#39;fooList&#39;, &#39;bar0′); //返回一个列表的长度2</p><p>$redis-&gt;rpushx(&#39;fooList&#39;, &#39;bar2′); //返回3,rpushx只对已存在的队列做添加,否则返回0</p><p>//llen返回当前列表长度</p><p>$redis-&gt;llen(&#39;fooList&#39;);//3</p><p>//lrange 返回队列中一个区间的元素</p><p>$redis-&gt;lrange(&#39;fooList&#39;,0,1); //返回数组包含第0个至第1个共2个元素</p><p>$redis-&gt;lrange(&#39;fooList&#39;,0,-1);//返回第0个至倒数第一个,相当于返回所有元素,注意redis中很多时候会用到负数,下同</p><p>//lindex 返回指定顺序位置的list元素</p><p>$redis-&gt;lindex(&#39;fooList&#39;,1); //返回&#39;bar1′</p><p>//lset 修改队列中指定位置的value</p><p>$redis-&gt;lset(&#39;fooList&#39;,1,&#39;123′);//修改位置1的元素,返回true</p><p>//lrem 删除队列中左起指定数量的字符</p><p>$redis-&gt;lrem(&#39;fooList&#39;,1,&#39;_&#39;); //删除队列中左起(右起使用-1)1个字符&#39;_&#39;(若有)</p><p>//lpop/rpop 类似栈结构地弹出(并删除)最左或最右的一个元素</p><p>$redis-&gt;lpop(&#39;fooList&#39;); //&#39;bar0′</p><p>$redis-&gt;rpop(&#39;fooList&#39;); //&#39;bar2′</p><p>//ltrim 队列修改,保留左边起若干元素,其余删除</p><p>$redis-&gt;ltrim(&#39;fooList&#39;, 0,1); //保留左边起第0个至第1个元素</p><p>//rpoplpush 从一个队列中pop出元素并push到另一个队列</p><p>$redis-&gt;rpush(&#39;list1′,&#39;ab0′);</p><p>$redis-&gt;rpush(&#39;list1′,&#39;ab1′);</p><p>$redis-&gt;rpush(&#39;list2′,&#39;ab2′);</p><p>$redis-&gt;rpush(&#39;list2′,&#39;ab3′);</p><p>$redis-&gt;rpoplpush(&#39;list1′,&#39;list2′);//结果list1 =&gt;array(&#39;ab0′),list2 =&gt;array(&#39;ab1′,&#39;ab2′,&#39;ab3′)</p><p>$redis-&gt;rpoplpush(&#39;list2′,&#39;list2′);//也适用于同一个队列,把最后一个元素移到头部list2 =&gt;array(&#39;ab3′,&#39;ab1′,&#39;ab2′)</p><p>//linsert 在队列的中间指定元素前或后插入元素</p><p>$redis-&gt;linsert(&#39;list2′, &#39;before&#39;,&#39;ab1′,&#39;123′); //表示在元素&#39;ab1′之前插入&#39;123′</p><p>$redis-&gt;linsert(&#39;list2′, &#39;after&#39;,&#39;ab1′,&#39;456′); //表示在元素&#39;ab1′之后插入&#39;456′</p><p>//blpop/brpop 阻塞并等待一个列队不为空时,再pop出最左或最右的一个元素(这个功能在php以外可以说非常好用)</p><p>//brpoplpush 同样是阻塞并等待操作,结果同rpoplpush一样</p><p>$redis-&gt;blpop(&#39;list3′,10); //如果list3为空则一直等待,直到不为空时将第一元素弹出,10秒后超时</p><p>/**</p><p>set表操作</p><p>*/</p><p>//sadd 增加元素,返回true,重复返回false</p><p>$redis-&gt;sadd(&#39;set1′,&#39;ab&#39;);</p><p>$redis-&gt;sadd(&#39;set1′,&#39;cd&#39;);</p><p>$redis-&gt;sadd(&#39;set1′,&#39;ef&#39;);</p><p>//srem 移除指定元素</p><p>$redis-&gt;srem(&#39;set1′,&#39;cd&#39;); //删除&#39;cd&#39;元素</p><p>//spop 弹出首元素</p><p>$redis-&gt;spop(&#39;set1′);</p><p>//smove 移动当前set表的指定元素到另一个set表</p><p>$redis-&gt;sadd(&#39;set2′,&#39;123′);</p><p>$redis-&gt;smove(&#39;set1′,&#39;set2′,&#39;ab&#39;);//移动&#39;set1′中的&#39;ab&#39;到&#39;set2′,返回true or false</p><p>//scard 返回当前set表元素个数</p><p>$redis-&gt;scard(&#39;set2′);//2</p><p>//sismember 判断元素是否属于当前表</p><p>$redis-&gt;sismember(&#39;set2′,&#39;123′); //true or false</p><p>//smembers 返回当前表的所有元素</p><p>$redis-&gt;smembers(&#39;set2′); //array(&#39;123′,&#39;ab&#39;);</p><p>//sinter/sunion/sdiff 返回两个表中元素的交集/并集/补集</p><p>$redis-&gt;sadd(&#39;set1′,&#39;ab&#39;);</p><p>$redis-&gt;sinter(&#39;set2′,&#39;set1′); //返回array(&#39;ab&#39;)</p><p>//sinterstore/sunionstore/sdiffstore 将两个表交集/并集/补集元素copy到第三个表中</p><p>$redis-&gt;set(&#39;foo&#39;,0);</p><p>$redis-&gt;sinterstore(&#39;foo&#39;,&#39;set1′); //这边等同于将&#39;set1′的内容copy到&#39;foo&#39;中,并将&#39;foo&#39;转为set表</p><p>$redis-&gt;sinterstore(&#39;foo&#39;,array(&#39;set1′,&#39;set2′)); //将&#39;set1′和&#39;set2′中相同的元素copy到&#39;foo&#39;表中,覆盖&#39;foo&#39;原有内容</p><p>//srandmember 返回表中一个随机元素</p><p>$redis-&gt;srandmember(&#39;set1′);</p><p>/**</p><p>有序set表操作</p><p>*/</p><p>//sadd 增加元素,并设置序号,返回true,重复返回false</p><p>$redis-&gt;zadd(&#39;zset1′,1,&#39;ab&#39;);</p><p>$redis-&gt;zadd(&#39;zset1′,2,&#39;cd&#39;);</p><p>$redis-&gt;zadd(&#39;zset1′,3,&#39;ef&#39;);</p><p>//zincrby 对指定元素索引值的增减,改变元素排列次序</p><p>$redis-&gt;zincrby(&#39;zset1′,10,&#39;ab&#39;);//返回11</p><p>//zrem 移除指定元素</p><p>$redis-&gt;zrem(&#39;zset1′,&#39;ef&#39;); //true or false</p><p>//zrange 按位置次序返回表中指定区间的元素</p><p>$redis-&gt;zrange(&#39;zset1′,0,1); //返回位置0和1之间(两个)的元素</p><p>$redis-&gt;zrange(&#39;zset1′,0,-1);//返回位置0和倒数第一个元素之间的元素(相当于所有元素)</p><p>//zrevrange 同上,返回表中指定区间的元素,按次序倒排</p><p>$redis-&gt;zrevrange(&#39;zset1′,0,-1); //元素顺序和zrange相反</p><p>//zrangebyscore/zrevrangebyscore 按顺序/降序返回表中指定索引区间的元素</p><p>$redis-&gt;zadd(&#39;zset1′,3,&#39;ef&#39;);</p><p>$redis-&gt;zadd(&#39;zset1′,5,&#39;gh&#39;);</p><p>$redis-&gt;zrangebyscore(&#39;zset1′,2,9); //返回索引值2-9之间的元素 array(&#39;ef&#39;,&#39;gh&#39;)</p><p>//参数形式</p><p>$redis-&gt;zrangebyscore(&#39;zset1′,2,9,&#39;withscores&#39;); //返回索引值2-9之间的元素并包含索引值 array(array(&#39;ef&#39;,3),array(&#39;gh&#39;,5))</p><p>$redis-&gt;zrangebyscore(&#39;zset1′,2,9,array(&#39;withscores&#39; =&gt;true,&#39;limit&#39;=&gt;array(1, 2))); //返回索引值2-9之间的元素,&#39;withscores&#39; =&gt;true表示包含索引值; &#39;limit&#39;=&gt;array(1, 2),表示最多返回2条,结果为array(array(&#39;ef&#39;,3),array(&#39;gh&#39;,5))</p><p>//zunionstore/zinterstore 将多个表的并集/交集存入另一个表中</p><p>$redis-&gt;zunionstore(&#39;zset3′,array(&#39;zset1′,&#39;zset2′,&#39;zset0′)); //将&#39;zset1′,&#39;zset2′,&#39;zset0′的并集存入&#39;zset3′</p><p>//其它参数</p><p>$redis-&gt;zunionstore(&#39;zset3′,array(&#39;zset1′,&#39;zset2′),array(&#39;weights&#39; =&gt; array(5,0)));//weights参数表示权重,其中表示并集后值大于5的元素排在前,大于0的排在后</p><p>$redis-&gt;zunionstore(&#39;zset3′,array(&#39;zset1′,&#39;zset2′),array(&#39;aggregate&#39; =&gt; &#39;max&#39;));//&#39;aggregate&#39; =&gt; &#39;max&#39;或&#39;min&#39;表示并集后相同的元素是取大值或是取小值</p><p>//zcount 统计一个索引区间的元素个数</p><p>$redis-&gt;zcount(&#39;zset1′,3,5);//2</p><p>$redis-&gt;zcount(&#39;zset1′,&#39;(3′,5)); //&#39;(3′表示索引值在3-5之间但不含3,同理也可以使用&#39;(5′表示上限为5但不含5</p><p>//zcard 统计元素个数</p><p>$redis-&gt;zcard(&#39;zset1′);//4</p><p>//zscore 查询元素的索引</p><p>$redis-&gt;zscore(&#39;zset1′,&#39;ef&#39;);//3</p><p>//zremrangebyscore 删除一个索引区间的元素</p><p>$redis-&gt;zremrangebyscore(&#39;zset1′,0,2); //删除索引在0-2之间的元素(&#39;ab&#39;,&#39;cd&#39;),返回删除元素个数2</p><p>//zrank/zrevrank 返回元素所在表顺序/降序的位置(不是索引)</p><p>$redis-&gt;zrank(&#39;zset1′,&#39;ef&#39;);//返回0,因为它是第一个元素;zrevrank则返回1(最后一个)</p><p>//zremrangebyrank 删除表中指定位置区间的元素</p><p>$redis-&gt;zremrangebyrank(&#39;zset1′,0,10); //删除位置为0-10的元素,返回删除的元素个数2</p><p>/**</p><p>hash表操作</p><p>*/</p><p>//hset/hget 存取hash表的数据</p><p>$redis-&gt;hset(&#39;hash1′,&#39;key1′,&#39;v1′); //将key为&#39;key1′ value为&#39;v1′的元素存入hash1表</p><p>$redis-&gt;hset(&#39;hash1′,&#39;key2′,&#39;v2′);</p><p>$redis-&gt;hget(&#39;hash1′,&#39;key1′); //取出表&#39;hash1′中的key &#39;key1′的值,返回&#39;v1′</p><p>//hexists 返回hash表中的指定key是否存在</p><p>$redis-&gt;hexists (&#39;hash1′,&#39;key1′); //true or false</p><p>//hdel 删除hash表中指定key的元素</p><p>$redis-&gt;hdel(&#39;hash1′,&#39;key2′); //true or false</p><p>//hlen 返回hash表元素个数</p><p>$redis-&gt;hlen(&#39;hash1′); //1</p><p>//hsetnx 增加一个元素,但不能重复</p><p>$redis-&gt;hsetnx(&#39;hash1′,&#39;key1′,&#39;v2′); //false</p><p>$redis-&gt;hsetnx(&#39;hash1′,&#39;key2′,&#39;v2′); //true</p><p>//hmset/hmget 存取多个元素到hash表</p><p>$redis-&gt;hmset(&#39;hash1′,array(&#39;key3′=&gt;&#39;v3′,&#39;key4′=&gt;&#39;v4′));</p><p>$redis-&gt;hmget(&#39;hash1′,array(&#39;key3′,&#39;key4′)); //返回相应的值 array(&#39;v3′,&#39;v4′)</p><p>//hincrby 对指定key进行累加</p><p>$redis-&gt;hincrby(&#39;hash1′,&#39;key5′,3); //返回3</p><p>$redis-&gt;hincrby(&#39;hash1′,&#39;key5′,10); //返回13</p><p>//hkeys 返回hash表中的所有key</p><p>$redis-&gt;hkeys(&#39;hash1′); //返回array(&#39;key1′,&#39;key2′,&#39;key3′,&#39;key4′,&#39;key5′)</p><p>//hvals 返回hash表中的所有value</p><p>$redis-&gt;hvals(&#39;hash1′); //返回array(&#39;v1′,&#39;v2′,&#39;v3′,&#39;v4′,13)</p><p>//hgetall 返回整个hash表元素</p><p>$redis-&gt;hgetall(&#39;hash1′); //返回array(&#39;key1′=&gt;&#39;v1′,&#39;key2′=&gt;&#39;v2′,&#39;key3′=&gt;&#39;v3′,&#39;key4′=&gt;&#39;v4′,&#39;key5′=&gt;13)</p><p>/**</p><p>排序操作</p><p>*/</p><p>//sort 排序</p><p>$redis-&gt;rpush(&#39;tab&#39;,3);</p><p>$redis-&gt;rpush(&#39;tab&#39;,2);</p><p>$redis-&gt;rpush(&#39;tab&#39;,17);</p><p>$redis-&gt;sort(&#39;tab&#39;); //返回array(2,3,17)</p><p>//使用参数,可组合使用 array(&#39;sort&#39; =&gt; &#39;desc&#39;,&#39;limit&#39; =&gt; array(1, 2))</p><p>$redis-&gt;sort(&#39;tab&#39;,array(&#39;sort&#39; =&gt; &#39;desc&#39;)); //降序排列,返回array(17,3,2)</p><p>$redis-&gt;sort(&#39;tab&#39;,array(&#39;limit&#39; =&gt; array(1, 2))); //返回顺序位置中1的元素2个(这里的2是指个数,而不是位置),返回array(3,17)</p><p>$redis-&gt;sort(&#39;tab&#39;,array(&#39;limit&#39; =&gt; array(&#39;alpha&#39; =&gt; true))); //按首字符排序返回array(17,2,3),因为17的首字符是&#39;1′所以排首位置</p><p>$redis-&gt;sort(&#39;tab&#39;,array(&#39;limit&#39; =&gt; array(&#39;store&#39; =&gt; &#39;ordered&#39;))); //表示永久性排序,返回元素个数</p><p>$redis-&gt;sort(&#39;tab&#39;,array(&#39;limit&#39; =&gt; array(&#39;get&#39; =&gt; &#39;pre_*&#39;))); //使用了通配符&#39;*&#39;过滤元素,表示只返回以&#39;pre_&#39;开头的元素</p><p>/**</p><p>redis管理操作</p><p>*/</p><p>//select 指定要操作的数据库</p><p>$redis-&gt;select(&#39;mydb&#39;); //指定为mydb,不存在则创建</p><p>//flushdb 清空当前库</p><p>$redis-&gt;flushdb();</p><p>//move 移动当库的元素到其它库</p><p>$redis-&gt;set(&#39;foo&#39;, &#39;bar&#39;);</p><p>$redis-&gt;move(&#39;foo&#39;, &#39;mydb2′); //若&#39;mydb2′库存在</p><p>//info 显示服务当状态信息</p><p>$redis-&gt;info();</p><p>//slaveof 配置从服务器</p><p>$redis-&gt;slaveof(&#39;127.0.0.1′,80); //配置127.0.0.1端口80的服务器为从服务器</p><p>$redis-&gt;slaveof(); //清除从服务器</p><p>//同步保存服务器数据到磁盘</p><p>$redis-&gt;save();</p><p>//异步保存服务器数据到磁盘</p><p>$redis-&gt;bgsave();</p><p>//??</p><p>$redis-&gt;bgrewriteaof();</p><p>//返回最后更新磁盘的时间</p><p>$redis-&gt;lastsave();</p><p>//set/get多个key-value</p><p>$mkv = array(</p><p>&#39;usr:0001′ =&gt; &#39;First user&#39;,</p><p>&#39;usr:0002′ =&gt; &#39;Second user&#39;,</p><p>&#39;usr:0003′ =&gt; &#39;Third user&#39;</p><p>);</p><p>$redis-&gt;mset($mkv); //存储多个key对应的value</p><p>$retval = $redis-&gt;mget(array_keys($mkv)); //获取多个key对应的value</p><p>print_r($retval);</p><p>//批量操作</p><p>$replies = $redis-&gt;pipeline(function($pipe) {</p><p>$pipe-&gt;ping();</p><p>$pipe-&gt;flushdb();</p><p>$pipe-&gt;incrby(&#39;counter&#39;, 10); //增量操作</p><p>$pipe-&gt;incrby(&#39;counter&#39;, 30);</p><p>$pipe-&gt;exists(&#39;counter&#39;);</p><p>$pipe-&gt;get(&#39;counter&#39;);</p><p>$pipe-&gt;mget(&#39;does_not_exist&#39;, &#39;counter&#39;);</p><p>});</p><p>print_r($replies);</p><p>//CAS,事务性操作</p><p>function zpop($client, $zsetKey) {</p><p>$element = null;</p><p>$options = array(</p><p>&#39;cas&#39; =&gt; true, // Initialize with support for CAS operations</p><p>&#39;watch&#39; =&gt; $zsetKey, // Key that needs to be WATCHed to detect changes</p><p>&#39;retry&#39; =&gt; 3, // Number of retries on aborted transactions, after</p><p>// which the client bails out with an exception.</p><p>);</p><p>$txReply = $client-&gt;multiExec($options, function($tx)</p><p>use ($zsetKey, &amp;$element) {</p><p>@list($element) = $tx-&gt;zrange($zsetKey, 0, 0);</p><p>if (isset($element)) {</p><p>$tx-&gt;multi(); // With CAS, MULTI *must* be explicitly invoked.</p><p>$tx-&gt;zrem($zsetKey, $element);</p><p>}</p><p>});</p><p>return $element;</p><p>}</p><p>$zpopped = zpop($redis, &#39;zset&#39;);</p><p>echo isset($zpopped) ? &quot;ZPOPed $zpopped&quot; : &quot;Nothing to ZPOP!&quot;, &quot;\n&quot;;</p><p>//对存取的key加前缀,如: &#39;nrk:&#39;</p><p>$redis-&gt;getProfile()-&gt;setPreprocessor(new KeyPrefixPreprocessor(&#39;nrk:&#39;));</p><p>//分布式存储的一些方法</p><pre class="brush:php;toolbar:false">$multiple_servers=array( array( &#39;host&#39;=&gt;&#39;127.0.0.1′, &#39;port&#39;=&gt;6379, &#39;database&#39;=&gt;15, &#39;alias&#39;=&gt;&#39;first&#39;, ), array( &#39;host&#39;=&gt;&#39;127.0.0.1′, &#39;port&#39;=&gt;6380, &#39;database&#39;=&gt;15, &#39;alias&#39;=&gt;&#39;second&#39;, ), ); usePredis\Distribution\IDistributionStrategy; classNaiveDistributionStrategyimplementsIDistributionStrategy{ private$_nodes,$_nodesCount; publicfunction__constructor(){ $this-&gt;_nodes=array(); $this-&gt;_nodesCount=0; } publicfunctionadd($node,$weight=null){ $this-&gt;_nodes[]=$node; $this-&gt;_nodesCount++; } publicfunctionremove($node){ $this-&gt;_nodes=array_filter($this-&gt;_nodes,function($n)use($node){ return$n!==$node; }); $this-&gt;_nodesCount=count($this-&gt;_nodes); } publicfunctionget($key){ $count=$this-&gt;_nodesCount; if($count===0){ thrownewRuntimeException(&#39;Noconnections&#39;); } return$this-&gt;_nodes[$count&gt;1?abs(crc32($key)%$count):0]; } publicfunctiongenerateKey($value){ returncrc32($value); } }</pre><p>//配置键分布策略</p><pre class="brush:php;toolbar:false">$options=array( &#39;key_distribution&#39;=&gt;newNaiveDistributionStrategy(), ); $redis=newPredis\Client($multiple_servers,$options); for($i=0;$iset(&quot;key:$i&quot;,str_pad($i,4,&#39;0′,0)); $redis-&gt;get(&quot;key:$i&quot;); } $server1=$redis-&gt;getClientFor(&#39;first&#39;)-&gt;info(); $server2=$redis-&gt;getClientFor(&#39;second&#39;)-&gt;info(); printf(&quot;Server&#39;%s&#39;has%dkeyswhileserver&#39;%s&#39;has%dkeys.\n&quot;, &#39;first&#39;,$server1[&#39;db15&#39;][&#39;keys&#39;],&#39;second&#39;,$server2[&#39;db15&#39;][&#39;keys&#39;]</pre>
RangeTime:0.011130s
RangeMem:223.52 KB
返回顶部 留言