使用 Laravel Horizon 优雅的终止进程(1)

本文涉及的产品
云数据库 Redis 版,社区版 2GB
推荐场景:
搭建游戏排行榜
云原生内存数据库 Tair,内存型 2GB
云数据库 Redis 版,倚天版 1GB 1个月
简介: 通过调研之后发现,laravel 的 horizon 扩展可以解决这个问题,使用下面的命令可以优雅的结束进程:确保进行中进程不会被kill掉,执行结束后才允许被kill;非进行的任务等候,不会加入到队列中;

抛出问题


我们发布新版本代码时,如果优雅的终止运行中的异步任务,规避异步任务运行到一半被kill掉的情况。


解决办法


通过调研之后发现,laravel 的 horizon 扩展可以解决这个问题,使用下面的命令可以优雅的结束进程:


  1. 确保进行中进程不会被kill掉,执行结束后才允许被kill;
  2. 非进行的任务等候,不会加入到队列中;


优雅的解决了这个问题,思路就是这么的朴实无华。


php artisan horizon:terminate


下面开始隆重介绍 Horizon


简介


Horizon 提供了一个漂亮的仪表盘,可以通过代码配置 Laravel Redis 队列,同时它允许你轻易的监控你的队列系统中诸如任务吞吐量,运行时间和失败任务等关键指标。


微信图片_20221111215114.jpg


微信图片_20221111215117.jpg


安装


注意:确保 queue 配置文件中设置了 redis 队列驱动。


使用 Composer 为 Laravel 项目安装 Horizon:


composer require laravel/horizon


安装完成后,使用 horizon:install 发布 Artisan 命令:


php artisan horizon:install


需要创建 failed_jobs  表,Laravel 将使用该表来存储任何 failed queue jobs:


php artisan queue:failed-table
php artisan migrate


升级 Horizon


当准备升级到 Horizon 的一个新的主要版本之前,一定好好看看更新声明,熟悉新特性,结合业务场景思考有没有坑。

注意,升级之后记得要重新发布 Horizon 的资源文件:


php artisan horizon:assets


配置


发布 Horizon 相关文件后,他的主要配置文件会放在 config/horizon.php。

可以在这个文件中配置队列相关选项,并且每个配置项都有详细的使用说明。


注意:确保 horizon 配置文件的 environments 部分包含你计划在其上运行 Horizon 的每个环境的条目。


'environments' => [
    'production' => [
        'supervisor-1' => [
            'connection' => 'redis',
            'queue' => [
                'high_{0}',
            ],
            'balance' => 'auto',
            'minProcesses' => 1,
            'maxProcesses' => 2,
            'tries' => 1
        ],
    ],
    'test' => [
        'supervisor-1' => [
            'connection' => 'redis',
            'queue' => [
                'high_{0}',
            ],
            'balance' => 'auto',
            'minProcesses' => 1,
            'maxProcesses' => 2,
            'tries' => 1
        ],
    ],
    'local' => [
        'supervisor-1' => [
            'connection' => 'redis',
            'queue' => [
                'high_{0}',
            ],
            'balance' => 'auto',
            'minProcesses' => 3,
            'maxProcesses' => 11,
            'tries' => 1
        ],
    ],
],


均衡配置


Horizon 提供了三种均衡策略: simple , auto ,和 false 。


  1. 默认的是 simple , 会将收到的任务均分给队列进程


'balance' => 'simple',


  1. auto 策略会根据当前的工作量调整每个队列的工作进程任务数量


例如:如果  A 队列有 1000 个待执行任务,但是你的 B  队列是空的, Horizon 会分配更多的工作进程给 B 队列,直到 A 队列中所有任务执行完成。


  1. 当配置项 balance 配置为 false ,Horizon 会使用 Laravel 默认执行行为,它将按照配置中列出的顺序处理队列任务。


当使用 auto 策略时,您可以定义 minProcesses 和 maxProcesses 配置选项,以控制最小和最大进程数范围应向上和向下扩展到:


'environments' => [
    'production' => [
        'supervisor-1' => [
            'connection' => 'redis',
            'queue' => ['default'],
            'balance' => 'auto',
            'minProcesses' => 1,
            'maxProcesses' => 10,
            'tries' => 3,
        ],
    ],
],


失败任务记录


horizon 配置文件允许你配置应保留最近和失败任务的时间(以分钟为单位)。 默认情况下,最近的任务保留一小时,而失败的任务保留一周:


'trim' => [
    'recent' => 60,
    'failed' => 10080,
],
复制代码


微信图片_20221111215121.jpg

仪表盘权限验证


Horizon 仪表盘路由是 /horizon 。

默认情况下,你只能在 local 环境下访问仪表盘。


在你的  app/Providers/HorizonServiceProvider.php 文件中,有一个 gate 方法。

这里授权控制 非本地 环境中对 Horizon 的访问。


可以根据需要随意修改此门面,以限制对 Horizon 安装的访问:


/**
 * Register the Horizon gate.
 *
 * This gate determines who can access Horizon in non-local environments.
 *
 * @return void
 */
protected function gate()
{
    Gate::define('viewHorizon', function ($user) {
        return in_array($user->email, [
            'xxxx@xxx.com',
        ]);
    });
}


注意:记住,Laravel 会自动将 authenticated 用户注入到 gate 方法。


如果应用程序通过其他方法(如 IP 限制)提供 Horizon 安全,那么 Horizon 用户可能不需要 “登录”。

相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore     ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库 ECS 实例和一台目标数据库 RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
相关文章
|
编解码 C++ Windows
QT软件开发: QProcess启动进程完成交互并获取输出
QT软件开发: QProcess启动进程完成交互并获取输出
2250 0
QT软件开发: QProcess启动进程完成交互并获取输出
|
1月前
|
Ubuntu Unix Linux
如何使用 Supervisor 管理你的进程
**Supervisor** 是一款Python编写的进程管理工具,用于类Unix系统,确保应用服务持续运行。常用命令包括:`reload`(重新加载配置)、`status`(查看进程状态)、`shutdown`(关闭所有进程)、`start`和`stop`(控制单个进程)。在CentOS上安装Supervisor用`yum install -y supervisor`,配置文件通常在`/etc/supervisord.conf`。
27 0
|
9月前
|
存储 SQL Shell
【OSTEP】Abstraction Process | 进程 | 虚拟化 | 进程API
【OSTEP】Abstraction Process | 进程 | 虚拟化 | 进程API
38 0
|
PHP 调度
使用 Laravel Horizon 优雅的终止进程(2)
通过调研之后发现,laravel 的 horizon 扩展可以解决这个问题,使用下面的命令可以优雅的结束进程: 确保进行中进程不会被kill掉,执行结束后才允许被kill; 非进行的任务等候,不会加入到队列中;
311 0
|
缓存 监控 NoSQL
Python编程:supervisor模块管理进程实例
Python编程:supervisor模块管理进程实例
674 0
Python编程:supervisor模块管理进程实例
|
监控 安全 Java
使用supervisor管理你的程序
Supervisor是python开发的一种进程管理工具。不仅可以监控我们的程序还可以自动重启我们的程序,非常好用。
190 1
使用supervisor管理你的程序
|
Linux Shell 网络安全
如何让Erlang服务器程序在后台运行,即实现守护进程的形态运行(★firecat推荐★)
如何让Erlang服务器程序在后台运行,即实现守护进程的形态运行(★firecat推荐★)
316 0