php寫數據redis php寫數據庫接口

php實現redis數據庫指定庫號遷移的方法

這篇文章主要介紹了php實現redis數據庫指定庫號遷移的方法,涉及對于redis數據庫的操作技巧,非常具有實用價值,需要的朋友可以參考下

創新互聯建站長期為成百上千客戶提供的網站建設服務，團隊從業經驗10年，關注不同地域、不同群體，并針對不同對象提供差異化的產品和服務；打造開放共贏平臺，與合作伙伴共同營造健康的互聯網生態環境。為碾子山企業提供專業的做網站、網站建設，碾子山網站改版等技術服務。擁有10多年豐富建站經驗和眾多成功案例,為您定制開發。

本文實例講述了php實現redis數據庫指定庫號遷移的方法,分享給大家供大家參考。具體如下：

redis普通的數據庫遷移,只能整個redis

save,或者利用主從,當然也可以安裝一個redis-dump,不過比較麻煩,這里提供一種php的腳本,實現指定庫號的遷移,其實也就是遍歷根據存儲類型,讀出來,插入新庫,效果是這樣:

代碼如下:

[root@localhost

~]#

php

1.php

1/407

101/407

201/407

301/407

401/407

PHP實例代碼如下:

代碼如下:

?php

$from

=

'10.0.2.52:6379/7';

$to

=

'127.0.0.1:6379/7';

$from_redis

=

redis_init($from);

$to_redis

=

redis_init($to);

$keys

=

$from_redis-keys('*');

$count

=

0;

$total

=

count($keys);

foreach($keys

as

$key){

if(++$count

%

100

==

1){

echo

"$count/$totaln";

}

$type

=

$from_redis-type($key);

switch($type){

case

Redis::REDIS_STRING:

$val

=

$from_redis-get($key);

$to_redis-set($key,

$val);

break;

case

Redis::REDIS_LIST:

$list

=

$from_redis-lRange($key,

0,

-1);

foreach($list

as

$val){

$to_redis-rPush($key,

$val);

}

break;

case

Redis::REDIS_HASH:

$hash

=

$from_redis-hGetAll($key);

$to_redis-hMSet($key,

$hash);

break;

case

Redis::REDIS_ZSET:

$zset

=

$from_redis-zRange($key,

0,

-1,

true);

foreach($zset

as

$val=$score){

$to_redis-zAdd($key,

$score,

$val);

}

break;

}

}

function

redis_init($conf){

$redis

=

new

Redis();

preg_match('/^([^:]+)(:[0-9]+)?/(.+)?/',

$conf,

$ms);

$host

=

$ms[1];

$port

=

trim($ms[2],

':');

$db

=

$ms[3];

$redis-connect($host,

$port);

$redis-select($db);

return

$redis;

}

?

希望本文所述對大家的php程序設計有所幫助。

在php中 為什么不能使用redis類

redis是一個key-value存儲系統。和Memcached類似，它支持存儲的value類型相對更多，包括string(字符串)、list(鏈表)、set(集合)和zset(有序集合)。這些數據類型都支持push/pop、add/remove及取交集并集和差集及更豐富的操作，而且這些操作都是原子性的。在此基礎上，redis支持各種不同方式的排序。與memcached一樣，為了保證效率，數據都是緩存在內存中。區別的是redis會周期性的把更新的數據寫入磁盤或者把修改操作寫入追加的記錄文件，并且在此基礎上實現了master-slave(主從)同步。

Redis 是一個高性能的key-value數據庫。redis的出現，很大程度補償了memcached這類keyvalue存儲的不足，在部 分場合可以對關系數據庫起到很好的補充作用。它提供了Python，Ruby，Erlang，PHP客戶端，使用很方便。

若想在PHP中使用redis，首先要先安裝redis。然后在PHP中配置擴展。

安裝redis。

首先下載好redis安裝文件，解壓到D盤或其他盤。

然后通過Dos命令行進行安裝。

把這個文件夾復制到其它地方，比如D：\redis 目錄下。

打開一個cmd窗口 使用cd命令切換目錄到D:\redis 運行 redis-server.exe redis.conf

如果想方便的話，可以把redis的路徑加到系統的環境變量里，這樣就省得再輸路徑了，后面的那個redis.conf可以省略，如果省略，會啟用默認的。

這時候另啟一個cmd窗口，原來的不要關閉，不然就無法訪問服務端了

切換到redis目錄下運行 redis-cli.exe -h 127.0.0.1 -p 6379

這時候，就已經完成配置了。

完成了配置之后，要在PHP中添加redis的擴展，之后才可以用PHP靈活的使用它。

在windows下安裝php的redis擴展非常簡單，下載一個.dll擴展包放到php的ext目錄下，在php.ini里邊添加一行配置就可以了。

php代碼測試

redis=newRedis();redis-connect(‘127.0.0.1′,6379);

redis?set(‘test′,′helloworld!′);echoredis-get(‘test’);

輸出hello world!

php怎樣使用redis緩存數據

?php

/**

* Redis緩存操作

* @author hxm

* @version 1.0

* @since 2015.05.04

*/

class RCache extends Object implements CacheFace

{

private $redis = null; //redis對象

private $sId = 1; //servier服務ID

private $con = null;//鏈接資源

/**

* 初始化Redis

*

* @return Object

*/

public function __construct()

{

if ( !class_exists('Redis') )

{

throw new QException('PHP extension does not exist: Redis');

}

$this-redis = new Redis();

}

/**

* 鏈接memcahce服務

*

* @access private

* @param string $key 關鍵字

* @param string $value 緩存內容

* @return array

*/

private function connect( $sid )

{

$file = $this-CacheFile();

require $file;

if(! isset($cache) )

{

throw new QException('緩存配置文件不存在'.$file);

}

$server = $cache[$this-cacheId];

$sid = isset($sid) == 0 ? $this-sId : $sid;//memcache服務選擇

if ( ! $server[$sid])

{

throw new QException('當前操作的緩存服務器配置文件不存在');

}希望能幫到你，我還在后盾網學習呢，有不會的可以問我，一會有空回答你。（　^ω^）

如何用php代碼來操做redis

存儲普通數據就用set，讀取就用get。存儲普通數據就用set，讀取就用get。

但是存儲之前最好是先判斷一下。

下面是一段相關的代碼。

?php

$redis?=?new?Redis();

$redis-connect('127.0.0.1',?6379);//連接redis

if?(!$redis-exists("content")){

//如果沒有content這個key，就新建一個，并存儲數據。

$redis-set("content",$content);

}else{

//如果存在，則讀取content這個key里面的數據

echo?$redis-get("content");

}

?

推薦去三體教程看看，有redis存儲讀取數據方法的詳解。

php怎么將數據導入redis

對于大訪問量的站點使用默認的Session 并不合適，我們可以將其存入數據庫、或者使用Redis KEY-VALUE數據存儲方案

首先新建一個session表

CREATE TABLE `sessions` (

`sid` char(40) NOT NULL,

`updatetime` int(20) NOT NULL,

`data` varchar(200) NOT NULL,

UNIQUE KEY `sid` (`sid`) USING HASH

) ENGINE=MEMORY DEFAULT CHARSET=utf8;

Mysql 的memory引擎采用內存表，所有數據存儲在內存，操作速度快

復制代碼

?php

//引入數據庫文件

include "db.php";

class MySessionHandler implements SessionHandlerInterface

{

private $savePath;

private $sessData;

public $expiretime; //設置過期時間

public $db; //數據庫

public function __construct($hanlder =''){

$this-db = Database::getInstance();

//獲取數據庫實力

///var_dump($this-db);

}

public function open($savePath, $sessionName)

{

return true;

}

public function close()

{

return true;

}

public function read($id)

{

$sql ="select * from sessions where sid ='$id'";

$result = $this-db-execute($sql);

if(!empty($result)){

return $this-sessData = $result;

}

}

//函數的參數 $id - 當前會話ID

//數據DATA - 序列化之后的字符串

public function write($id, $data)

{

// echo $id;

// echo $data;

$now = time();

$newExp = $now+$this-expiretime; //總時間=當前時間 + 期限時間

$sql = "select * from sessions where sid ='$id'";

$result = $this-db-getOne($sql);

//var_dump($result);

if($data==''||isset($data)){

$data = $this-sessData;

}

if($result){

//如果存在則更新

$sql ="update sessions set updatetime = '$newExp',data ='$data' where sid = '$id'";

//echo $sql;

$update_data =$this-db-execute($sql);

if($update_data){

return true;

}

}else{

//不存在則生成生成

$sql = "insert into sessions(sid,updatetime,data) values('$id','$now','$data')";

$insert_data = $this-db-execute($sql);

if($insert_data){

return true;

}

}

return false;

}

public function destroy($id)

{ //銷毀

$sql = "delete from sessions where sid="."$id";

$destory = $this-db-execute($sql);

if($destory){

return true;

}else{

return false;

}

}

public function gc($sessMaxLifeTime)

{

$t = time();

$sql ="delete from sessions where $t - 'updatetime'${sessMaxLifeTime}";

$data = $this-db-execute($this-tosql);

if($data){

return true;

}else{

return false;

}

return true;

}

}

復制代碼

實例化

此處 PHP 手冊可以有兩種方法

1，實現了SessionHandlerInterface借口的對象,自PHP5.4可以使用

2 ，直接使用 session_set_save_handler

復制代碼

//判斷PHP版本

if(version_compare(PHP_VERSION,5.4)==1){

session_set_save_handler($handler, true);

session_start();

}else{

ini_set('session.use_trans_sid',0);

ini_set('session.use_cookies',1);

ini_set('session.cookie_path','/');

ini_set('session.save_handler','user');

session_module_name('user');

session_set_save_handler(array($session,"open"),array($session,"close"),array($session,"read"),array($session,"write"),array($session,"destory"),array($session,"gc"));

session_start();

}

$_SESSION['QQ']="QQ";

echo $_SESSION['QQ'];

復制代碼

數據庫代碼 db.php

復制代碼

?php

class Database{

static $instance;

static $db;

static function getInstance(){

if(self::$instance){

return self::$instance;

}else{

return new Database();

}

}

public function __construct(){

self::$db = new PDO('mysql:host=localhost;dbname=session', 'root','');

}

public function getOne($sql){

$rs =self::$db-query($sql);

@$rs-setFetchMode(PDO::FETCH_ASSOC);//返回關聯數組

$result = $rs - fetch();

return $result;

}

public function execute($sql){

$rs = self::$db-exec($sql);

return $rs;

}

}

//$data = Database::getInstance();

//var_dump($data);

復制代碼

使用REDIS 存儲SESSION

復制代碼

?php

class SessionManager{

private $redis;

private $sessionSavePath;

private $sessionName;

private $sessionExpireTime = 30;

public function __construct(){

$this-redis = new Redis();

$this-redis-connect('127.0.0.1',6379); //連接redis

$retval = session_set_save_handler(

array($this,"open"),

array($this,"close"),

array($this,"read"),

array($this,"write"),

array($this,"destory"),

array($this,"gc")

);

session_start();

}

public function open($path,$name){

return true;

}

public function close(){

return true;

}

public function read($id){

$value = $this-redis-get($id);

if($value){

return $value;

}else{

return "";

}

}

public function write($id,$data){

if($this-redis-set($id,$data)){

$this-redis-expire($id,$this-sessionExpireTime);

//設置過期時間

return true;

}

return false;

}

public function destory($id){

if($this-redis-delete($id)){

return true;

}

return false;

}

public function gc($maxlifetime){

return true;

}

//析構函數

public function __destruct(){

session_write_close();

}

}

$re = new SessionManager();

$_SESSION['name'] = "qq";

echo $_SESSION['name'];

php中關于redis和數據庫

select 查詢的時候始終先查 redis 有沒有，沒有去查數據庫，再把結果緩存起來；

update 修改完數據庫內容后，同時對 redis 中緩存的數據做一下 update 更新操作，這樣 select 查詢 redis 的時候就是查詢的最新數據；

同理，delete、insert 操作數據庫后也要同時對 redis 中緩存的數據做 update 更新操作，這樣 select 查詢 redis 的時候就是查詢的最新數據；

這樣，所有的查詢操作就都是對 redis 做緩存讀取，可以緩解數據庫的壓力；

分享標題：php寫數據redis php寫數據庫接口
鏈接地址：http://m.kartarina.com/article12/dodsjdc.html

成都網站建設公司_創新互聯，為您提供全網營銷推廣、品牌網站設計、虛擬主機、品牌網站制作、域名注冊、關鍵詞優化

廣告

聲明：本網站發布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創新互聯