Redis基础特性及应用练习-php

redis持久化（persistence）

redis支持两种方式的持久化，可以单独使用或者结合起来使用。

第一种：RDB方式（redis默认的持久化方式）

rdb方式的持久化是通过快照完成的，当符合一定条件时redis会自动将内存中的所有数据执行快照操作并存储到硬盘上。默认存储在dump.rdb文件中。(文件名在配置文件中dbfilename)
redis进行快照的时机（在配置文件redis.conf中）

save 900 1  //表示900秒内至少一个键被更改则进行快照。
save 300 10  //表示300秒内10条被更改则快照
save 60 10000  //60秒内10000条

第二种：AOF方式

aof方式的持久化是通过日志文件的方式。默认情况下redis没有开启aof，可以通过参数appendonly参数开启。

appendonly yes

aof文件的保存位置和rdb文件的位置相同，都是dir参数设置的，默认的文件名是appendonly.aof，可以通过appendfilename参数修改

appendfilename appendonly.aof

redis写命令同步的时机

appendfsync always 每次都会执行
appendfsync everysec 默认 每秒执行一次同步操作（推荐，默认）
appendfsync no不主动进行同步，由操作系统来做，30秒一次

宝塔设置：

redis中键的生存时间（expire）

class Myredis{protected $redis;public function __construct() {//实例化Redis类$redis = new Redis();//选择指定的redis数据库连接，默认端口号为6379$redis->connect('127.0.0.1',6379);$this->redis = $redis;}public function expire(string $name,int $expire){$this->redis->expire($name, $expire);// $redis->ttl(‘foo’); //返回有效期值1s// $redis->expire(‘foo’); //取消expire行为}
}
$redis = new Myredis();
$redis->expire("name",10);	//（单位/秒）

redis的事务（transaction）

    public function transaction(){//Redis 事务的本质是一组命令的集合。事务支持一次执行多个命令，一个事务中所有命令都会被序列化。在事务执行过程，会按照顺序串行化执行队列中的命令，其他客户端提交的命令请求不会插入到事务执行命令序列中。/**//1 Redis事务没有隔离级别$this->redis->multi();$this->redis->decrby("number",10);//发送 EXEC 命令前被放入队列缓存，并不会被实际执行，也就不存在事务内的查询要看到事务里的更新，事务外查询不能看到。if($this->redis->get("number") < 0){return $this->redis->discard();}$this->redis->incrby("number2",10);$this->redis->exec();	//number:-10, number2:10*//**//2 Redis不保证原子性//Redis中，单条命令是原子性执行的，但事务不保证原子性，且没有回滚。事务中任意命令执行失败，其余的命令仍会被执行。$this->redis->multi();$this->redis->decrby("number",10);$this->redis->incrby("number2",10,21,321);	//err$this->redis->incrby("number3",10);$this->redis->exec(); //number:-10, number3: 10//Redis中，单条命令是原子性执行的，但事务不保证原子性，且没有回滚。*/// Watch 命令用于监视一个(或多个) key ，如果在事务执行之前这个(或这些) key 被其他命令所改动，那么事务将被打断$this->redis->watch('number');sleep(10);	//期间改掉number，下面的命令都不会执行$this->redis->multi();$this->redis->set('favorite_fruit','cherry');$this->redis->incrBy('number',3);$this->redis->exec();}$redis->transaction();

发布/订阅

//调用
public function Publish_Subscribe(){//通过订阅/发布，添加数据库数据。 tb_people表$channelName = "tb_people";//向指定频道发送消息try {$redis = new Redis();$redis->connect('127.0.0.1', 6379);for ($i=0;$i<5;$i++){$data = array('name' => 'key'.$i);$ret = $redis->publish($channelName, json_encode($data));print_r($ret);}} catch (Exception $e){echo $e->getMessage();}
}

xxxx.php:单独起个php文件，订阅信息

<?php
//设置php脚本执行时间
set_time_limit(0);
//设置socket连接超时时间
ini_set('default_socket_timeout', -1);$servername = "localhost";
$username = "root";
$password = "root";
try {$conn = new PDO("mysql:host=$servername;dbname=my_mysql;port=3306", $username, $password);// echo "连接成功";
}catch(PDOException $e){echo $e->getMessage();
}//声明测试频道名称
$channelName = "tb_people";
try {$redis = new Redis();//建立一个长链接$redis->pconnect('127.0.0.1', 6379);//阻塞获取消息$redis->subscribe(array($channelName), function ($redis, $chan, $msg) use($conn){// echo "channel:".$chan.",message:".$msg."\n";$arr_msg = json_decode($msg,true);$sqlquery = "INSERT INTO tb_people (name) VALUES ('".$arr_msg['name']."')";$conn->query($sqlquery);echo "成功";});
} catch (Exception $e){echo $e->getMessage();
}
mysql_close($con);