이 글은 PHP와 Redis의 간단한 응용에 대해 공유합니다. 필요한 친구들이 참고할 수 있습니다.
1. 실험 환경: win10 + redis3.2 + php7
2 , php -redis/redis/redis 그래픽 관리 도구 및 기타 설치에서는 이 단계를 건너뜁니다.
3 일반적으로 사용되는 5가지 Redis 데이터 유형은 자세히 설명하지 않습니다.
참조: http://www.runoob.com /redis/r...
Four.php + mysql + redis 단순 애플리케이션
데이터베이스 이름: redis 데이터 테이블: redis_user
PHP 작업 시뮬레이션 Mysql + redis CURD 작업
1.config.php 구성 파일
<?php
$config = array(
'mysql'=>array(
'host'=>'127.0.0.1',
'user'=>'root',
'pass'=>'root',
'dbname'=>'redis',
'prefix'=>'redis_'
),
'redis'=>array(
'host'=>'127.0.0.1',
'port'=>6379
)
);로그인 후 복사
.php 항목 파일은 Mysql
<?php
reqiure_once('Mysql.php');
//增加数据
// echo Mysql::getInstance()->table('user')->insert(['user'=>'张三','pass'=>md5('123456'),'create_time'=>date('Y-m-d H:i:s')]);
//删除数据
// echo Mysql::getInstance()->table('user')->where(array('id'=>30))->delete();
//查看单条数据
// $data = Mysql::getInstance()->table('user')->where(array('id'=>'30'))->find();
// print_r($data);
//查找所有数据
// $all = Mysql::getInstance()->table('user')->field('id,user')->select();
$all = Mysql::getInstance()->table('user')->select();
print_r($all);
//修改数据
// echo Mysql::getInstance()->table('user')->where(array('id'=>30))->update(['user'=>'张三adfadfasdf11111111','pass'=>md5('123456aaa')]);
?>
로그인 후 복사
Mysql.php 파일
<?php
class Mysql
{
static $instance;
private $conn;
private $redis;
private $options = array();
//单例模式
private function __construct()
{
error_reporting(E_ALL^E_NOTICE^E_WARNING);
require_once(__DIR__.'/Config.php');
$conn = mysqli_connect($config['mysql']['host'],$config['mysql']['user'],$config['mysql']['pass'],$config['mysql']['dbname']);
if(mysqli_connect_errno($conn)) {
echo "连接Mysql失败：".mysqli_connect_error();
exit;
}
mysqli_query($conn,'set names utf8');
$this->options['prefix'] = $config['mysql']['prefix'];
$this->conn = $conn;
$this->redis = new Redis();
$this->redis->connect($config['redis']['host'],$config['redis']['port']);
}
//获取对象实例
static function getInstance()
{
if(self::$instance) {
return self::$instance;
} else {
self::$instance = new self();
return self::$instance;
}
}
//设置表名
public function table(string $table)
{
$this->options['table'] = '`'.$this->options['prefix'].$table.'`';
return $this;
}
//设置redis键名
public function redis(string $key)
{
$this->options['key'] = $key;
return $this;
}
//设置条件
public function where(array $where)
{
$condition = '';
$and = count($where) > 1 ? ' and ' : '';
foreach ($where as $key => $value) {
if($key == 'id') {$this->options['user_id'] = $value;}
if(strpos($key,':')) {
$arr = explode(':', $key);
$condition .= '`'.$arr['0'].'` '.$arr['1']. ' "'.$value.'" ' . $and ;
} else {
$condition .= '`'.$key.'` = ' .'"'.$value.'"' .$and ;
}
}
$this->options['where'] = rtrim($condition,' and ');
return $this;
}
//设置字段
public function field(string $field)
{
$this->options['field'] = $field;
return $this;
}
//增加数据
public function insert(array $data)
{
$key = '`'.implode('`,`', array_keys($data)).'`';
$value = '"'.implode('","', $data).'"';
$sql = "insert into {$this->options['table']} (".$key.") values (".$value.");";
if( mysqli_query($this->conn,$sql) ) {
$user_id = $this->conn->insert_id;
$data['id'] = $user_id;
//以hash类型存储
$this->redis->hset($this->options['table'],$user_id,json_encode($data));
return $user_id;
} else {
return 0;
}
}
//删除数据
public function delete()
{
$where = $this->options['where'] ? $this->options['where'] : '1';
$sql = "delete from {$this->options['table']} where {$where};";
if(mysqli_query($this->conn,$sql)) {
$this->redis->hdel($this->options['table'],$this->options['user_id']);
return 1;
} else {
return 0;
}
}
//修改数据
public function update(array $data)
{
$condition = '';
$where = $this->options['where'] ? $this->options['where'] : '1';
foreach ($data as $key => $value) {
$condition .= ", `".$key."` = '".$value."'";
}
$condition = substr($condition, 1);
$sql = " update {$this->options['table']} set {$condition} where {$where} ; ";
if(mysqli_query($this->conn,$sql)) {
$hashData = (array)json_decode($this->redis->hget($this->options['table'],$this->options['user_id']));
foreach ($data as $key => $value) {
$hashData[$key] = $value;
}
$this->redis->hset($this->options['table'],$this->options['user_id'],json_encode($hashData));
return 1;
} else {
return 0;
}
}
//查找单条数据
public function find()
{
$field = $this->options['field'] ? $this->options['field'] : '*';
$where = $this->options['where'] ? $this->options['where'] : '1';
if($this->options['user_id']) {
echo '从redis获取数据<pre class="brush:php;toolbar:false">';
$data = (array)json_decode($this->redis->hget($this->options['table'],$this->options['user_id']));
if($field != '*') {
$field = explode(',', $field);
foreach ($field as $value) {
$arr[$value] = $data[$value];
$arr['typ'] = 'redis';
}
return $arr;
}
return $data;
} else {
$sql = " select {$field} from {$this->options['table']} where {$where}; ";
if($query = mysqli_query($this->conn,$sql)) {
return mysqli_fetch_assoc($query);
} else {
return array();
}
}
}
//查找所有数据
public function select()
{
$data = array();
$field = $this->options['field'] ? $this->options['field'] : '*';
$hashData = $this->redis->hgetall($this->options['table']);
if($hashData) {
if($field != '*') {
$field = explode(',', $field);
}
foreach ($hashData as $key => $value) {
$data[$key] = array();
$values = (array)json_decode($value);
if($field != '*') {
foreach ($field as $k => $v) {
$data[$key][$v] = $values[$v];
}
}else{
$data[$key] = $values;
}
}
echo '从redis获取数据<pre class="brush:php;toolbar:false">';
} else {
$sql = " select {$field} from {$this->options['table']} ; ";
if($query = mysqli_query($this->conn,$sql)) {
while ($row = mysqli_fetch_assoc($query)) {
$data[] = $row;
}
}
}
return $data;
}
public function __destruct()
{
mysqli_close($this->conn);
}
}로그인 후 복사
운영 시 기본 키 ID를 사용하시기 바랍니다. ~
위 내용은 PHP와 Redis 및 간단한 애플리케이션 시작하기의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!
![[웹 프런트엔드] Node.js 빠른 시작](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
