PHP使用Redis队列执行定时任务实例讲解
更新时间:2021年3月20日 15:00 点击:2067
Redis类:
<?php namespace Utils; use Phalcon\Config\Adapter\Ini as ConfigIni; class Redis{ private static $redis1; private static $session; /** * 获取一个单例的redis对象 * @param string $name * @return \Redis */ public static function getObj($name='redis1') { try{ if(!empty(self::$$name)){ return self::$$name; } $config = new ConfigIni(APP_PATH."/config".ENV."/redis.ini"); self::$$name = new \Redis(); self::$$name->connect($config[$name]['host'], $config[$name]['port'],2); if(isset($config[$name]['password']) && !empty($config[$name]['password'])){ self::$$name->auth($config[$name]['password']); } self::$$name->select($config[$name]['database']); }catch (\Exception $exception){ self::$$name = false; } return self::$$name; } };
定时任务:
/** * 订单任务 */ public function orderAction() { error_reporting(E_ALL & ~E_NOTICE); $redis = Redis::getObj(); //获取数据库连接实例 $db = $this->getDI()->getShared('db'); while (true) { print_r(' -start- '); $order_status = 1; file_put_contents(APP_PATH . "/../domain_order.log", time()); try { //防止长时间无任务导致MySQL超时 $db->query("select 1"); //出列 $order_info = $redis->lPop('order'); if (!$order_info) {//队列为空时暂停 echo ' -empty- '; sleep(1); continue; } $order_info = json_decode($order_info, true); $model_order_info = NetUserOrder::findFirst(['order_sn = :order_sn:','bind'=>['order_sn'=>$order_domain_info_save->order_sn]]); //未支付 if($model_order_info->pay_status != 200){ echo 'no pay'; continue; } //已操作 if ($order_domain_info_save->order_status == 3) { echo ' -Operated- '; continue; } //事务开始 $db->begin(); ## 这里执行订单流程操作 ## $order_status = 3;//操作成功 //修改订单状态 $order_domain_info_save->order_status = $order_status; $order_domain_info_save->operation_time = time(); $order_domain_info_save->update(); } //提交事务 $db->commit(); printf('### succ order_id' . $order_info['id'] . ' ###'); } catch (\Exception $e) { //回滚事务 $db->rollback(); $order_status = 2;//操作失败 $order_domain_info_save->order_status = $order_status; $order_domain_info_save->operation_time = time(); $order_domain_info_save->update(); printf(' error ' . $e->getMessage() . ' '); //异常,发送通知 Log::error($e->getMessage()); $redis->hSet('order_domain_retry', 'domain_retry_' . $order_info['id'], json_encode($order_info)); }
Redis常用队列方法:
//队列第一个 =>出列 $Redis->lPop($key); //入到 =>队列最后 $Redis->rPush($key); //队列最后一个 =>出列 $Redis->rPop($key); //入到 =>队列第一个 $Redis->rPop($key); //返回整个列表的值,不出列 $redis->lRange($key,0,-1);
到此这篇关于PHP使用Redis队列执行定时任务实例讲解的文章就介绍到这了,更多相关PHP使用Redis队列执行定时任务内容请搜索猪先飞以前的文章或继续浏览下面的相关文章希望大家以后多多支持猪先飞!
上一篇: YII2 全局异常处理深入讲解
下一篇: laravel使用redis队列实例讲解
相关文章
- 这篇文章主要介绍了Redis连接池配置及初始化实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-03-29
- 这篇文章主要介绍了详解如何清理redis集群的所有数据,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-02-18
- 这篇文章主要介绍了源码分析系列之json_encode()如何转化一个对象,对json_encode()感兴趣的同学,可以参考下...2021-04-22
- PHP去除html、css样式、js格式的方法很多,但发现,它们基本都有一个弊端:空格往往清除不了 经过不断的研究,最终找到了一个理想的去除html包括空格css样式、js 的PHP函数。...2013-08-02
详解redis desktop manager安装及连接方式
这篇文章主要介绍了redis desktop manager安装及连接方式,本文图文并茂给大家介绍的非常详细,具有一定的参考借鉴价值,需要的朋友可以参考下...2021-01-15- 这篇文章主要介绍了浅谈redis key值内存消耗以及性能影响,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-02-07
- index.php怎么打开?初学者可能不知道如何打开index.php,不会的同学可以参考一下本篇教程 打开编辑:右键->打开方式->经文本方式打开打开运行:首先你要有个支持运行PH...2017-07-06
- 最近在工作中遇到了一个问题,通过查找相关资料才得知原因是因为返回结果的问题,下面这篇文章主要给大家介绍了关于lua读取redis数据的null判断的相关资料,文中通过示例代码介绍的非常详细,需要的朋友可以参考下...2020-06-30
- 队列的特性很简答,就是先进先出,一般利用数组来实现,本文就介绍了C#队列的简单使用,文中根据实例编码详细介绍的十分详尽,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2022-03-17
- 这篇文章主要介绍了SpringBoot集成Redis实现消息队列的方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-02-10
redis setIfAbsent和setnx的区别与使用说明
这篇文章主要介绍了redis setIfAbsent和setnx的区别与使用,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-08-04- 这篇文章主要介绍了Redis的Expire与Setex区别说明,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-01-15
PHP中func_get_args(),func_get_arg(),func_num_args()的区别
复制代码 代码如下:<?php function jb51(){ print_r(func_get_args()); echo "<br>"; echo func_get_arg(1); echo "<br>"; echo func_num_args(); } jb51("www","j...2013-10-04- 这篇文章主要介绍了PHP编程 SSO详细介绍及简单实例的相关资料,这里介绍了三种模式跨子域单点登陆、完全跨单点域登陆、站群共享身份认证,需要的朋友可以参考下...2017-01-25
- 这篇文章主要介绍了PHP实现创建以太坊钱包转账等功能,对以太坊感兴趣的同学,可以参考下...2021-04-20
- Redis 是一个开源、高性能的Key-Value数据库,被广泛应用在服务器各种场景中。本文介绍几个查看Redis内存信息的命令,包括常用的info memory、info keyspace、bigkeys等。...2021-01-15
- 这篇文章主要为大家详细介绍了php微信公众账号开发之五个坑,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2016-10-02
- 这篇文章主要介绍了c++优先队列(priority_queue)用法详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-04-25
ThinkPHP使用心得分享-ThinkPHP + Ajax 实现2级联动下拉菜单
首先是数据库的设计。分类表叫cate.我做的是分类数据的二级联动,数据需要的字段有:id,name(中文名),pid(父id). 父id的设置: 若数据没有上一级,则父id为0,若有上级,则父id为上一级的id。数据库有内容后,就可以开始写代码,进...2014-05-31- 这篇文章主要介绍了PHP如何通过date() 函数格式化显示时间,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下...2020-11-13