当前位置: 开发笔记 > 编程语言 > 正文

PHP简单实现延时操作

作者：Manordo | 来源：互联网 | 2020-09-13 18:41

在业务中有时会碰到延迟操作，如下单后半小时未支付则取消订单、下单后十五分钟未支付则发短信提醒等等，那这样的需求如何去实现呢，本文详细解说。

场景

在业务中有时会碰到延迟操作，如下单后半小时未支付则取消订单、下单后十五分钟未支付则发短信提醒等等。那这样的需求如何去实现呢。

相关学习推荐：PHP编程从入门到精通

实现方式

第一个简单的方式就是用一个后台进程死循环去查订单，根据下单时间去做不同的操作
第二种就是使用消息队列的定时消息，下单之后发送定时消息，不同的定时队列去处理不同的逻辑
第三种可以使用框架提供的一些既有功能去做

实现代码

我们以订单创建15分钟后未支付，给用户发送邮件为场景进行学习

准备工作：

简单的订单表：order
各种需要的composer包
rabbitMq本地服务
开通阿里云RocketMq服务

第一种

代码逻辑很简单就直接死循环就行了
启动这个脚本进程，可以用supervisor配置
部分代码

//创建订单的逻辑/**
 * 随机创建订单
 */$order = [
    &＃39;order_number&＃39; => mt_rand(100,10000).date("YmdHis"),
    &＃39;user_id&＃39; => mt_rand(1, 100),
    &＃39;order_amount&＃39; => mt_rand(100, 1000),];
    /**@var $manager Illuminate\Database\Capsule\Manager **/
    $cOnn= $manager;$insertResult = $conn::table("order")
    ->insert($order);print_r($insertResult);

延迟处理逻辑

while(true) {
    // 未支付订单列表
    $orderList = $conn::table("order")
        ->where("created_time",  &＃39;<=&＃39;, date("Y-m-d H:i:s", strtotime("-15 minutes")))
        ->where(&＃39;sended_need_pay_notify&＃39;, &＃39;=&＃39;, 2)
        ->where(&＃39;status&＃39;, &＃39;=&＃39;, 1)
        ->select([&＃39;user_id&＃39;, &＃39;id&＃39;])
        ->orderBy("id", &＃39;asc&＃39;)
        ->get();
    $orderList = json_decode(json_encode($orderList), true);
    foreach ($orderList as $orderInfo) {
        sendEmail($orderInfo[&＃39;user_id&＃39;]);
        $conn::table(&＃39;order&＃39;)
            ->where(&＃39;id&＃39;, &＃39;=&＃39;, $orderInfo[&＃39;id&＃39;])
            ->update([&＃39;sended_need_pay_notify&＃39; => 1]);
        logs("update-success-orderId-". $orderInfo[&＃39;id&＃39;]."-userId-".$orderInfo[&＃39;user_id&＃39;]);
    }

    sleep(10);}

执行处理脚本

gaoz@nobodyMBP delay_mq_demo % php first_while_handler.php
send email to 73 success ...
2020-06-24 11:37:36:update-success-orderId-3-userId-73

这种方式吧实现简单，但是不优雅，同时大批量订单产生也会遇到问题。

第二种

比如使用阿里云的MQ服务，目前rocketMq与rabbitMq版本支持延迟消息，但是rabbit的延时消息收费太高了
这里先使用rocketMq的延迟消息去实现
需要开通阿里云的服务

// 创建订单的逻辑try
        {

            /**
             * 随机创建订单
             */
            $order = [
                &＃39;order_number&＃39; => mt_rand(100,10000).date("YmdHis"),
                &＃39;user_id&＃39; => mt_rand(1, 100),
                &＃39;order_amount&＃39; => mt_rand(100, 1000),
            ];

            /**@var $manager Illuminate\Database\Capsule\Manager **/
            $cOnn= $manager;

            $insertId = $conn::table("order")
                ->insertGetId($order);

            $body = json_encode([&＃39;order_id&＃39; => $insertId, &＃39;created_time&＃39; => date("Y-m-d H:i:s")]);
            $publishMessage = new TopicMessage(
                $body            );
            // 设置消息KEY
            $publishMessage->setMessageKey("MessageKey");

            // 定时消息, 定时时间为3分钟后
            $publishMessage->setStartDeliverTime(time() * 1000 + 3 * 60 * 1000);

            $result = $this->producer->publishMessage($publishMessage);

            print "Send mq message success. msgId is:" . $result->getMessageId() . ", bodyMD5 is:" . $result
            -
            >getMessageBodyMD5() . "\n";
        } catch (\Exception $e) {
            print_r($e->getMessage() . "\n");
        }

