PHP PDO和消息队列的个人理解与应用实例分析
本文实例讲述了PHPPDO和消息队列的个人理解与应用。分享给大家供大家参考，具体如下：
什么是消息队列，百度百科说，···消息队列····是在消息的传输过程中保存消息的容器。
看着网上林林总总的文章，都说是为了应对高并发，处理数据量超级大的一种数据容器，也可以说是利用各种方式，先把数据存储在一个···容器···中，然后，再慢慢从这个容器中获取数据，实现·····异步操作数据库·····的方式，以便降低数据库的压力。
不管消息队列是什么，个人姑且认为它就是一种存储数据的···容器···，就这么简单明了，呵呵，因为本人对消息队列这东西研究的比较肤浅。
不过，在这里，我还是要卖弄一下一个个人的小实验代码，呵呵，假若下面的东西与消息队列相离太远，那么请看官可别见怪哦，因为我上面已经声明的很清楚了，本人对这东西还是不甚了解，只不过是工作之余卖弄一下‘文采'而已，所以，假如真有误解消息队列这个东西，我只能说声，请你指正我的错误，让笔者迷途知返。
先给出连接mysql数据库配置文件mysql.ini的内容：
[database] driver=mysql host=127.0.0.1 port=3306 dbname=mysql username=root password=1234 [options] PDO::MYSQL_ATTR_INIT_COMMAND=setnamesutf8
数据表文件queue.sql的内容：
--消息队列测试 --商品表 createtablegoods( idintunsignedprimarykeyauto_increment, goodsnamevarchar(40)notnullcomment'商品名', pricedecimal(9,2)notnullcomment'价格', category_idtinyintunsignednotnullcomment'商品类别id', sorttinyintcomment'商品排序', descriptionvarchar(255)comment'商品描述', remarkvarchar(255)comment'备注' )engineInnoDBdefaultcharset=utf8; insertintogoodsvalues(default,'iPhone5s',5999,1,1,'美国入口贵重电子产品','请多多销售'),(default,'宏基手提电脑1',4888,3,1,'价格划算好电脑',null),(default,'f-30绒衣',200,2,1,'以纯白色厚皮羽绒服',null),(default,'n-100鞋子',300,4,1,'Nick品牌',null);
下面是简单的消息队列实现PDO商品入库的代码：
郑重提醒：请认真看我的注释，请认真看我的注释，请认真看我的注释。重要的信息要说三遍，呵呵！
setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
try{
//选择商品数据表所在的数据库
self::$pdo->exec('usequeue');
}catch(PDOException$e){
echo$e->getMessage();
}
}catch(PDOException$e){
echo$e->getMessage();
}
}
/*
*入列
*$data数组
*成功返回1，失败返回false，或者null
*/
publicfunction_unshift($data=array()){
if(!is_array($data)||empty($data)){returnfalse;}
$sql='default';
foreach($dataas$k=>$v){
$sql.=',"'.$v.'"';
}
//把$data转为sql语句，添加到队列容器contain中
$sql='insertintogoodsvalues('.$sql.')';
return@array_unshift(self::$container,$sql);
}
/*
*出列
*成功返回最后插入的数据id
*失败返回失败信息
*/
privatestaticfunction_pop(){
try{//获取尾部的sql语句，出列
$sql=array_pop(self::$container);
self::$pdo->exec($sql);
//把剩余的容器值赋给中间变量
$middle=self::$container;
//判断中间变量是否为空，不为空则继续获取容器尾部的数据，继续出列
while($middle){
$sql=array_pop($middle);
self::$pdo->exec($sql);
//把数据再转给容器，也就是转给while循环外面的$middle，这样才能实现循环，让容器里面的数据全部出列，插入到数据库中
self::$container=$middle;
}
//返回的是，最后插入的id，失败是null
returnself::$pdo->lastInsertId();
}catch(PDOException$e){
return$e->getMessage();
}
}
//析构函数，对象回收时调用，通过它实现自动让容器数据入库
publicfunction__destruct(){
//当对象被回收时，判断容器是否存在消息，假如存在，则调用_pop方法，把消息出列
if(self::$container){
self::_pop();
}
}
}
下面是同一级目录下调用这个类的文件的内容，当然，你也可以在上面那个queue类的下面调用_unshift方法实现消息队列的操作
_unshift(array('goodsname'=>'vivo手机8888','price'=>1120,'category_id'=>1,'sort'=>1,'description'=>'vivo品牌','remark'=>'好用'));
$ob->_unshift(array('goodsname'=>'小米手机888','price'=>1998,'category_id'=>1,'sort'=>1,'description'=>'小米品牌手机','remark'=>'国产好货'));
//之所以打印出来，完成是为了看看效果，至于，有没有实现商品入库，你得去看看你的数据库了，呵呵
var_dump(Queue::$container);
更多关于PHP相关内容感兴趣的读者可查看本站专题：《PHP基于pdo操作数据库技巧总结》、《php+mysqli数据库程序设计技巧总结》、《php面向对象程序设计入门教程》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》
希望本文所述对大家PHP程序设计有所帮助。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。