Beanstalkd消息中间件实现秒杀功能

朱雀 2023-07-04 04:43 116阅读 0赞

# Beanstalkd技术及环境搭建 #

**参考**

> 《消息中间件Beanstalkd技术指南》参见：[https://blog.csdn.net/yan\_dk/article/details/104176990][https_blog.csdn.net_yan_dk_article_details_104176990]
> 
> Beanstalked的初步了解和使用（包括利用beanstalkd 秒杀消息队列的实现）[https://blog.csdn.net/m\_nanle\_xiaobudiu/article/details/80466702][https_blog.csdn.net_m_nanle_xiaobudiu_article_details_80466702]

## 秒杀功能实现案例 ##

**需求场景描述**：举行一个秒杀活动，在一个时刻统一开奖，取得前10名用户作为中奖用户。

**设计**

填写秒杀活动表单：后台管理人员填写秒杀活动的内容设计安排。

![20200208112712279.png][]![20200208114011642.png][]

秒杀表单：商城中，显示秒杀产品如下。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbl9kaw_size_16_color_FFFFFF_t_70][]

在开奖时间（2020-02-08  20:00:00）之前，【开始抢购】按钮是灰色的，到达开奖时间按钮立即变成可用的，网民可以开始点击它进行秒杀，在开奖时间那一刻，后台将点击秒杀的用户记录，开启生产任务，从所有用户中取得前10名用户，消费任务处理，将中奖的这10名用户记录，并分别向他们发送中奖消息，中奖的物品或奖券发放到他们的账户中。开奖时间过后，可以设置延迟5秒，结束秒杀，【开始抢购】失效。

**数据库设计**

创建秒杀表

create table `seckill`(
    `uid` int unsigned not null default '0',
    `time_stamp` int unsigned not null  default '0',
    `order_num` bigint unsigned not null default '0',
    primary key (`uid`),
    key (order_num)
    )engine = myisam default charset= utf8;

建立生产者producer\_seckill.php

<?php
    require "vendor/autoload.php";
    
    use Pheanstalk\Pheanstalk;
    
    //连接beanstalkd
    $ph = new Pheanstalk('127.0.0.1', 11300);
    
    $tube_name = 'SecKill2';
    
    //使用SecKill2管道
    $SEC = $ph->useTube($tube_name);
    
    //模拟100人请求秒杀
    for ($i = 0; $i < 100; $i++) {
        $uid = rand(10000000, 99999999);
        //获取当前队列已经拥有的数量,如果人数少于十,则加入这个队列
        $total_jobs = $ph->statsTube($tube_name)['total-jobs'];
        $num = 10;//模拟获取10人中奖，投递到任务池
        if ($total_jobs < $num) {
            $SEC->put($uid);//向管道放任务
            echo $uid . "秒杀成功";
        } else {
            //如果当前队列人数已经达到10人,则返回秒杀已完成
            echo "秒杀已结束<br>";
        }
    }
    print_r($ph->statsTube($tube_name));//查看SecKill2管道的信息

建立消费者consumer\_seckill.php

<?php
    
    require "vendor/autoload.php";
    
    use Pheanstalk\Pheanstalk;
    
    //连接BeanStalkd队列系统
    $ph = new Pheanstalk('127.0.0.1',11300);
    $tube_name = 'SecKill2';
    //取出SecKill2管道的任务总数
    $total_jobs = $ph->statsTube($tube_name)['total-jobs'];
    
    //PDO连接mysql数据库
    $dsn = "mysql:dbname=test;host=127.0.0.1;port=3306";
    $pdo = new PDO($dsn, 'root', '123456');
    
    //循环取出管道中任务,并执行插入数据库操作
    for($i = 0; $i < $total_jobs; $i++){
        //监听SecKill4管道,并将任务取出来
        $job = $ph->watch($tube_name)->reserve();
    
        //取出任务存储的值uid
        $uid = $job->getData();//打印出的样子 string(8) "24541944"
    
        if (!$uid) {
            sleep(2);
            continue;
        }
        //生成订单号
        $orderNum = build_order_no($uid);
        //生成订单时间
        $timeStamp = time();
        //构造插入数组
        $user_data = array('uid'=>$uid,'time_stamp'=>$timeStamp,'order_num'=>$orderNum);
        //将数据保存到数据库
        $sql = "insert into seckill (uid,time_stamp,order_num) values (:uid,:time_stamp,:order_num)";
        $stmt = $pdo->prepare($sql);
        $res = $stmt->execute($user_data);
        //如果数据库操作成功,则删除任务
        if ($res) {
            $ph->delete($job);
        }
    
    }
    
    //生成唯一订单号
    function build_order_no($uid){
        return  substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8).$uid;
    }

运行生产者

\# php /study/producer\_seckill.php

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbl9kaw_size_16_color_FFFFFF_t_70 1][]

运行消费者consumer\_seckill.php

\#php /study/consumer\_seckill.php

运行后，得到秒杀成功后插入数据表记录，如下图。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbl9kaw_size_16_color_FFFFFF_t_70 2][]

[https_blog.csdn.net_yan_dk_article_details_104176990]: https://blog.csdn.net/yan_dk/article/details/104176990
[https_blog.csdn.net_m_nanle_xiaobudiu_article_details_80466702]: https://blog.csdn.net/m_nanle_xiaobudiu/article/details/80466702
[20200208112712279.png]: https://img-blog.csdnimg.cn/20200208112712279.png
[20200208114011642.png]: https://img-blog.csdnimg.cn/20200208114011642.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbl9kaw_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200208113830203.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbl9kaw==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbl9kaw_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20200207234410662.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbl9kaw==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbl9kaw_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20200208002411471.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3lhbl9kaw==,size_16,color_FFFFFF,t_70