1.准备工作

1.1 创建 thinkphp5.1.40 项目

composer create-project topthink/think=5.1.40 orderService

1.2 安装消息队列依赖

composer require topthink/think-queue 2.0.4

注意:如果是TP6版本要去掉后面的版本号,TP5.1只能安装上面的包

1.3 依赖安装好以后会在config目录下生成queue.php的配置文件,直接修改配置文件如下

return [

'connector' => 'redis',

'REDIS_CLIENT' => 'predis',

'REDIS_HOST' => '127.0.0.1',

];

1.4 由于配置文件内配置了 predis,所以需要安装predis

composer require predis/predis

要注意的是PHP环境必须要事先安装redis扩展,具体安装过程这里不做赘述

2.开始开发

2.1 创建任务: application/job/CloseOrder.php,在文件内添加代码

namespace app\job;

use app\common\model\Orders;

use think\queue\Job;

class CloseOrder

{

public function fire(Job $job, $data)

{

// 查询订单信息

$order = Orders::get($data);

// 如果处于没有处于待支付状态则返回

if ($order['state'] != 2) {

$job->delete();

return;

}

// 更新订单状态为已取消

$order->state = 1;

$result = $order->save();

if($result!==false){

// 如果执行成功则删除任务

$job->delete();

}else{

// 重复3次都没结束则强制删除任务

if ($job->attempts() > 3) {

$job->delete();

return;

}else{

// 延迟10秒钟再执行一次这个任务

$job->release(10);

}

}

}

public function failed($data)

{

// ...任务达到最大重试次数后,失败了

}

}

Orders为订单表的模型文件,用于操作订单表

2.2 触发任务

当事务提交成功后,执行任务处理器。在生成订单的控制器内添加如下代码

use think\Db;

use think\Queue;

.

.

.

.

// 提交事务

DB::commit();

// 30 * 60为 30分钟的秒数

// $oid为创建成功的订单ID

Queue::later(30*60,CloseOrder::class,$oid);

关于Queue的参数请参考消息队列的文档,已经解释得很清楚了

2.3 监听并执行任务

在项目根目录运行终端代码

php think queue:listen

php think queue:work

可配合supervisor使用,保证进程常驻

3 测试

前台提交订单不支付,等待30分钟,自动更改到取消状态

技术
下载桌面版
GitHub
百度网盘(提取码:draw)
Gitee
云服务器优惠
阿里云优惠券
腾讯云优惠券
华为云优惠券
站点信息
问题反馈
邮箱:[email protected]
QQ群:766591547
关注微信