Redis 初次嘗試
第一次接觸redis,也不知道要寫些什么。就玩了下將redis列表中的數據存入mysql數據庫中。
首先有三個文件:
redis.php 添加數據進redis;
insert_class.php 將數據插入數據庫;
inert.php 調用insert_class.php;
具體代碼如下:
//redis.php
<?php//連接本地的 Redis 服務$redis = new Redis();$redis->connect('127.0.0.1', 6379);$info = array("username"=>"abc","password"=>"123","content"=>"aaaabbbbcccddd");//將數組轉化為json存儲$list = json_encode($info);//lpushx 添加字符串元素$redis->lpush('webo_list',$list);$redis->close();print_r($list);
//indert_class.php
<?php class SaveData{public function save($username="",$password="",$content=""){$db = new mysqli('localhost','root','','redis');$sql = "INSERT INTO user(username,password,content) VALUES('$username','$password','$content')";$db->query('SET NAMES UTF8');if ($db->query($sql)){echo '1111';}else{echo '222';}}}
//insert.php
<?php include "insert_class.php";$save = new SaveData();$redis = new Redis();$redis->connect('127.0.0.1',6379);//返回列表的大小。如果列表不存在返回0,不是列表返回falseif ($redis->lsize('webo_list')) {//刪除list頭部并返回刪除數據$data = $redis->rPop('webo_list');$data = json_decode($data);$save->save($data->username,$data->password,$data->content);}$redis->close();print_r($data);
以后可以在此基礎上擴展批數據處理。