PHP PDO和消息队列的个人理解与应用实例分析

本文实例讲述了php pdo和消息队列的个人理解与应用。分享给大家供大家参考，具体如下：

什么是消息队列，百度百科说，···消息队列····是在消息的传输过程中保存消息的容器。

看着网上林林总总的文章，都说是为了应对高并发，处理数据量超级大的一种数据容器，也可以说是利用各种方式，先把数据存储在一个···容器···中，然后，再慢慢从这个容器中获取数据，实现·····异步操作数据库·····的方式，以便降低数据库的压力。

不管消息队列是什么，个人姑且认为它就是一种存储数据的···容器···，就这么简单明了，呵呵，因为本人对消息队列这东西研究的比较肤浅。

不过，在这里，我还是要卖弄一下一个个人的小实验代码，呵呵，假若下面的东西与消息队列相离太远，那么请看官可别见怪哦，因为我上面已经声明的很清楚了，本人对这东西还是不甚了解，只不过是工作之余卖弄一下‘文采’而已，所以，假如真有误解消息队列这个东西，我只能说声，请你指正我的错误，让笔者迷途知返。

先给出连接mysql数据库配置文件mysql.ini的内容：

[databa]driver = mysqlhost = 127.0.0.1port = 3306dbname = mysqlurname = rootpassword = 1234[options]pdo::mysql_attr_init_command = t names utf8

数据表文件queue.sql的内容：

-- 消息队列测试-- 商品表create table goods(id int unsigned primary key auto_increment,goodsname varchar(40) not null comment '商品名',price decimal(9,2) n白岩松语录ot null comment '价格',category_id tinyint unsigned not null comment '商品类别id',sort tinyint comment '商品排序',description varchar(255) comment '商品描述',remark varchar(255) comment '备注')engine innodb default chart=utf8;inrt into goods values(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商品入库的代码：

郑重提醒：请认真看我的注释，请认真看我的注释，请认真看我的注释。重要的信息要说三遍，呵呵！

<?phpnamespace home;header('content-type:text/html;chart=utf-8;');//引入pdo类u \pdo;u \pdostatement;u \pdoexception;/*简单消息队列*/class queue{  //容器可以是私有，最好是公有  static public $container=array();  //把pdo对象存放到属性中是为了跨方法使用  static private $pdo;  //构造函数实现初始化pdo连接数据库  public五年一贯制 function __construct($file = './mysql.ini'){//mysql数据库的配置文件，./mysql.ini与这个类是同一个目录    //par_ini雅思6分是什么水平_file函数作用，解析并获取ini文件的参数，加true是二维数组    $dbini    = par_ini_file($file,true);    $driver    = $dbini['databa']['driver'];    //这里的数据库是mysql的总数据库    $dbname    = $dbini['databa']['dbname混凝土泵送施工技术规程'];    $host    = $dbini['databa']['host'];    $port    = $dbini['databa']['port'];    //构造pdo连接数据库的第一个参数，这个参数这么设置纯属是pdo类的语法，不懂的可以百度一下，这里就不做详解了    $dsn = $driver.':'.'dbname='.$dbname.';host='.$host.';port='.$port;    //其他连接数据库参数    $urname  = $dbini['databa']['urname'];    $password  = $dbini['databa']['password'];    $options  = $dbini['options'];//初始化设置pdo选项    try{      lf::$pdo = new pdo($dsn,$urname,$password,$options);      //设置pdo属性。抛出错误报告      lf::$pdo->tattribute(pdo::attr_errmode,pdo::errmode_exception);      try{        //选择商品数据表所在的数据库        lf::$pdo->exec('u queue');      }catch(pdoexception $e){        echo $e->getmessage();      }    }catch(pdoexception $e){      echo $e->getmessage();    }  }  /*  *入列  *$data数组  *成功返回1，失败返回fal，或者null  */  public function _unshift($data =array()){    if(!is_array($data) || empty($data)){return fal;}    $sql = 'default';    foreach($data as $k=>$v){      $sql .= ',"'.$v.'"';    }    //把$data转为sql语句，添加到队列容器contain中    $sql = 'inrt into goods values('.$sql.')';    return @array_unshift(lf::$container,$sql);  }  /*  *出列  *成功返回最后插入的数据id  *失败返回失败信息  */  private static function _pop(){    try{//获取尾部的sql语句，出列      $sql = array_pop(lf::$container);      lf::$pdo->exec($sql);      //把剩余的容器值赋给中间变量      $middle = lf::$container;      //判断中间变量是否为空，不为空则继续获取容器尾部的数据，继续出列      while($middle){        $sql = array_pop($middle);        lf::$pdo->exec($sql);        //把数据再转给容器，也就是转给while循环外面的$middle，这样才能实现循环，让容器里面的数据全部出列，插入到数据库中        lf::$container = $middle;      }      //返回的是，最后插入的id，失败是null      return lf::$pdo->lastinrtid();      }catch(pdoexception $e){        return $e->getmessage();      }  }  //析构函数，对象回收时调用，通过它实现自动让容器数据入库  public function __destruct(){    //当对象被回收时，判断容器是否存在消息，假如存在，则调用_pop方法，把消息出列    if(lf::$container){      lf::_pop(弹力定义);    }  }}

下面是同一级目录下调用这个类的文件的内容，当然，你也可以在上面那个queue类的下面调用_unshift方法实现消息队列的操作

<?phpinclude './queue.php';u home\queue;//引入命名空间的queue类$ob = new queue;//消息入列$ob->_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);