php中使用PhpRedis扩展操作Redis的实例

当前位置：首页 > redis > 正文

php中使用PhpRedis模块操作Redis的实例

Feb262014

作者：Fisher 发布：2014-02-26 00:52 分类：redis 抢沙发

Redis是一款开源的可基于内存亦可持久化的日志型、Key-Value数据库，是目前最快的NOSQL数据库之一，单从做缓存应用来讲比Memcache更加优秀。要操作Redis缓存，我们必须选择一种客户端。Redis官方已经列出了很多的PHP的客户端，这里推荐另外一个非常受欢迎的php客户端–phpredis。

下文中我们将使用phpredis来于redis进行交互，主要包含以下几点；
（一）配置phpredis
（二）使用phpredis
（三）phpredis中常用的方法
（四）php程序中使用redis的完整实例

（一）配置phpredis
首先从github上将phpredis下载下来，https://github.com/nicolasff/phpredis
下载之后解压，Ubuntu上可以使用如下命令安装：
cd phpredis
sudo phpize
sudo ./configure
sudo make
sudo make install

现在phpredis扩展已经打进来了，复制模块到php扩展目录

sudo cp modules/redis.so {php-config–extension-dir}

1	sudo cp modules/redis.so {php-config–extension-dir}

现在，修改php.ini，增加如下

extension = redis.so

1	extension = redis.so

或者如下操作：

sudo echo “extension=redis.so”  > /etc/php5/conf.d/redis.ini

1	sudo echo “extension=redis.so” > /etc/php5/conf.d/redis.ini

（二）使用phpredis
phpredis扩展引入了Redis类，基于这个类我们可以进行各种操作了。
1.Redis类
通常用于连接redis，我们可以使用如下代码创建实例

$redisClient = new Redis();

1	$redisClient = new Redis();

2.RedisException类
这个类是用来进行异常捕获的，代码样例如下：

try{
  if( $socket = fsockopen( $host, $port, $errorNo, $errorStr )){
  	if( $errorNo ){
  	  throw new RedisException(“Socket cannot be opened”);
  	}	
  }
}catch( Exception $e ){
  echo $e -> getMessage( );
}

