之前记得有写过PHP的几种这模式。这几天看群里在问单列模式,觉得还是有必要再深入写清楚下。。其实单例模式很好理解滴哦
单例模式顾名思义,就是只有一个实例,作为对象的创建模式,单例模式确保某一个类只有一个实例,而且自行实例化并向整个系统提供这个实例。
单例模式的三个要点:
1.某个类只能有一个实例。
2.必须自行创建这个实例。
3.必须自行向整个系统提供这个实例。
为什么要使用PHP单例模式?
1.PHP的应用有一个大方面是针对于数据库,一个应用中会存在大量的数据库操作,在使用面向对象的方式开发时,如果使用单例模式,就可以避免大量的new 操作消耗的资源,还可以减少数据库连接,这样就不容易出现too many connections情况。
2.如果一个系统中需要一个类来全局控制某些配置信息,那么,使用单例模式可以很方便的实现。
3.在一次页面请求中便于进行调试,因为所有代码都集中在一个类中,可以在类中设置钩子,输出日志,避免到处的var_dump(),echo。
<?php
/**
* 设计模式之单例模式
* $_instance必须声明为静态的私有变量
* 构造函数必须声明为私有,防止外部程序new类从而失去单例模式的意义
* getInstance()方法必须设置为公有的,必须调用此方法以返回实例的一个引用
* ::操作符只能访问静态变量和静态函数
* new对象都会消耗内存
* 使用场景:最常用的地方是数据库连接。
* 使用单例模式生成一个对象后,该对象可以被其它众多对象所使用。
*/
class Girlfriend
{
//保存例实例在此属性中
private static $_instance;
//构造函数声明为private,防止直接创建对象
private function __construct()
{
echo '实例初始化了!';
}
//单例方法
public static function get_instance()
{
var_dump(isset(self::$_instance));
if(!isset(self::$_instance))
{
self::$_instance=new self();
}
return self::$_instance;
}
//阻止用户复制对象实例
private function __clone()
{
trigger_error('禁止克隆' ,E_USER_ERROR);
}
function test()
{
echo("here is a test");
}
}
// 这个写法会出错,因为构造方法被声明为private
//$test = new Girlfriend;
// 下面将得到该类的单例对象
$test = Girlfriend::get_instance();
$test = Girlfriend::get_instance();
$test->test();
// 复制对象将导致一个E_USER_ERROR.
//$test_clone = clone $test;
上面两次调用:Girlfriend::get_instance() 而构造函数只是在初始实例时调用一次,并且初始的var_dump(isset(self::$_instance)) 返回false,后面多次实例都未输出构造函数...var_dump(isset(self::$_instance)) 都返回了true。。。
名副其实的一个类只有一个实例...相信这个例子大家应该可以深入理解啦.
二、为什么要使用单例模式?
多数人都是从单例模式的字面上的意思来理解它的用途, 认为这是对系统资源的节省, 可以避免重复实例化, 是一种"计划生育". 而PHP每次执行完页面都是会从内存中清理掉所有的资源. 因而PHP中的单例实际每次运行都是需要重新实例化的, 这样就失去了单例重复实例化的意义了. 单单从这个方面来说, PHP的单例的确有点让各位失望. 但是单例仅仅只有这个功能和应用吗? 答案是否定的,我们一起来看看。
php的应用主要在于数据库应用, 所以一个应用中会存在大量的数据库操作, 在使用面向对象的方式开发时(废话), 如果使用单例模式, 则可以避免大量的new 操作消耗的资源。
如果系统中需要有一个类来全局控制某些配置信息, 那么使用单例模式可以很方便的实现. 这个可以参看zend Framework的FrontController部分。
在一次页面请求中, 便于进行调试, 因为所有的代码(例如数据库操作类db)都集中在一个类中, 我们可以在类中设置钩子, 输出日志,从而避免到处var_dump, echo。
1、PHP缺点:
PHP语言是一种解释型的脚本语言,这种运行机制使得每个PHP页面被解释执行后,所有的相关资源都会被回收。也就是说,PHP在语言级别上没有办法让某个对象常驻内存,这和asp.net、Java等编译型是不同的,比如在Java中单例会一直存在于整个应用程序的生命周期里,变量是跨页面级的,真正可以做到这个实例在应用程序生命周期中的唯一性。然而在PHP中,所有的变量无论是全局变量还是类的静态成员,都是页面级的,每次页面被执行时,都会重新建立新的对象,都会在页面执行完毕后被清空,这样似乎PHP单例模式就没有什么意义了,所以PHP单例模式我觉得只是针对单次页面级请求时出现多个应用场景并需要共享同一对象资源时是非常有意义的。
2、单例模式在PHP中的应用场合:
(1)、应用程序与数据库交互
一个应用中会存在大量的数据库操作,比如过数据库句柄来连接数据库这一行为,使用单例模式可以避免大量的new操作,因为每一次new操作都会消耗内存资源和系统资源。
(2)、控制配置信息
如果系统中需要有一个类来全局控制某些配置信息, 那么使用单例模式可以很方便的实现.
三、如何实现单例模式?
1、普通的数据库访问例子:
<?php
......
//初始化一个数据库句柄
$db = new DB(...);
//添加用户信息
$db->addUserInfo(...);
......
//在函数中访问数据库,查找用户信息
function getUserInfo()
{
$db = new DB(...);//再次new 数据库类,和数据库建立连接
$db = query(....);//根据查询语句访问数据库
}
?>
2、应用单例模式对数据库进行操作
<?php
class
DB
{
private
$_db
;
private
static
$_instance
;
private
function
__construct(...)
{
$this
->_db = pg_connect(...);
//postgrsql
}
private
function
__clone() {};
//覆盖__clone()方法,禁止克隆
public
static
function
getInstance()
{
if
(! (self::
$_instance
instanceof
self) ) {
self::
$_instance
=
new
self();
}
return
self::
$_instance
;
}
public
function
addUserInfo(...)
{
}
public
function
getUserInfo(...)
{
}
}
//test
$db
= DB::getInstance();
$db
->addUserInfo(...);
$db
->getUserInfo(...);
?>
下面的代码是PDO操作数据库类的一个封装,采用了单例模式:
<?php
/**
* MyPDO
*/
class
MyPDO
{
protected
static
$_instance
= null;
protected
$dbName
=
''
;
protected
$dsn
;
protected
$dbh
;
/**
* 构造
*
* @return MyPDO
*/
private
function
__construct(
$dbHost
,
$dbUser
,
$dbPasswd
,
$dbName
,
$dbCharset
)
{
try
{
$this
->dsn =
'mysql:host='
.
$dbHost
.
';dbname='
.
$dbName
;
$this
->dbh =
new
PDO(
$this
->dsn,
$dbUser
,
$dbPasswd
);
$this
->dbh->
exec
(
'SET character_set_connection='
.
$dbCharset
.
', character_set_results='
.
$dbCharset
.
', character_set_client=binary'
);
} <a href=
"\"/tags.php/catch/\""
target=
"\"_blank\""
>
catch
</a> (PDOException
$e
) {
$this
->outputError(
$e
->getMessage());
}
}
/**
* 防止克隆
*
*/
private
function
__clone() {}
/**
* Singleton instance
*
* @return Object
*/
public
static
function
getInstance(
$dbHost
,
$dbUser
,
$dbPasswd
,
$dbName
,
$dbCharset
)
{
if
(self::
$_instance
=== null) {
self::
$_instance
=
new
self(
$dbHost
,
$dbUser
,
$dbPasswd
,
$dbName
,
$dbCharset
);
}
return
self::
$_instance
;
}
/**
* Query 查询
*
* @param String $strSql SQL语句
* @param String $queryMode 查询方式(All or Row)
* @param Boolean $debug
* @return Array
*/
public
function
query(
$strSql
,
$queryMode
=
'All'
,
$debug
= false)
{
if
(
$debug
=== true)
$this
->debug(
$strSql
);
$recordset
=
$this
->dbh->query(
$strSql
);
$this
->getPDOError();
if
(
$recordset
) {
$recordset
->setFetchMode(PDO::FETCH_ASSOC);
if
(
$queryMode
==
'All'
) {
$result
=
$recordset
->fetchAll();
}
elseif
(
$queryMode
==
'Row'
) {
$result
=
$recordset
->fetch();
}
}
else
{
$result
= null;
}
return
$result
;
}
/**
* Update 更新
*
* @param String $table 表名
* @param Array $arrayDataValue 字段与值
* @param String $where 条件
* @param Boolean $debug
* @return Int
*/
public
function
update(
$table
,
$arrayDataValue
,
$where
=
''
,
$debug
= false)
{
$this
->checkFields(
$table
,
$arrayDataValue
);
if
(
$where
) {
$strSql
=
''
;
<a href=
"\"/tags.php/foreach/\""
target=
"\"_blank\""
>
foreach
</a> (
$arrayDataValue
as
$key
=>
$value
) {
$strSql
.=
", `$key`='$value'"
;
}
$strSql
= <a href=
"\"/tags.php/substr/\""
target=
"\"_blank\""
>
substr
</a>(
$strSql
, 1);
$strSql
=
"UPDATE `$table` SET $strSql WHERE $where"
;
}
else
{
$strSql
=
"REPLACE INTO `$table` (`"
.implode(
'`,`'
,
array_keys
(
$arrayDataValue
)).
"`) VALUES ('"
.implode(
"','"
,
$arrayDataValue
).
"')"
;
}
if
(
$debug
=== true)
$this
->debug(
$strSql
);
$result
=
$this
->dbh->
exec
(
$strSql
);
$this
->getPDOError();
return
$result
;
}
/**
* Insert 插入
*
* @param String $table 表名
* @param Array $arrayDataValue 字段与值
* @param Boolean $debug
* @return Int
*/
public
function
insert(
$table
,
$arrayDataValue
,
$debug
= false)
{
$this
->checkFields(
$table
,
$arrayDataValue
);
$strSql
=
"INSERT INTO `$table` (`"
.implode(
'`,`'
,
array_keys
(
$arrayDataValue
)).
"`) VALUES ('"
.implode(
"','"
,
$arrayDataValue
).
"')"
;
if
(
$debug
=== true)
$this
->debug(
$strSql
);
$result
=
$this
->dbh->
exec
(
$strSql
);
$this
->getPDOError();
return
$result
;
}
/**
* Replace 覆盖方式插入
*
* @param String $table 表名
* @param Array $arrayDataValue 字段与值
* @param Boolean $debug
* @return Int
*/
public
function
replace(
$table
,
$arrayDataValue
,
$debug
= false)
{
$this
->checkFields(
$table
,
$arrayDataValue
);
$strSql
=
"REPLACE INTO `$table`(`"
.implode(
'`,`'
,
array_keys
(
$arrayDataValue
)).
"`) VALUES ('"
.implode(
"','"
,
$arrayDataValue
).
"')"
;
if
(
$debug
=== true)
$this
->debug(
$strSql
);
$result
=
$this
->dbh->
exec
(
$strSql
);
$this
->getPDOError();
return
$result
;
}
/**
* Delete 删除
*
* @param String $table 表名
* @param String $where 条件
* @param Boolean $debug
* @return Int
*/
public
function
delete
(
$table
,
$where
=
''
,
$debug
= false)
{
if
(
$where
==
''
) {
$this
->outputError(
"'WHERE' is Null"
);
}
else
{
$strSql
=
"DELETE FROM `$table` WHERE $where"
;
if
(
$debug
=== true)
$this
->debug(
$strSql
);
$result
=
$this
->dbh->
exec
(
$strSql
);
$this
->getPDOError();
return
$result
;
}
}
/**
* execSql 执行SQL语句
*
* @param String $strSql
* @param Boolean $debug
* @return Int
*/
public
function
execSql(
$strSql
,
$debug
= false)
{
if
(
$debug
=== true)
$this
->debug(
$strSql
);
$result
=
$this
->dbh->
exec
(
$strSql
);
$this
->getPDOError();
return
$result
;
}
/**
* 获取字段最大值
*
* @param string $table 表名
* @param string $field_name 字段名
* @param string $where 条件
*/
public
function
getMaxValue(
$table
,
$field_name
,
$where
=
''
,
$debug
= false)
{
$strSql
=
"SELECT MAX("
.
$field_name
.
") AS MAX_VALUE FROM $table"
;
if
(
$where
!=
''
)
$strSql
.=
" WHERE $where"
;
if
(
$debug
=== true)
$this
->debug(
$strSql
);
$arrTemp
=
$this
->query(
$strSql
,
'Row'
);
$maxValue
=
$arrTemp
[
"MAX_VALUE"
];
if
(
$maxValue
==
""
||
$maxValue
== null) {
$maxValue
= 0;
}
return
$maxValue
;
}
/**
* 获取指定列的数量
*
* @param string $table
* @param string $field_name
* @param string $where
* @param bool $debug
* @return int
*/
public
function
getCount(
$table
,
$field_name
,
$where
=
''
,
$debug
= false)
{
$strSql
=
"SELECT COUNT($field_name) AS NUM FROM $table"
;
if
(
$where
!=
''
)
$strSql
.=
" WHERE $where"
;
if
(
$debug
=== true)
$this
->debug(
$strSql
);
$arrTemp
=
$this
->query(
$strSql
,
'Row'
);
return
$arrTemp
[
'NUM'
];
}
/**
* 获取表引擎
*
* @param String $dbName 库名
* @param String $tableName 表名
* @param Boolean $debug
* @return String
*/
public
function
getTableEngine(
$dbName
,
$tableName
)
{
$strSql
=
"SHOW TABLE STATUS FROM $dbName WHERE Name='"
.
$tableName
.
"'"
;
$arrayTableInfo
=
$this
->query(
$strSql
);
$this
->getPDOError();
return
$arrayTableInfo
[0][
'Engine'
];
}
/**
* beginTransaction 事务开始
*/
private
function
beginTransaction()
{
$this
->dbh->beginTransaction();
}
/**
* commit 事务提交
*/
private
function
commit()
{
$this
->dbh->commit();
}
/**
* rollback 事务回滚
*/
private
function
rollback()
{
$this
->dbh->rollback();
}
/**
* transaction 通过事务处理多条SQL语句
* 调用前需通过getTableEngine判断表引擎是否支持事务
*
* @param array $arraySql
* @return Boolean
*/
public
function
execTransaction(
$arraySql
)
{
$retval
= 1;
$this
->beginTransaction();
foreach
(
$arraySql
as
$strSql
) {
if
(
$this
->execSql(
$strSql
) == 0)
$retval
= 0;
}
if
(
$retval
== 0) {
$this
->rollback();
return
false;
}
else
{
$this
->commit();
return
true;
}
}
/**
* checkFields 检查指定字段是否在指定数据表中存在
*
* @param String $table
* @param array $arrayField
*/
private
function
checkFields(
$table
,
$arrayFields
)
{
$fields
=
$this
->getFields(
$table
);
foreach
(
$arrayFields
as
$key
=>
$value
) {
if
(!in_array(
$key
,
$fields
)) {
$this
->outputError(
"Unknown column `$key` in field list."
);
}
}
}
/**
* getFields 获取指定数据表中的全部字段名
*
* @param String $table 表名
* @return array
*/
private
function
getFields(
$table
)
{
$fields
=
array
();
$recordset
=
$this
->dbh->query(
"SHOW COLUMNS FROM $table"
);
$this
->getPDOError();
$recordset
->setFetchMode(PDO::FETCH_ASSOC);
$result
=
$recordset
->fetchAll();
foreach
(
$result
as
$rows
) {
$fields
[] =
$rows
[
'Field'
];
}
return
$fields
;
}
/**
* getPDOError 捕获PDO错误信息
*/
private
function
getPDOError()
{
if
(
$this
->dbh->errorCode() !=
'00000'
) {
$arrayError
=
$this
->dbh->errorInfo();
$this
->outputError(
$arrayError
[2]);
}
}
/**
* debug
*
* @param mixed $debuginfo
*/
private
function
debug(
$debuginfo
)
{
var_dump(
$debuginfo
);
exit
();
}
/**
* 输出错误信息
*
* @param String $strErrMsg
*/
private
function
outputError(
$strErrMsg
)
{
throw
new
Exception(
'MySQL Error: '
.
$strErrMsg
);
}
/**
* destruct 关闭数据库连接
*/
public
function
destruct()
{
$this
->dbh = null;
}
}
?>
调用方法:
<?php
require
'MyPDO.class.php'
;
$db
= MyPDO::getInstance(
'localhost'
,
'root'
,
'123456'
,
'test'
,
'utf8'
);
$db
->query(
"<a href="
\"/tags.php/select/\"
" target="
\"_blank\"
">select</a> count(*) frome table"
);
$db
->destruct();
?>