一、PHP消息队列实现及应用
二、消息队列的优缺点
三、消息队列的配置和准备工作
案例如下：
下面是队列表字段及属性
四、Mysql订单队列
1、接受订单，并写入数据 order.php
<?php
//这个文件是用来接受用户的订单信息并写入队列的一个文件 //引入数据库链接类
include '../include/db.php';
//当接收到用户手机号不为空的时候 if(!empty($_GET['mobile'])){
//这里首先是订单中心的处理流程
//因为订单系统是个单独的流程 这里需要处理
//...... 这里不单独写了
//把用户提交的数据进行过滤，防止sql注入
//直接假设个订单号
$order_id = rand(10000,99999);
//生成订单信息
$insert_data = array(
'order_id'=>$order_id,
'mobile'=>$_GET['mobile'],
'created_at'=>date('Y-m-d H:i:s',time()),
'status'=>0,//0未处理 1已处理2处理中
);
//把订单信息存入到队列表中
$db = DB::getIntance();//此处是操作数据库，注意不同的框架有相应的内置的操作方法
$res = $db->insert('order_queue',$insert_data);//insert($table,$data)
if($res){
echo '插入成功'； }else{
echo '插入失败'； } }
2、队列系统处理队列中的订单并进行标识goods.php
<?php
//这个文件主要是配送系统处理队列中的订单并进行标记的一个文件
//加载数据库操作类
include '../include/db.php';
//初始化
$db = DB::getIntance();
//1：先把要处理的记录更新为等待处理（此处要锁定订单，防止处理未完成便被取用）
$waiting = array(‘status’=>0);//等待处理的数据
$lock = array(‘status’=>2);//锁定的数据
$res_lock = $db->update('order_queue',$lock,$waiting,2);//update($table,$data,$where,$limit=0)
//2：选择出刚刚更新的数据，然后进行配送系统的处理
if($res_lock){
//选择出要处理的订单的内容
$res = $db->selectAll('order_queue',$lock);//
//然后由配货系统进行配货处理
//......//此处是配货系统
//3：把处理过的程序更新为已完成
$success = array(
'status'=>1,//已完成
'updated_at'=>date('Y-m-d H:i:s',time()),
);
$res_last = $db->update('order_queue',$success,$lock);
if($res_last){
echo 'Success'.$res_last;
}else{
echo 'Fail'.$res_last;
} }else{
echo 'ALL Finished';
}
3、定时任务。每分钟执行一次goods.sh 要会shell基础
#!/bin/bash date "+%G-%m-%d %H:%M:S"
cd /home/html/ssggw/queue_mysql/
php goods.php
4、在服务器部署下定时任务crontab -e
为了方便看结果，把定时任务结果输出到日志文件中，设定为标准输出，命令如下
执行命令保存文件：wq
新建日志文件命令
touch /home/html/ssggw/log.log
监控日志文件
数据库中已经成功两条数据
数据库中已经成功四条数据
解耦案例结束
五、Redis
六、Redis队列实现秒杀
1、创建数据表 redis_queue
2、接受用户请求的程序user.php
<?php
//先加载redis组件
$redis = new Redis();
$redis->connect('127.0.0.1',6379);
$redis_name = "miaosha"; //接受用户id
$uid = $_GET['uid'];
//获取下redis里面已有的数量
$num = 10;//秒杀前10个
//如果当天人数少于10的时候，则加入这个队列
if($redis->lLen($redis_name)<10){
$redis->rFush($redis_name,$uid.'%'.microtime());//将用户uid（连接一个微妙）加入$fredis_name这个队列的尾部
echo "秒杀成功";
}else{
//如果当天人数已经达到了10个人，则返回秒杀已完成
echo "秒杀已结束";
} //关掉redis链接
$redis->close();
3、处理程序，即报数据写入mysql对应数据表savetodb.php
<?php
//引入操作数据库类
include '../include/db.php'; //加载redis组件
$redis = new Redis();
$redis->connect('127.0.0.1',6379);
$redis_name = "miaosha"; $db = DB::getlntance(); //死循环
while(1){
//从队列最左侧取出一个值来
$user = $redis->IPop($redis_name);
//然后判断这个值是否存在
if(!$user || $user =='nil'){
//减少服务器压力 每1秒执行一次 真正的秒杀时间会很短，不用设置
sleep(1);
//跳出循环
continue;
}
//切割出时间，uid
$user_arr = explode('%',$user);
//定义一个数组
$insert_data = array(
'uid'=>$user_arr[0],
'time_stamp'=>$user_arr[1],
);
//保存到数据库中
$res = $db->insert('redis_queue',$insert_data);
//数据库插入失败的时候的回滚机制
if(!$res){
$redis->rPush($redis_name,$user);
}
}
//释放一下redis
$redis->close();
测试
访问user.php文件url
结果
数据库表情况