try{

if( $socket = fsockopen( $host, $port, $errorNo, $errorStr )){

if( $errorNo ){

throw new RedisException(“Socket cannot be opened”);

}

}catch( Exception $e ){

echo $e -> getMessage( );

}

（三）常用的phpredis方法
1.Connect
用来连接redis实例

$redisClient -> connect(“hostOrUnixPath”, “port”, “timeOut”, “reservedInterval” );

1	$redisClient -> connect(“hostOrUnixPath”, “port”, “timeOut”, “reservedInterval” );

例如：

$objRedis = new Redis();
$objRedis->connect( ‘localhost’, 6379 );
$objRedis->connect( ’127.0.0.1′ ); // By default it will take port 6379
$objRedis->connect( ’127.0.0.1′, 6379, 3.5 ); // Giving timeOut of 3.5 sec
$objRedis->connect( ‘/var/temp/redis/redis.sock’ ); // Unix domain socket path
$objRedis->connect( ’127.0.0.1′, 6379, 2.5, NULL, 150 ); // Delay of 150 ms in-between reconnection attempts with a time out of 2.5 sec

$objRedis = new Redis();

$objRedis->connect( ‘localhost’, 6379 );

$objRedis->connect( ’127.0.0.1′ ); // By default it will take port 6379

$objRedis->connect( ’127.0.0.1′, 6379, 3.5 ); // Giving timeOut of 3.5 sec

$objRedis->connect( ‘/var/temp/redis/redis.sock’ ); // Unix domain socket path

$objRedis->connect( ’127.0.0.1′, 6379, 2.5, NULL, 150 ); // Delay of 150 ms in-between reconnection attempts with a time out of 2.5 sec

2.get
根据key得到value

$redisClient -> get('key', 'value');

1	$redisClient -> get('key', 'value');

3.mget
根据key的队列获取多个value值

$arrKeys = array(“keyA”, “keyB”, “keyC”);
$redisClient -> mget($arrKeys);

1 2	$arrKeys = array(“keyA”, “keyB”, “keyC”); $redisClient -> mget($arrKeys);

4.set
写入key-value对

$redisClient -> set('key');

1	$redisClient -> set('key');

5.setex
同样是写入key-value对，添加了过期时间

$redisClient -> setex('key', 3600, 'value' );

1	$redisClient -> setex('key', 3600, 'value' );

6.del
删除key

$redisClient -> del('key');

1	$redisClient -> del('key');

7.exists
判断key是否存在，如存在返回true

$redisClient -> exists('key');

1	$redisClient -> exists('key');

8.close
关闭连接

$redisClient -> close();

1	$redisClient -> close();

（四）php使用redis的例子
通常redis作为数据库的cache而存在，这里我们可以看到redis是如何跟php+mysql整合的。

<?php 
  /* Functions for redis operations starts here   */ 

  $redisObj = new Redis(); 

  function openRedisConnection( $hostName, $port){ 
  	global $redisObj; 
	// Opening a redis connection
  	$redisObj->connect( $hostName, $port );
  	return $redisObj; 
  } 

  function setValueWithTtl( $key, $value, $ttl ){ 

  	try{ 
  		global $redisObj; 
		// setting the value in redis
  		$redisObj->setex( $key, $ttl, $value );
  	}catch( Exception $e ){ 
  		echo $e->getMessage(); 
  	} 
  } 

  function getValueFromKey( $key ){ 
  	try{ 
  		global $redisObj; 
		// getting the value from redis
  		return $redisObj->get( $key);
  	}catch( Exception $e ){ 
  		echo $e->getMessage(); 
  	} 
  } 

  function deleteValueFromKey( $key ){ 
  	try{ 
  		global $redisObj; 
		// deleting the value from redis
  		$redisObj->del( $key);
  	}catch( Exception $e ){ 
  		echo $e->getMessage(); 
  	} 
  } 

   /* Functions for converting sql result  object to array goes below  */ 

  function convertToArray( $result ){ 
  	$resultArray = array(); 

  	for( $count=0; $row = $result->fetch_assoc(); $count++ ) { 
  		$resultArray[$count] = $row; 
  	} 

  	return $resultArray; 
  } 

   /* Functions for executing the mySql query goes below   */ 

  function executeQuery( $query ){ 
     $mysqli = new mysqli( 'localhost',  'username',  'password',  'someDatabase' ); 

     if( $mysqli->connect_errno ){ 
       echo "Failed to connect to MySql:"."(".mysqli_connect_error().")".mysqli_connect_errno(); 
     } 

     $result =  $mysqli->query( $query ); 
	 // Calling function to convert result  to array
     $arrResult = convertToArray( $result );

     return $arrResult;   	 
  }  

  $query = 'select * from sometable limit 1'; 
  // Calling function to execute sql query
  $arrValues = executeQuery( $query );

  // Making json string
  $jsonValue = json_encode($arrValues);

  // Opening a redis connection
  openRedisConnection( 'localhost', 6379 );

  // Inserting the value with ttl =  1 hours
  setValueWithTtl( 'somekey1', $jsonValue, 3600);

  // Fetching value from redis using the key. 
  $val = getValueFromKey( 'somekey1' ); 

  //  Output:  the json encoded array from redis 
  echo $val;

  // Unsetting value from redis
  deleteValueFromKey( $key );

?>

<?php

/* Functions for redis operations starts here */

$redisObj = new Redis();

function openRedisConnection( $hostName, $port){

global $redisObj;

// Opening a redis connection

$redisObj->connect( $hostName, $port );

return $redisObj;

}

function setValueWithTtl( $key, $value, $ttl ){

try{

global $redisObj;

// setting the value in redis

$redisObj->setex( $key, $ttl, $value );

}catch( Exception $e ){

echo $e->getMessage();

}

function getValueFromKey( $key ){

try{

global $redisObj;

// getting the value from redis

return $redisObj->get( $key);

}catch( Exception $e ){

echo $e->getMessage();

}

function deleteValueFromKey( $key ){

try{

global $redisObj;

// deleting the value from redis

$redisObj->del( $key);

}catch( Exception $e ){

echo $e->getMessage();

}

/* Functions for converting sql result object to array goes below */

function convertToArray( $result ){

$resultArray = array();

for( $count=0; $row = $result->fetch_assoc(); $count++ ) {

$resultArray[$count] = $row;

}

return $resultArray;

}

/* Functions for executing the mySql query goes below */

function executeQuery( $query ){

$mysqli = new mysqli( 'localhost', 'username', 'password', 'someDatabase' );

if( $mysqli->connect_errno ){

echo "Failed to connect to MySql:"."(".mysqli_connect_error().")".mysqli_connect_errno();

}

$result = $mysqli->query( $query );

// Calling function to convert result to array

$arrResult = convertToArray( $result );

return $arrResult;

}

$query = 'select * from sometable limit 1';

// Calling function to execute sql query

$arrValues = executeQuery( $query );

// Making json string

$jsonValue = json_encode($arrValues);

// Opening a redis connection

openRedisConnection( 'localhost', 6379 );

// Inserting the value with ttl = 1 hours

setValueWithTtl( 'somekey1', $jsonValue, 3600);

// Fetching value from redis using the key.

$val = getValueFromKey( 'somekey1' );

// Output: the json encoded array from redis

echo $val;

// Unsetting value from redis

deleteValueFromKey( $key );

简单描述一下上面的phpredis例子，我们执行了一个sql语句从mysql中取数据，查询结果返回一个array集合，然后encode mysql查询出来的array成一个json格式插入到redis中，最后从redis中取出来，并做展现。

本文固定链接: https://www.sudops.com/example-of-use-redis-with-phpredis.html | 运维·速度

该日志由 Fisher 于2014年02月26日发表在 redis 分类下，你可以发表评论，并在保留原文地址及作者的情况下引用到你的网站或博客。
原创文章转载请注明: php中使用PhpRedis模块操作Redis的实例 | 运维·速度
关键字: php, redis

【上一篇】MongoDB分片副本集的环境搭建
【下一篇】golang 环境上搭建 redis 客户端(gosexy)及安装 mysql 驱动

php中使用PhpRedis模块操作Redis的实例

您可能还会对这些文章感兴趣！

php中使用PhpRedis模块操作Redis的实例：等您坐沙发呢！

发表评论

最新日志热评日志随机日志

赞助链接

标签云

最新文章

最近评论

最活跃的读者

欢迎关注运维·速度微信公众号

最新评论

标签云集

博客统计

php中使用PhpRedis模块操作Redis的实例

您可能还会对这些文章感兴趣！

php中使用PhpRedis模块操作Redis的实例：等您坐沙发呢！

发表评论

最新日志热评日志随机日志

赞助链接

标签云

最新文章

最近评论

最活跃的读者

欢迎关注 运维·速度 微信公众号

最新评论

标签云集

博客统计

欢迎关注运维·速度微信公众号