php使用redis的几种常见操作方式和用法示例

本文实例讲述了php使用redis的几种常见操作方式和用法。分享给大家供大家参考，具体如下：

一、简单的字符串缓存

比如针对一些sql查询较慢，更新不频繁的数据进行缓存。

?

1 2 3 4 5 6 7 8 9 10 11 12 13

<?php $redis = new Redis(); $redis ->connect( '127.0.0.1' , 6379, 60); $sql = 'select * from tb_order order by id desc limit 10' ; //伪代码，从数据库中获取数据 $data = $db ->query( $sql ); $data = json_encode( $data , JSON_UNESCAPED_UNICODE); $key = md5( $sql ); //缓存数据 $redis ->set( $key , $value , 60); //获取数据 $data = $redis ->get( $key ); print_r(json_decode( $data , true));

二、通过列表模拟简单队列

比如我们需要批量的发送邮件，可以把发送邮件的任务存入队列中，然后启多个php脚本从队列中读取任务去发送邮件。

也可以用来处理商品秒杀，用户点击抢购时，把一个个的用户抢购任务放入队列中，串行化处理，判断队列数量，防止超卖的发生。

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23

<?php $redis = new Redis(); $redis ->connect( '127.0.0.1' , 6379, 60); //循环的把发送1000条邮件任务插入队列 for ( $ix = 0; $ix < 1000; $ix ++) {    $redis ->lPush( 'send_email_queue' , json_encode([      'id' => $ix ,      'send' => 'xxx@qq.com' ,      'receive' => 'yyy@qq.com' ,      'title' => 'xxx' ,      'body' => 'xxx' ,    ])); } sleep(3); //从队列中取任务，执行任务 while ( $count = $redis ->lLen( 'send_email_queue' )) {    echo "当前任务队列数 {$count} <br>" ;    $task = $redis ->rpop( 'send_email_queue' );    $task = json_decode( $task , true);    //伪代码，发送邮件    $mailer ->send( $task [ 'send' ], $task [ 'receive' ], $task [ 'title' ], $task [ 'body' ]);    echo "任务 {$task['id']} 邮件发送成功<br>" ; }

三、通过watch + multi 来实现乐观锁

乐观锁，顾名思义，乐观的认为数据不会被修改，只有当更新时才去判断数据是否被修改过，通常用版本号或时间戳来实现。

redis中通过watch和multi来实现，watch会监视给定的key是否发生更改，当exec的时候如果监视的key发生过改变，则整个事务会失败。

当然我们可以调用多次watch监视多个key。

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17

<?php $redis = new Redis(); $redis ->connect( '127.0.0.1' , 6379, 60); //设置商品的库存数为100 $redis ->set( 'goods_stock_nums' , 100); //监视该key $redis ->watch( 'goods_stock_nums' ); //开启事务 $redis ->multi(); //修改库存数 $redis ->decr( 'goods_stock_nums' ); //提交事务，如果在此期间有其他请求修改了该key，那么事务会失败 if ( $redis -> exec ()) {    echo '抢购成功' ; } else {    echo '数据错误，请重新再试' ; }

四、使用 set 来实现悲观锁

悲观锁，顾名思义，悲观的认为数据总是会被修改，所以在操作前都会先加上锁，操作完后，再释放锁。

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44

<?php function getRedis() {    $redis = new Redis();    $redis ->connect( '127.0.0.1' , 6379, 60);    return $redis ; } function lock( $key , $random ) {    $redis = getRedis();    return $redis ->set( $key , $random , [ 'nx' , 'ex' => 3]); } function unlock( $key , $random ) {    $redis = getRedis();    //使用lua脚本保证原子性    $script = 'if redis.call("get",KEYS[1]) == ARGV[1] then return redis.call("del",KEYS[1]) else return 0 end' ;    return $redis -> eval ( $script , [ $key , $random ], 1); } function decrGoodsStockNums() {    $redis = getRedis();    //获取商品库存数    $ret = $redis ->get( 'goods_stock_nums' );    if ( $ret === false) {      return false;    }    if ( $ret <= 0) {      return false;    }    $random = mt_rand();    //先获取锁    if (lock( 'goods_stock_nums_lock' , $random )) {      //修改库存数      $redis ->decr( 'goods_stock_nums' );      //释放锁      unlock( 'goods_stock_nums_lock' , $random );      return true;    } else {      usleep(100);      decrGoodsStockNums();    } } decrGoodsStockNums();

五、使用 publish + subscribe 完成发布和订阅

发布代码：

?

1 2 3 4 5 6 7 8 9 10 11 12 13 14

<?php $redis = new Redis(); $redis ->pconnect( '127.0.0.1' , 6379); $ix = 0; //发布内容 while (true) {    $redis ->publish( 'news' , json_encode([      'title' => '我是新闻标题' . $ix ,      'content' => '我是新闻内容' . $ix ,      'time' => date ( 'Y-m-d H:i:s' ),    ]));    $ix ++;    sleep(1); }

订阅代码：

?

1 2 3 4 5 6 7 8

<?php $redis = new Redis(); $redis ->pconnect( '127.0.0.1' , 6379); //订阅内容 $redis ->subscribe([ 'news' ], function ( $redis , $channel , $msg ) {    $msg = json_decode( $msg , true);    echo "标题: {$msg['title']} 内容: {$msg['content']} 时间: {$msg['time']} <br>" ; });

希望本文所述对大家PHP程序设计有所帮助。

原文链接：https://www.cnblogs.com/jkko123/p/10491342.html