消费逻辑同样是在消费者中处理

foreach ($messages as $message) {
                $receiptHandles[] = $message->getReceiptHandle();

                $messageBody = $message->getMessageBody();

                $orderInfo = json_decode($messageBody, true);
                if (!empty($orderInfo[&＃39;order_id&＃39;])) {
                    $orderId = $orderInfo[&＃39;order_id&＃39;];

                    /**@var $manager Illuminate\Database\Capsule\Manager * */
                    $cOnn= $manager;
                    $orderInfo = $conn::table("order")
                        ->select([&＃39;id&＃39;, &＃39;user_id&＃39;])
                        ->where(&＃39;id&＃39;, &＃39;=&＃39;, $orderId)
                        ->where(&＃39;status&＃39;, &＃39;=&＃39;, 1)
                        ->first();
                    if (!empty($orderInfo)) {
                        $orderInfo = json_decode(json_encode($orderInfo), true);
                        sendEmail($orderInfo[&＃39;user_id&＃39;]);
                        $conn::table(&＃39;order&＃39;)
                            ->where(&＃39;id&＃39;, &＃39;=&＃39;, $orderInfo[&＃39;id&＃39;])
                            ->update([&＃39;sended_need_pay_notify&＃39; => 1]);
                        logs("update-success-orderId-" . $orderInfo[&＃39;id&＃39;] . 
                        "-userId-" . $orderInfo[&＃39;user_id&＃39;]);
                    }
                }
            }

启动生产一条消息

gaoz@nobodyMBP delay_mq_demo % php rocket_mq_handler_producer.php 
Send mq message success. msgId is:76CF2135696C3D4EAC698A9FA1E1879D, bodyMD5 
is:63448B50AA7B8AF47B07AA7CE807E3D3
gaoz@nobodyMBP delay_mq_demo %

启动消费者慢慢等待

gaoz@nobodyMBP delay_mq_demo % php rocket_mq_handler_consumer.php 
No message, contine long polling!RequestId:5EF752583441411C74869BA9
No message, contine long polling!RequestId:5EF7525B3441411C74869FE2
No message, contine long polling!RequestId:5EF7525E3441411C7486A42C
No message, contine long polling!RequestId:5EF752613441411C7486A7D9
consume finish, messages:send email to 95 success ...2020-06-27 12:08:05:update-success-orderId-8-userId-95
 Array(
    [0] => 76CF2135696C3D4EAC698A9FA1E1879D-MCAxNTkzMjY2NzkxNDM5IDMwMDAwMCAzIDAgYmpzaGFyZTUtMDggNSAw)
    ack

这种方式有现有的服务可以使用，减少开发时间

第三种使用rabbitMq去实现

查阅文档没有找到rabbitMq支持延迟队列的原生功能，但是可以通过消息的ttl+死信队列实现
私信队列就是用来存放没有被消费或者消费失败等消息的队列
当设置消息的有效期内没有被消费消息就会被转发到死信队列
通过设置消息的有效期实现延时功能

// 生产者$exchange = &＃39;order15min_notify_exchange&＃39;;
$queue = &＃39;order15minx_notify_queue&＃39;;$dlxExchange = "dlx_order15min_exchange";
$dlxQueue = "dlx_order15min_queue";
$cOnnection= new AMQPStreamConnection(getenv(&＃39;RABBIT_HOST&＃39;), getenv(&＃39;RABBIT_PORT&＃39;), getenv("RABBIT_USER"), getenv("RABBIT_PASS"), getenv("RABBIT_VHOST"));
$channel = $connection->channel();$channel->exchange_declare($exchange, AMQPExchangeType::DIRECT, false, true, false);
$channel->exchange_declare($dlxExchange, AMQPExchangeType::DIRECT, false, true, false);// 设置队列的过期时间// 正常队列$table = new \PhpAmqpLib\Wire\AMQPTable();// 消息有效期$table->set(&＃39;x-message-ttl&＃39;, 3*60*1000);$table->set("x-dead-letter-exchange", $dlxExchange);$channel->queue_declare($queue, false, true, false, false, false, $table);$channel->queue_bind($queue, $exchange);// 死信队列$channel->queue_declare($dlxQueue, false, true, false, false, false);$channel->queue_bind($dlxQueue, $dlxExchange);/**
 * 随机创建订单
 */$order = [
    &＃39;order_number&＃39; => mt_rand(100,10000).date("YmdHis"),
    &＃39;user_id&＃39; => mt_rand(1, 100),
    &＃39;order_amount&＃39; => mt_rand(100, 1000),];/**@var $manager Illuminate\Database\Capsule\Manager **/$cOnn= $manager;$insertId = $conn::table("order")
    ->insertGetId($order);$messageBody = json_encode([&＃39;order_id&＃39; => $insertId, &＃39;created_time&＃39; => date("Y-m-d H:i:s")]);
    $message = new AMQPMessage($messageBody, array(&＃39;content_type&＃39; => &＃39;text/plain&＃39;, &＃39;delivery_mode&＃39; => AMQPMessage::DELIVERY_MODE_PERSISTENT));
    $channel->basic_publish($message, $exchange);

