当前位置:首页 > PHP教程 > php高级应用 > 列表

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

发布:smiling 来源: PHP粉丝网  添加日期:2022-01-24 14:05:17 浏览: 评论:0 

本文实例讲述了PHP PDO和消息队列的个人理解与应用,分享给大家供大家参考,具体如下:

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

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

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

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

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

  1. [database] 
  2. driver = mysql 
  3. host = 127.0.0.1 
  4. port = 3306 
  5. dbname = mysql 
  6. username = root 
  7. password = 1234 
  8. [options] 
  9. PDO::MYSQL_ATTR_INIT_COMMAND = set names utf8 

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

  1. -- 消息队列测试 
  2. -- 商品表 
  3. create table goods( 
  4. id int unsigned primary key auto_increment, 
  5. goodsname varchar(40) not null comment '商品名'
  6. price decimal(9,2) not null comment '价格'
  7. category_id tinyint unsigned not null comment '商品类别id'
  8. sort tinyint comment '商品排序'
  9. description varchar(255) comment '商品描述'
  10. remark varchar(255) comment '备注' 
  11. )engine InnoDB default charset=utf8; 
  12. insert 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商品入库的代码:

郑重提醒:请认真看我的注释,请认真看我的注释,请认真看我的注释,重要的信息要说三遍,呵呵!

  1. <?php 
  2. namespace Home; 
  3. header('content-type:text/html;charset=utf-8;'); 
  4. //引入PDO类 
  5. use \PDO; 
  6. use \PDOStatement; 
  7. use \PDOException; 
  8. /*简单消息队列*/ 
  9. class Queue{ 
  10.   //容器可以是私有,最好是公有 
  11.   static public $container=array(); 
  12.   //把PDO对象存放到属性中是为了跨方法使用 
  13.   static private $pdo
  14.   //构造函数实现初始化PDO连接数据库 
  15.   public function __construct($file = './mysql.ini'){//mysql数据库的配置文件,./mysql.ini与这个类是同一个目录 
  16.     //parse_ini_file函数作用,解析并获取ini文件的参数,加true是二维数组 
  17.     $dbini    = parse_ini_file($file,true); 
  18.     $driver    = $dbini['database']['driver']; 
  19.     //这里的数据库是mysql的总数据库 
  20.     $dbname    = $dbini['database']['dbname']; 
  21.     $host    = $dbini['database']['host']; 
  22.     $port    = $dbini['database']['port']; 
  23.     //构造PDO连接数据库的第一个参数,这个参数这么设置纯属是PDO类的语法,不懂的可以百度一下,这里就不做详解了 
  24.     $dsn = $driver.':'.'dbname='.$dbname.';host='.$host.';port='.$port
  25.     //其他连接数据库参数 
  26.     $username  = $dbini['database']['username']; 
  27.     $password  = $dbini['database']['password']; 
  28.     $options  = $dbini['options'];//初始化设置PDO选项 
  29.     try{ 
  30.       self::$pdo = new PDO($dsn,$username,$password,$options); 
  31.       //设置PDO属性。抛出错误报告 
  32.       self::$pdo->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION); 
  33.       try{ 
  34.         //选择商品数据表所在的数据库 
  35.         self::$pdo->exec('use queue'); 
  36.       }catch(PDOException $e){ 
  37.         echo $e->getMessage(); 
  38.       } 
  39.     }catch(PDOException $e){ 
  40.       echo $e->getMessage(); 
  41.     } 
  42.   } 
  43.   /* 
  44.   *入列 
  45.   *$data数组 
  46.   *成功返回1,失败返回false,或者null 
  47.   */ 
  48.   public function _unshift($data =array()){ 
  49.     if(!is_array($data) || emptyempty($data)){return false;} 
  50.     $sql = 'default'
  51.     foreach($data as $k=>$v){ 
  52.       $sql .= ',"'.$v.'"'
  53.     } 
  54.     //把$data转为sql语句,添加到队列容器contain中 
  55.     $sql = 'insert into goods values('.$sql.')'
  56.     return @array_unshift(self::$container,$sql); 
  57.   } 
  58.   /* 
  59.   *出列 
  60.   *成功返回最后插入的数据id 
  61.   *失败返回失败信息 
  62.   */ 
  63.   private static function _pop(){ 
  64.     try{//获取尾部的sql语句,出列 
  65.       $sql = array_pop(self::$container); 
  66.       self::$pdo->exec($sql); 
  67.       //把剩余的容器值赋给中间变量 
  68.       $middle = self::$container
  69.       //判断中间变量是否为空,不为空则继续获取容器尾部的数据,继续出列 
  70.       while($middle){ 
  71.         $sql = array_pop($middle); 
  72.         self::$pdo->exec($sql); 
  73.         //把数据再转给容器,也就是转给while循环外面的$middle,这样才能实现循环,让容器里面的数据全部出列,插入到数据库中 
  74.         self::$container = $middle
  75.       } 
  76.       //返回的是,最后插入的id,失败是null 
  77.       return self::$pdo->lastInsertId(); 
  78.       }catch(PDOException $e){ 
  79.         return $e->getMessage(); 
  80.       } 
  81.   } 
  82.   //析构函数,对象回收时调用,通过它实现自动让容器数据入库 
  83.   public function __destruct(){ 
  84.     //当对象被回收时,判断容器是否存在消息,假如存在,则调用_pop方法,把消息出列 
  85.     if(self::$container){ 
  86.       self::_pop(); 
  87.     } 
  88.   } 

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

  1. <?php 
  2. include './queue.php'
  3. use Home\Queue;//引入命名空间的Queue类 
  4. $ob = new Queue; 
  5. //消息入列 
  6. $ob->_unshift(array('goodsname'=>'vivo手机8888','price'=>1120,'category_id'=>1,'sort'=>1,'description'=>'vivo品牌','remark'=>'好用')); 
  7. $ob->_unshift(array('goodsname'=>'小米手机888','price'=>1998,'category_id'=>1,'sort'=>1,'description'=>'小米品牌手机','remark'=>'国产好货')); 
  8. //之所以打印出来,完成是为了看看效果,至于,有没有实现商品入库,你得去看看你的数据库了,呵呵 
  9. var_dump(Queue::$container);

Tags: PHP消息队列 PDO

分享到: