title: redis协程客户端 meta:

  • name: description content: redis协程客户端,由swoole 协程client实现,覆盖了redis 99%的方法
  • name: keywords content: swoole|swoole 拓展|swoole 框架|EasySwoole redis| Swoole redis协程客户端|swoole Redis|redis协程

键操作方法

方法列表

方法名称 参数 说明 备注
set $key, $val, $timeout = 0 设置一个键,以及设置过期时间,单位秒 $timeout值可为int(过期时间秒),可为string(“NX”,”XX”),也可为array[‘NX’,’EX’=>10]
get $key 获取一个键
getRange $key, $start, $end 返回子字符串
getSet $key, $value 返回key旧值并设置新值
getBit $key, $offset 获取指定偏移量上的bit值
mGet $keys 获取多个key的值(参数可为string或者数组) 在集群中,将会分开处理
setBit $key, $offset, $value 设置偏移量的bit值
setEx $key, $expireTime, $value 设置值以及过期时间(秒)
setNx $key, $value key不存在时设置 key 的值。
setRange $key, $offset, $value 设置偏移量的值
strLen $key 返回 key 所储存的字符串值的长度
mSet $data 设置多个key的值,参数为关联数组
mSetNx $data 当所有key不存在时,设置多个key值,参数和mSet一样 在集群中,key将会分开处理
pSetEx $key, $expireTime, $value 同setEx,过期时间为毫秒
incr $key 自增1
incrBy $key, $value 自增$value数值
incrByFloat $key, $value 自增$value浮点值
decr $key 自减1
decrBy $key, $value 自减$value数值
appEnd $key, $value 追加字符串
scan &$cursor, $pattern=null, $count=null 迭代string键名 集群模式不能使用

::: warning 如果开启序列化配置,getRange,setRange,getBit,setBit,strLen,自增自减命令,append等都会失效 :::

::: warning 在集群中,批量设置,批量获取都是拆数组一个个处理的,所以mSetNx 的特性将失效 :::

实例

  2. go(function () {
  3.     $redis = new \EasySwoole\Redis\Redis(new \EasySwoole\Redis\Config\RedisConfig([
  4.         'host'      => '127.0.0.1',
  5.         'port'      => '6379',
  6.         'auth'      => 'easyswoole',
  7.         'serialize' => \EasySwoole\Redis\Config\RedisConfig::SERIALIZE_NONE
  8.     ]));
  9.     $key = 'test';
  10.     $value = 1;
  11.     $data = $redis->del($key);
  12.     var_dump($data);
  13.     $data = $redis->set($key, $value);
  14.     var_dump($data);
  15.     $data = $redis->set($key, $value,'XX');
  16.     var_dump($data);
  17.     $data = $redis->set($key, $value,'NX');
  18.     var_dump($data);
  19.     $data = $redis->set($key, $value,['NX','EX'=>20]);
  20.     var_dump($data);
  21.     $data = $redis->set($key, $value,['NX','PX'=>20000]);
  22.     var_dump($data);
  24.     $data = $redis->get($key);
  25.     var_dump($data);
  27.     $data = $redis->exists($key);
  28.     var_dump($data);
  30.     $data = $redis->set($key, $value);
  31.     var_dump($data);
  32.     $value += 1;
  33.     $data = $redis->incr($key);
  34.     var_dump($data);
  36.     $value += 10;
  37.     $data = $redis->incrBy($key, 10);
  38.     var_dump($data);
  40.     $value -= 1;
  41.     $data = $redis->decr($key);
  42.     var_dump($data);
  44.     $value -= 10;
  45.     $data = $redis->decrBy($key, 10);
  46.     var_dump($data);
  48.     $key = 'stringTest';
  49.     $value = 'tioncico';
  50.     $redis->set($key, $value);
  51.     $data = $redis->getRange($key, 1, 2);
  52.     var_dump($data);
  54.     $data = $redis->getSet($key, $value . 'a');
  55.     var_dump($data);
  56.     $redis->set($key, $value);
  58.     $bitKey = 'testBit';
  59.     $bitValue = 10000;
  60.     $redis->set($bitKey, $bitValue);
  61.     $data = $redis->setBit($bitKey, 1, 0);
  62.     var_dump($data);
  63.     $data = $redis->getBit($key, 1);
  64.     var_dump($data);
  67.     $field = [
  68.         'stringField1',
  69.         'stringField2',
  70.         'stringField3',
  71.         'stringField4',
  72.         'stringField5',
  73.     ];
  74.     $value = [
  75.         1,
  76.         2,
  77.         3,
  78.         4,
  79.         5,
  80.     ];
  81.     $data = $redis->mSet([
  82.         "{$field[0]}" => $value[0],
  83.         "{$field[1]}" => $value[1],
  84.         "{$field[2]}" => $value[2],
  85.         "{$field[3]}" => $value[3],
  86.         "{$field[4]}" => $value[4],
  87.     ]);
  88.     var_dump($data);
  89.     $data = $redis->mGet([$field[3], $field[2], $field[1]]);
  90.     var_dump($data);
  93.     $data = $redis->setEx($key, 1, $value[0] . $value[0]);
  94.     var_dump($data);
  95.     var_dump($redis->get($key));
  97.     $data = $redis->pSetEx($key, 1, $value[0]);
  98.     var_dump($data);
  99.     var_dump($redis->get($key));
  102.     $redis->del($key);
  103.     $data = $redis->setNx($key, 1);
  104.     var_dump($data);
  107.     $redis->del($field[0]);
  108.     $data = $redis->mSetNx([
  109.         "{$field[0]}" => $value[0],
  110.         "{$field[1]}" => $value[1],
  111.     ]);
  112.     var_dump($data);
  113.     var_dump( $redis->get($field[1]));
  114.     $redis->del($field[1]);
  115.     $data = $redis->mSetNx([
  116.         "{$field[0]}" => $value[0] + 1,
  117.         "{$field[1]}" => $value[1] + 1,
  118.     ]);
  119.     var_dump($data);
  120.     var_dump($redis->get($field[0]));
  122.     $data = $redis->setRange($field[0], 1, 1);
  123.     var_dump($data);
  124.     var_dump($redis->get($field[0]));
  126.     $data = $redis->strLen($field[0]);
  127.     var_dump($data);
  129.     $redis->set($key, 1);
  130.     $data = $redis->incrByFloat($key, 0.1);
  131.     var_dump($data);
  132.     $data = $redis->appEnd($field[0], '1');
  133.     var_dump($data);
  134.     var_dump($redis->get($field[0]));
  138.     //迭代测试
  139.     $cursor = 0;//迭代初始值0
  140.     $redis->flushAll();
  141.     $redis->set('xxxa', '仙士可');
  142.     $redis->set('xxxb', '仙士可');
  143.     $redis->set('xxxc', '仙士可');
  144.     $redis->set('xxxd', '仙士可');
  145.     $data = [];
  146.     do {
  147.         //每次迭代都会设置一次$cursor,为0代表迭代完成
  148.         $keys = $redis->scan($cursor, 'xxx*', 1);
  149.         $data = array_merge($data,$keys);
  150.     } while ($cursor);
  151.     var_dump($data);
  152. });