发帖
翼度科技»论坛 › 编程开发 › PHP › 查看内容

Laravel实现队列的示例代码

你的大可爱已上线

5

主题

5

帖子

15

积分

新手上路

Rank: 1

积分
15
显示全部楼层
一：队列配置

队列的配置文件放置在config/queue.php文件中，laravel框架中支持的队列驱动有：sync, database, beanstalkd, sqs, redis,null对应着：同步（本地使用）驱动，数据库驱动，beanstalkd ,Amazon SQS ,redis,null 队列驱动用于那些放弃队列的任务

1：队列相关配置

(1)：队列驱动配置
  1. 'default' => env('QUEUE_DRIVER', 'sync'),//队列驱动设置
复制代码
(2)：不同驱动相关配置
  1. 'connections' => [
  2.     syns驱动配置
  3.     'sync' => [
  4.         'driver' => 'sync',
  5.     ],
  6.     数据库驱动配置
  7.     'database' => [
  8.         'driver' => 'database',
  9.         'table' => 'jobs',//数据库驱动配置使用的数据库
  10.         'queue' => 'default',
  11.         'retry_after' => 90,//指定了任务最多处理多少秒后就被当做失败重试,比如说，如果这个选项设置为 90，那么当这个任务持续执行了 90 秒而没有被删除，那么它将被释放回队列
  12.     ],
  13.     //beanstalkd驱动配置
  14.     'beanstalkd' => [
  15.         'driver' => 'beanstalkd',
  16.         'host' => 'localhost',//使用beanstalkd驱动地址
  17.         'queue' => 'default',
  18.         'retry_after' => 90,//指定了任务最多处理多少秒后就被当做失败重试,比如说，如果这个选项设置为 90，那么当这个任务持续执行了 90 秒而没有被删除，那么它将被释放回队列
  19.         'block_for' => 0,
  20.     ],
  21.     //sqs驱动配置
  22.     'sqs' => [
  23.         'driver' => 'sqs',
  24.         'key' => env('AWS_ACCESS_KEY_ID'),
  25.         'secret' => env('AWS_SECRET_ACCESS_KEY'),
  26.         'prefix' => env('SQS_PREFIX', 'https://sqs.us-east-1.amazonaws.com/your-account-id'),
  27.         'queue' => env('SQS_QUEUE', 'your-queue-name'),
  28.         'region' => env('AWS_DEFAULT_REGION', 'us-east-1'),
  29.     ],
  30.     //redis驱动配置
  31.     'redis' => [
  32.         'driver' => 'redis',
  33.         'connection' => 'default',//使用哪个连接的redis,redis配置是在config/database.php文件中
  34.         'queue' => env('REDIS_QUEUE', 'default'),
  35.         'retry_after' => 90,
  36.         'block_for' => null,
  37.     ],

  39. ],
复制代码
2：不同队列依赖

(1)：数据库驱动
使用数据库驱动需要生成一个队列驱动表
  1. php artisan queue:table
  2. php artisan migrate
复制代码
执行上面的命令之后会发现数据库中会增加一个jobs表
(2)：redis驱动
使用redis驱动需要安装一个predis/predis 拓展
  1. composer require predis/predis
复制代码
(3)：Amazon SQS驱动
使用Amazon SQS驱动时需要安装aws/aws-sdk-php拓展
  1. composer require aws/aws-sdk-php
复制代码
(4)：Beanstalkd驱动
使用Beanstalkd驱动需要安装pda/pheanstalk拓展
  1. composer require pda/pheanstalk
复制代码
二：创建队列任务
  1. php artisan make:job TestJobs
复制代码
执行上面的命令创建一个队列任务类，这时候会发现在app/jobs目录下生成一个TestJobs.php文件
简单的队列任务类实例：
  1. <?php
  2. namespace App\Jobs;
  3. use App\Models\blog\User;
  4. use Illuminate\Bus\Queueable;
  5. use Illuminate\Queue\SerializesModels;
  6. use Illuminate\Queue\InteractsWithQueue;
  7. use Illuminate\Contracts\Queue\ShouldQueue;
  8. use Illuminate\Foundation\Bus\Dispatchable;
  9. class TestJobs implements ShouldQueue
  10. {
  11.     use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
  12.     /**
  13.      * 任务最大尝试次数。
  14.      *
  15.      * @var int
  16.      */
  17.     public $tries = 5;
  18.     /**
  19.      * 任务运行的超时时间。
  20.      * 指定了 Laravel 队列处理器最多执行多长时间后就应该被关闭掉
  21.      * --timeout 应该永远都要比 retry_after 短至少几秒钟的时间。这样就能保证任务进程总能在失败重试前就被杀死了。
  22.      * 如果你的 --timeout 选项大于 retry_after 配置选项，你的任务可能被执行两次
  23.      *
  24.      * @var int
  25.      */
  26.     public $timeout = 120;
  27.     public $info;
  28.     /**
  29.      * Create a new job instance.
  30.      *
  31.      * @return void
  32.      */
  33.     public function __construct($info)
  34.     {
  35.         //
  36.         $this->info = $info;
  37.     }
  38.     /**
  39.      * Execute the job.
  40.      *
  41.      * @return void
  42.      */
  43.     public function handle()
  44.     {
  45.         //
  46.         $user = new User();
  47.         $user->user_no = $this->info['user_no'];
  48.         $user->user_name = $this->info['user_name'];
  49.         $user->save();
  50.     }
  51. }
复制代码
三：任务分发


1：默认分发
  1. $info = [
  2.     'user_no'=>'006',
  3.     'user_name'=>'testName'
  4. ];
  5. TestJobs::dispatch($info);
