追影

大米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：创建队列任务（队列里要做的任务）

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）写一个事件促发异步队列

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

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

复制代码