消费者

$dlxExchange = "dlx_order15min_exchange";$dlxQueue = "dlx_order15min_queue";
$cOnnection= new AMQPStreamConnection(getenv(&＃39;RABBIT_HOST&＃39;), getenv(&＃39;RABBIT_PORT&＃39;), getenv("RABBIT_USER"), getenv("RABBIT_PASS"), getenv("RABBIT_VHOST"));
$channel = $connection->channel();
$channel->queue_declare($dlxQueue, false, true, false, false);$channel->exchange_declare($dlxExchange, AMQPExchangeType::DIRECT, false, true, false);
$channel->queue_bind($dlxQueue, $dlxExchange);/**
 * @param \PhpAmqpLib\Message\AMQPMessage $message
 */function process_message($message){
    echo "\n--------\n";
    echo $message->body;
    echo "\n--------\n";

    $orderInfo = json_decode($message->body, true);
    if (!empty($orderInfo[&＃39;order_id&＃39;])) {
        $orderId = $orderInfo[&＃39;order_id&＃39;];

        /**@var $conn Illuminate\Database\Capsule\Manager * */
        $cOnn= getdb();
        $orderInfo = $conn::table("order")
            ->select([&＃39;id&＃39;, &＃39;user_id&＃39;])
            ->where(&＃39;id&＃39;, &＃39;=&＃39;, $orderId)
            ->where(&＃39;status&＃39;, &＃39;=&＃39;, 1)
            ->first();
        if (!empty($orderInfo)) {
            $orderInfo = json_decode(json_encode($orderInfo), true);
            sendEmail($orderInfo[&＃39;user_id&＃39;]);
            $conn::table(&＃39;order&＃39;)
                ->where(&＃39;id&＃39;, &＃39;=&＃39;, $orderInfo[&＃39;id&＃39;])
                ->update([&＃39;sended_need_pay_notify&＃39; => 1]);
            logs("update-success-orderId-" . $orderInfo[&＃39;id&＃39;] . "-userId-" . $orderInfo[&＃39;user_id&＃39;]);
        }

    }
    $message->delivery_info[&＃39;channel&＃39;]->basic_ack(
        $message->delivery_info[&＃39;delivery_tag&＃39;]);}$channel->basic_consume($dlxQueue, $consumerTag, false, false, false, false, &＃39;process_message&＃39;);

启动消费者

gaoz@nobodyMBP delay_mq_demo % php rabbit_mq_handler_consumer.php
--------
{"order_id":7,"created_time":"2020-06-27 11:50:08"}
--------
send email to 2 success ...
2020-06-27 11:56:55:update-success-orderId-7-userId-2

分别启动消费者、生产者就可以了，这里面消息的流转可以看到

消息先进入到正常队列，过期后进入了死信队列而被消费

第四种

使用laravel自带的Queue去实现
这里没有整理详细代码，后面更新出来
可以查看官方文档队列《Laravel 5.7 中文文档》

代码示例：github.com/nobody05/delay_mq_demo

以上就是PHP 简单实现延时操作的详细内容，更多请关注第一PHP社区其它相关文章！

推荐阅读

post
Yii2 GridView 实现列表页数据直接编辑的完整指南

本文详细介绍了如何使用 Yii2 的 GridView 组件在列表页面实现数据的直接编辑功能。通过具体的代码示例和步骤，帮助开发者快速掌握这一实用技巧。 ... [详细]

蜡笔小新 2024-12-27 16:27:52
php
Composer Registry Manager：PHP的源切换管理工具