复制代码
2：延时分发
  1. TestJobs::dispatch($info)->delay(Carbon::now()->addMinutes(10));//表示延时十分钟分发任务
复制代码
3：指定队列分发
  1. TestJobs::dispatch($info)->onQueue('processing');//表示使用默认驱动的processing队列
复制代码
4：指定驱动分发
  1. TestJobs::dispatch($info)->onConnection('redis');//使用redis驱动的默认队列
复制代码
5：指定驱动和队列分发
  1. TestJobs::dispatch($info)->onConnection('redis')->onQueue('processing');//使用redis驱动的processing队列
复制代码
四：任务处理
  1. php artisan queue:work
复制代码
执行后我们会发现user表中发现多了一条user_no为006，user_name为testName数据，但是如果你指定了驱动和队列的话，这时候执行php artisan queue:work，你就会发现数据库中没有数据加进去，这是因为php artisan queue:work命令是对默认驱动和'default'队列监听，这时候就要使用：
  1. php artisan queue:work redis --queue="processing"  //redis表示指定驱动 processing表示指定队列
复制代码
五：失败任务处理
  1. php artisan queue:failed-table
  2. php artisan migrate
复制代码
执行上面命令后会在数据库中增加一张failed_jobs表，专门用于存储失败的任务信息，在TestJobs类中添加一个failed方法处理失败队列
  1. /**
  2. * 要处理的失败任务。
  3. *
  4. * @param  Exception  $exception
  5. * @return void
  6. */
  7. public function failed(Exception $exception)
  8. {
  9.     // 给用户发送失败通知，等等...
  10. }
复制代码
如果你想要注册一个只要当队列任务失败时就会被调用的事件，我们可以在 Laravel 的 app/Providers/AppServiceProvider.php文件中对这个事件附加一个回调函数即可
  1. /**
  2. * 启动任意应用程序的服务。
  3. *
  4. * @return void
  5. */
  6. public function boot()
  7. {
  8.     Queue::failing(function (JobFailed $event) {
  9.         // $event->connectionName
  10.         // $event->job
  11.         // $event->exception
  12.     });
  13. }
复制代码
六：使用Supervisor管理队列

一旦使用queue:work 命令，它将一直运行，直到你手动停止或者你关闭控制台，如果你想要让queue:work 命令永久在后台运行，这时候可以使用进程监控工具Supervisor来实现永久在后台运行

1：Supervisor安装

Supervisor安装可以参考文末补充内容

2：配置Supervisor

(1)：配置supervisord.conf
在/etc/supervisord.conf文件的最后一行增加
  1. files = supervisord.d/*.ini
复制代码
(2)：队列进程配置
在/etc/supervisord.d/目录下创建一个.ini文件
  1. [program:laravel-worker]process_name=%(program_name)s_%(process_num)02dcommand=php /home/forge/app.com/artisan queue:work database --sleep=3 --tries=3  #/home/forge/app.com为项目地址autostart=trueautorestart=trueuser=forgenumprocs=8 #numprocs 命令会要求 Supervisor 运行并监控 8 个 queue:work 进程redirect_stderr=truestdout_logfile=/home/forge/app.com/worker.log
复制代码
3：启动Supervisor
  1. systemctl start supervisord.servicesupervisorctl updatesupervisorctl reloadsupervisorctl start laravel-worker
复制代码
补充

Linux下使用supervisor实现进程管理
最近在linux下写了一个脚本需要在linux后台一直运行，这里我使用了supervisor来实现脚本进程管理
supervisor安装
1：yum安装
  1. yum install supervisor
复制代码
2：pip安装
  1. pip install supervisor
复制代码
supervisor常用命令
  1. supervisorctl status        //查看所有进程的状态
  2. supervisorctl stop xx       //停止指定进程(all为所有进程)
  3. supervisorctl start xx      //启动指定进程(all为所有进程)
  4. supervisorctl restart       //重启
  5. supervisorctl update        //配置文件修改后使用该命令加载新的配置
  6. supervisorctl reload        //重新启动配置中的所有程序
  7. systemctl start supervisord.service     //启动supervisor并加载默认配置文件
  8. systemctl enable supervisord.service    //将supervisor加入开机启动项
复制代码
将指定命令加入进程管理实例
1:supervisor配置
supervisor配置文件：/etc/supervisord.conf
子进程配置文件路径：/etc/supervisord.d/ (子进程的配置文件为ini格式)
我们增加一个命令到进程中只需要在子进程配置文件目录下创建一个ini进程文件进行配置即可
例：
  1. vim /etc/supervisord.d/test.ini
复制代码
在test.ini文件中加入如下命令：
  1. [program:test]     #项目进程名称dircetory=/XXX     #进程目录command=XXX     #进程命令autostart = true     #在supervisord启动的时候是否自动启动autorestart=false     #程序退出后是否自动重启#日志输出 stderr_logfile=/tmp/client_stderr.logstdout_logfile=/tmp/client_stdout.loguser=www     #脚本运行的用户身份 
复制代码
2：将test进程加入进程管理
  1. systemctl start supervisord.servicesupervisorctl updatesupervisorctl reloadsupervisorctl start test
复制代码
根据如上布置就可以实现将指定脚本加入进程管理
以上就是Laravel实现队列的示例代码的详细内容，更多关于Laravel队列的资料请关注脚本之家其它相关文章！

来源:https://www.jb51.net/article/274887.htm
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！

上一篇: Laravel操作redis和缓存操作详解

下一篇: Laravel中数据库迁移操作的示例详解

发表于 2023-2-25 21:03:31

举报 回复 使用道具

返回列表 发新帖

Archiver|手机版|小黑屋|翼度科技

Copyright © 2001-2020, Tencent Cloud.　Powered by Discuz! X3.4