大米cms7.x使用异步队列（数据库）实现，当然您也可以用redis

追影

大米cms7.x使用异步队列（数据库版）实现实例:
使用场景：有时我们需要点击某个按钮立刻响应, 但实际需要执行一个大的任务（耗时未知或很长）才会回调.这就需要用到异步队列

1:安装依赖:

1. composer require topthink/think-queue

复制代码

2:配置队列为使用数据库


3：创建数据库迁移文件

1. php think queue:table
   
2. php think queue:failed-table
   
3. php think migrate:run

复制代码

4：创建队列任务（队列里要做的任务）

1. <?php
   
2. 
   
3. namespace app\job;
   
4. 
   
5. use app\base\service\FoodAi;
   
6. use think\facade\Config;
   
7. use think\facade\Log;
   
8. use think\queue\Job;
   
9. use app\base\model\Article as ArticleModel;
   
10. use think\facade\Db;
    
11. 
    
12. class PythonStudy
    
13. {
    
14. 
    
15.     // 最大尝试次数（默认 3 次）
    
16.     public $tries = 2;
    
17. 
    
18.     // 最大异常次数（可选）
    
19.     public $maxExceptions = 2;
    
20.     public function fire(Job $job, $article) {
    
21.         // 处理任务逻辑
    
22.         try {
    
23.             //处理任务
    
24.             $this->do_upload($article);
    
25.             // 任务成功处理后删除
    
26.             $job->delete();
    
27.         } catch (\Exception $e) {
    
28.             // 任务失败处理
    
29.             $job->fail();
    
30.         }
    
31.     }
    
32. 
    
33.     public function failed($data) {
    
34.         // 任务失败回调
    
35.         echo "Job failed: " . json_encode($data) . "\n";
    
36.         Log::error('python学习任务失败', $data);
    
37.     }
    
38. 
    
39.     private function shouldUpload($article)
    
40.     {
    
41.         return $article->title
    
42.             && $article->aid
    
43.             && $article->ai_pictures
    
44.             && !$article->upload_ai
    
45.             && !$article->public_price
    
46.             && !$article->isflash;
    
47.     }
    
48. 
    
49. 
    
50. 
    
51.     private function do_upload($article_arr){
    
52.         try {
    
53.         $article = (object)$article_arr;//习惯用object
    
54.         if (!$this->shouldUpload($article)) {
    
55.             echo '验证参数不通过';
    
56.             return;
    
57.         }
    
58.         $str_pics = $article->ai_pictures;
    
59.         $company_code = $article->company_code?:$this->request->param('company_code');
    
60.         if(!$company_code) {echo('未传递company_code');return;}
    
61.         \payment\Common::changeDbByCompany($company_code);
    
62.         //上传数据集
    
63.         $baidu_service = new FoodAi();
    
64.         $r = $baidu_service->multi_study($str_pics, $article_arr,$company_code);
    
65.         if($r) {
    
66.             $article_model = new ArticleModel();
    
67.             $article_model->where('aid', '=', $article->aid)->save(['upload_ai' => 1]);
    
68.             echo 'python do upload success';
    
69.         }else{
    
70.             echo 'python do upload fail';
    
71.         }
    
72. 
    
73.         return true;
    
74.         }catch (\Exception $exception){
    
75.             echo $exception->getFile().$exception->getMessage();
    
76.         }
    
77.         return false;
    
78.     }
    
79. 
    
80. 
    
81. }

复制代码

（5）写一个事件促发异步队列

1. <?php
   
2. 
   
3. namespace app\base\event;
   
4. 
   
5. use app\base\service\Baidu as BaiduService;
   
6. use think\facade\Log;
   
7. use think\facade\Queue;
   
8. 
   
9. class PythonAi
   
10. {
    
11.     public function handle($article)
    
12.     {
    
13.         Queue::push(\app\job\PythonStudy::class,$article);
    
14.     }
    
15. }

复制代码

（6）注册事件与触发该事件

注册全局事件 app/event.php

1. <?php
   
2. // 事件定义文件
   
3. return [
   
4.     'bind'      => [
   
5.     ],
   
6.     'listen'    => [
   
7.         'AppInit'  => [],
   
8.         'HttpRun'  => [],
   
9.         'HttpEnd'  => [],
   
10.         'LogLevel' => [],
    
11.         'LogWrite' => [],
    
12.         'AiStudy' => [
    
13.             \app\base\event\PythonAi::class,
    
14.         ],
    
15. 
    
16.     ],
    
17. 
    
18.     'subscribe' => [
    
19.     ],
    
20. ];
    

复制代码

触发事件:用内置的event函数即可

1.     private function do_event($article){
   
2.         $article->company_code = $this->get_company_code();
   
3.         $article_arr = $article->toArray();
   
4.         //var_dump($article_arr);
   
5.         //触发事件
   
6.         event('AiStudy',$article_arr);
   
7.     }

复制代码

（7）最后 计划任务 让队列跑起来

1. # 以守护进程方式运行
   
2. php think queue:work

复制代码

顺带说下centos守护进程方式运行supervisord配置如下

1. [program:think-queue]
   
2. command=php /wwwroot/hall/xunyuan/think queue:work
   
3. directory=/wwwroot/hall/xunyuan
   
4. autostart=true
   
5. autorestart=true
   
6. startretries=3
   
7. user=nginx
   
8. numprocs=1
   
9. redirect_stderr=true
   
10. stdout_logfile=/var/log/supervisor/think-queue.log

复制代码