導(dǎo)讀:
PHP開發(fā)中,頻率的去mysql數(shù)據(jù)庫(kù)查詢,會(huì)導(dǎo)致網(wǎng)站性能下降,因此我們需要配合使用緩存技術(shù),來提高動(dòng)態(tài)Web應(yīng)用的速度、 提高可擴(kuò)展性。說到緩存,大家首先想到的可能是 Redis或者M(jìn)emcached等高性能的分布式內(nèi)存緩存服務(wù)器。但對(duì)于一些開放性比較強(qiáng)的項(xiàng)目,我們不希望使用redis等第三方緩存,使得系統(tǒng)依賴于其他服務(wù)。這時(shí)候,文件緩存會(huì)是一個(gè)不錯(cuò)的選擇。
文件緩存的功能:
- 能夠在較短的時(shí)間內(nèi)返回?cái)?shù)據(jù);
- 支持key過期;
文件緩存的技術(shù)點(diǎn):
- 為了避免一個(gè)文件內(nèi)的數(shù)據(jù)過大,造成讀取文件的時(shí)候延遲較高,我們采用一個(gè)key-value一個(gè)文件的方式實(shí)現(xiàn)存儲(chǔ)結(jié)構(gòu);
- 為了支持key過期,我們需要把expire數(shù)據(jù)寫入到文件中,所以需要對(duì)寫入的數(shù)據(jù)進(jìn)行序列化處理;
- 為了能夠快速的定位到文件路徑,我們采用hash算法一次計(jì)算出文件位置;
一、新建一個(gè)FileCache.php文件,代碼如下:
<?php
class FileCache{
public function __construct(){
//定義站點(diǎn)目錄
define('ROOT_PATH',str_replace('\\','/',realpath(dirname(__FILE__).'/../')));
}
//1.先定義一個(gè)指向自己實(shí)例的私有靜態(tài)引用
private static $instance=null;
//2.以自己實(shí)例為返回值的靜態(tài)的公有方法
public static function getInstance(){
//被動(dòng)創(chuàng)建,在真正需要使用時(shí)才去創(chuàng)建
if(is_null(SELF::$instance)){
SELF::$instance=new FileCache();
}
return SELF::$instance;
}
/**
* 緩存目錄
* @var
*/
private $cache_dir= ROOT_PATH."/cache/";//文件緩存于網(wǎng)站根目錄下的cache文件夾里
/**
* @param $cache_dir
* @throws Exception
*/
public function __construct()
{
if (!is_dir($this->cache_dir)) {
$make_dir_result = mkdir($this->cache_dir, 0755, true);
if ($make_dir_result === false) throw new Exception('Cannot create the cache directory');
}
}
/**
* 根據(jù)key獲取值,會(huì)判斷是否過期
* @param $key
* @return mixed
*/
public function get($key)
{
$cache_data = $this->getItem($key);
if ($cache_data === false || !is_array($cache_data)) return false;
return $cache_data['data'];
}
/**
* 添加或覆蓋一個(gè)key
* @param $key
* @param $value
* @param $expire
* @return mixed
*/
public function set($key, $value, $expire = 0)
{
return $this->setItem($key, $value, time(), $expire);
}
/**
* 設(shè)置包含元數(shù)據(jù)的信息
* @param $key
* @param $value
* @param $time
* @param $expire
* @return bool
*/
private function setItem($key, $value, $time, $expire)
{
$cache_file = $this->createCacheFile($key);
if ($cache_file === false) return false;
$cache_data = array('data' => $value, 'time' => $time, 'expire' => $expire);
$cache_data = json_encode($cache_data);
$put_result = file_put_contents($cache_file, $cache_data);
if ($put_result === false) return false;
return true;
}
/**
* 創(chuàng)建緩存文件
* @param $key
* @return bool|string
*/
private function createCacheFile($key)
{
$cache_file = $this->path($key);
if (!file_exists($cache_file)) {
$directory = dirname($cache_file);
if (!is_dir($directory)) {
$make_dir_result = mkdir($directory, 0755, true);
if ($make_dir_result === false) return false;
}
$create_result = touch($cache_file);
if ($create_result === false) return false;
}
return $cache_file;
}
/**
* 判斷Key是否存在
* @param $key
* @return mixed
*/
public function has($key)
{
$value = $this->get($key);
if ($value === false) return false;
return true;
}
/**
* 加法遞增
* @param $key
* @param int $value
* @return mixed
*/
public function increment($key, $value = 1)
{
$item = $this->getItem($key);
if ($item === false) {
$set_result = $this->set($key, $value);
if ($set_result === false) return false;
return $value;
}
$check_expire = $this->checkExpire($item);
if ($check_expire === false) return false;
$item['data'] += $value;
$result = $this->setItem($key, $item['data'], $item['time'], $item['expire']);
if ($result === false) return false;
return $item['data'];
}
/**
* 減法遞增
* @param $key
* @param int $value
* @return mixed
*/
public function decrement($key, $value = 1)
{
$item = $this->getItem($key);
if ($item === false) {
$value = 0 - $value;
$set_result = $this->set($key, $value);
if ($set_result === false) return false;
return $value;
}
$check_expire = $this->checkExpire($item);
if ($check_expire === false) return false;
$item['data'] -= $value;
$result = $this->setItem($key, $item['data'], $item['time'], $item['expire']);
if ($result === false) return false;
return $item['data'];
}
/**
* 刪除一個(gè)key,同事會(huì)刪除緩存文件
* @param $key
* @return mixed
*/
public function delete($key)
{
$cache_file = $this->path($key);
if (file_exists($cache_file)) {
$unlink_result = unlink($cache_file);
if ($unlink_result === false) return false;
}
return true;
}
/**
* 清楚所有緩存
* @return mixed
*/
public function clear()
{
return $this->delTree($this->cache_dir);
}
/**
* 遞歸刪除目錄
* @param $dir
* @return bool
*/
function delTree($dir)
{
$files = array_diff(scandir($dir), array('.', '..'));
foreach ($files as $file) {
(is_dir("$dir/$file")) ? $this->delTree("$dir/$file") : unlink("$dir/$file");
}
return rmdir($dir);
}
/**
* 根據(jù)key獲取緩存文件路徑
*
* @param string $key
* @return string
*/
protected function path($key)
{
$parts = array_slice(str_split($hash = md5($key), 2), 0, 2);
return $this->cache_dir . '/' . implode('/', $parts) . '/' . $hash;
}
/**
* 獲取含有元數(shù)據(jù)的信息
* @param $key
* @return bool|mixed|string
*/
protected function getItem($key)
{
$cache_file = $this->path($key);
if (!file_exists($cache_file) || !is_readable($cache_file)) {
return false;
}
$cache_data = file_get_contents($cache_file);
if (empty($cache_data)) return false;
$cache_data = json_decode($cache_data, true);
if ($cache_data) {
$check_expire = $this->checkExpire($cache_data);
if ($check_expire === false) {
$this->delete($key);
return false;
}
}
return $cache_data;
}
/**
* 檢查key是否過期
* @param $cache_data
* @return bool
*/
protected function checkExpire($cache_data)
{
$time = time();
$is_expire = intval($cache_data['expire']) !== 0 && (intval($cache_data['time']) + intval($cache_data['expire']) < $time);
if ($is_expire) return false;
return true;
}
}
二、File緩存調(diào)用方法:
1、設(shè)置緩存
<?php
include('FileCache.php');
//設(shè)置緩存 set參數(shù):(緩存名稱,要緩存的數(shù)據(jù),緩存時(shí)長(zhǎng))
FileCache::getInstance()->set("userid",123456,86400);
2、查詢緩存是否存在
<?php
include('FileCache.php');
$cache=FileCache::getInstance();
if($cache->has("userid")){
echo "存在名為userid的緩存";
}else{
echo "不存在名為userid的緩存";
}
3、獲取緩存
<?php
include('FileCache.php');
//讀取緩存
$userid=FileCache::getInstance()->get("userid");
echo $userid;
5、清空全部緩存
<?php
include('FileCache.php');
//清空全部緩存
FileCache::getInstance()->clear();