本文介绍了一个用于Composer的源切换管理工具——Composer Registry Manager。该项目旨在简化Composer包源的管理和切换，避免与常见的CRM系统混淆，并提供了详细的安装和使用指南。 ... [详细]

蜡笔小新 2024-12-25 19:34:14
php
Git 分布式版本控制系统：远程仓库的深入探讨

本文详细介绍了Git分布式版本控制系统中远程仓库的概念和操作方法。通过具体案例，帮助读者更好地理解和掌握如何高效管理代码库。 ... [详细]

蜡笔小新 2024-12-25 18:30:21
post
PHP 5.2.5 安装与配置指南

本文详细介绍了 PHP 5.2.5 的安装和配置步骤，帮助开发者解决常见的环境配置问题，特别是上传图片时遇到的错误。通过本教程，您可以顺利搭建并优化 PHP 运行环境。 ... [详细]

蜡笔小新 2024-12-27 19:05:41
php
PHP 中文 JSON 编码问题的解决方案

本文探讨了在 PHP 中处理 JSON 编码时中文字符显示为 Unicode 转义序列的问题，并提供了多种有效的解决方法，包括使用正则表达式替换、URL 编码以及利用 PHP 5.4 及以上版本提供的 JSON_UNESCAPED_UNICODE 选项。 ... [详细]

蜡笔小新 2024-12-26 20:41:16
string
解析JSON格式文本并处理数据

本文介绍如何使用阿里云的fastjson库解析包含时间戳、IP地址和参数等信息的JSON格式文本，并进行数据处理和保存。 ... [详细]

蜡笔小新 2024-12-26 16:06:09
post
网络运维工程师的前景与薪酬分析

网络运维工程师负责确保企业IT基础设施的稳定运行，保障业务连续性和数据安全。他们需要具备多种技能，包括搭建和维护网络环境、监控系统性能、处理突发事件等。本文将探讨网络运维工程师的职业前景及其平均薪酬水平。 ... [详细]

蜡笔小新 2024-12-26 14:35:04
string
中央电视台电影频道节目预告及优化分析

本文详细介绍了中央电视台电影频道的节目预告，并通过专业工具分析了其加载方式，确保用户能够获取最准确的电视节目信息。 ... [详细]

蜡笔小新 2024-12-25 21:01:14
php
使用npm脚本同时启动多个监听服务的技巧

本文介绍了如何利用npm脚本和concurrently工具，实现本地开发环境中多个监听服务的同时启动，包括HTTP服务、自动刷新、Sass和ES6支持。 ... [详细]

蜡笔小新 2024-12-25 18:10:18
match
深入解析JMeter中的JSON提取器及其应用

本文详细介绍了如何在JMeter中使用JSON提取器来获取和处理API响应中的数据。特别是在需要将一个接口返回的数据作为下一个接口的输入时，JSON提取器是一个非常有用的工具。 ... [详细]

蜡笔小新 2024-12-25 16:34:37
php
LeetCode 540：有序数组中的唯一元素

来源：力扣（LeetCode），链接：https://leetcode-cn.com/problems/single-element-in-a-sorted-array。题目要求在仅包含整数的有序数组中，找到唯一出现一次的元素，并确保算法的时间复杂度为 O(log n) 和空间复杂度为 O(1)。 ... [详细]

蜡笔小新 2024-12-28 13:14:07
instance
深入理解org.neo4j.helpers.collection.Iterators.single()方法及其应用

本文详细介绍了Java中org.neo4j.helpers.collection.Iterators.single()方法的功能、使用场景及代码示例，帮助开发者更好地理解和应用该方法。 ... [详细]

蜡笔小新 2024-12-28 10:51:55
instance
GWT PopupPanel onKeyDownPreview 方法详解与实例

本文详细介绍了 GWT 中 PopupPanel 类的 onKeyDownPreview 方法，提供了多个代码示例及应用场景，帮助开发者更好地理解和使用该方法。 ... [详细]

蜡笔小新 2024-12-28 10:07:27
instance
资源推荐 | TensorFlow官方中文教程助力英语非母语者学习

来源：机器之心。本文详细介绍了TensorFlow官方提供的中文版教程和指南，帮助开发者更好地理解和应用这一强大的开源机器学习平台。 ... [详细]

蜡笔小新 2024-12-28 09:00:51
post
Handling Null Object Encoding in OAuth 1.0a API Implementation

Explore a common issue encountered when implementing an OAuth 1.0a API, specifically the inability to encode null objects and how to resolve it. ... [详细]

蜡笔小新 2024-12-28 08:54:34