内容简介:ThinkAdmin v5.0 增加自定义任务机制,不再依赖于 think-queue 组件。 去除数据表 system_jobs 和 system_jobs_log,增加 system_queue 表。 关于异步任务处理指令如下: 执行 php think xtask:listen 启动异步任...
ThinkAdmin v5.0 增加自定义任务机制,不再依赖于 think-queue 组件。
去除数据表 system_jobs 和 system_jobs_log,增加 system_queue 表。
关于异步任务处理指令如下:
- 执行
php think xtask:listen
启动异步任务监听守护主进程 - 执行
php think xtask:query
查询正在执行的所有任务进程 - 执行
php think xtask:start
创建异步任务监听守护主进程 - 执行
php think xtask:state
查看异步任务监听主进程状态 - 执行
php think xtask:stop
平滑停止异步任务所有的进程
admin/sys.php 函数增加 sysqueue 函数以方便增加 任务队列。
sysqueue($title, $loade, $later = 0, $data = [], $double = 1)
可以指定任务的标题,执行任务,延时时间,任务附加数据,允许创建重复任务等。
有些任务,在待处理和处理中是不需要再创建重复任务的,$double 就需要设置为0,这是根据标题来识别的,所以标题也可以适当加上个性名称。
自建的异步处理是多进程任务处理,其中 windows 是基于 wmic 指令创建进程实现的,而 linux 则是通过 & 符实现。
因为是异步并列执行,建议自行控制下任务数据,免得过多消耗系统资源而影响项目正常使用。
在部署时,通常我们只需要创建定时器去执行 php think xtask:start
就可以守护异步任务监听进程。
目前,ThinkAmdin V5 自定义异步任务机制支持两种规则机制。
一、自定义单独的处理类,需要继承 app\admin\queue\Queue
抽象类,实现 execute
方法,参数为 $input, $output, $data
其中 input 为 cli 输入对象,output 为 cli 输出对象,而 data 为任务绑定的数据。详情可以阅读:https://gitee.com/zoujingli/ThinkAdmin/blob/master/application/wechat/queue/WechatQueue.php
二、自定义 ThinkPHP 指定,默认使用 Console::call() 去尝试执行传入的指令。如:
sysqueue("同步[{$this->appid}]粉丝列表",'xfans:all', 0, ['appid' => $this->appid], 0);
关于ThinkAdmin更多用法,请移步 https://gitee.com/zoujingli/ThinkAdmin
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持 码农网
猜你喜欢:- Netty 之异步通知机制
- JavaScript 同步和异步(执行机制)
- JavaScript异步机制(二)之任务队列和事件循环
- JS核心知识点梳理——异步,单线程,运行机制
- 一步步分析 Node.js 的异步I/O机制
- Vue你不得不知道的异步更新机制和nextTick原理
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。
Go程序设计语言
艾伦 A. A. 多诺万 / 李道兵、高博、庞向才、金鑫鑫、林齐斌 / 机械工业出版社 / 2017-5 / 79
本书由《C程序设计语言》的作者Kernighan和谷歌公司Go团队主管Alan Donovan联袂撰写,是学习Go语言程序设计的指南。本书共13章,主要内容包括:Go的基础知识、基本结构、基本数据类型、复合数据类型、函数、方法、接口、goroutine、通道、共享变量的并发性、包、go工具、测试、反射等。 本书适合作为计算机相关专业的教材,也可供Go语言爱好者阅读。一起来看看 《Go程序设计语言》 这本书的介绍吧!
HTML 压缩/解压工具
在线压缩/解压 HTML 代码
RGB HSV 转换
RGB HSV 互转工具