• 소개
• 설치
  • 구성
  • 대시보드 승인
• Run Horizon
  • Deploy Horizon
• 태그
• 알림
• Metrics

Introduction

Horizon은 아름다운 대시보드를 제공하며 코드를 통해 Laravel Redis 대기열을 구성할 수 있으며 작업 처리량과 같은 주요 지표와 같은 대기열 시스템을 쉽게 모니터링할 수 있습니다. 런타임 및 실패한 작업.

모든 구성 항목은 간단한 구성 파일에 저장되므로 팀 공동 작업 버전 관리에 배치하여 팀 공동 작업을 용이하게 할 수 있습니다.

Installation

{note} redis 큐 드라이버가 queue 구성 파일에 설정되어 있는지 확인해야 합니다. queue 配置文件中设置了 redis 队列驱动。

你应该使用 Composer 来安为你的 Laravel 项目安装 Horizon：

composer require laravel/horizon

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

php artisan horizon:install

你还应该创建 failed_jobs 表，Laravel 将使用该表来存储任何 失败的队列任务:

php artisan queue:failed-table

php artisan migrate

配置

发布 Horizon 相关文件后，他的主要配置文件会放在 config/horizon.php。你可以在这个文件中配置队列相关选项，并且每个配置项都有详细的使用说明，请详细阅读此文件。

均衡配置

Horizon 提供了三种均衡策略：simple，auto， 和 false。默认的是 simple , 会将收到的任务均分给队列进程：

'balance' => 'simple',

auto 策略会根据当前的工作量调整每个队列的工作进程任务数量。例如：如果 notifications 队列有 1000 个待执行任务，但是你的 render 队列是空的，Horizon 会分配更多的工作进程给 notifications 队列，直到 notifications 队列中所有任务执行完成。当配置项 balance  配置为 false 时，Horizon 会使用 Laravel 默认执行行为，它将按照配置中列出的顺序处理队列任务。

任务修整

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

'trim' => [
    'recent' => 60,    
    'failed' => 10080,
   ],

仪表盘权限验证

Horizon 仪表盘路由是 /horizon。 默认情况下，你只能在 local 环境下访问仪表盘。在你的 app/Providers/HorizonServiceProvider.php 文件中，有一个 gate 方法。这里授权控制 非本地 环境中对 Horizon 的访问。 你可以根据需要随意修改此门面，以限制对 Horizon 安装的访问：

/**
 * 注册 Horizon gate 方法
 *
 * gate 决定了谁可以在非本地环境中访问 Horizon。
 *
 * @return void
 */
 protected function gate(){
     Gate::define('viewHorizon', function ($user) { 
            return in_array($user->email, [   
                     'taylor@laravel.com',    
                     ]);  
                });
           }

运行 Horizon

当在 config/horizon.php 文件中配置好了你的队列执行进程后，你就可以使用 horizon Artisan 命令启动 Horizon。只需要一条命令语句即可启动所有配置好的队列进程：

php artisan horizon

你也可以使用 horizon:pause 和 horizon:continue Artisan 命令来暂停或继续执行队列任务：

php artisan horizon:pausephp artisan horizon:continue

你可以使用 horizon:terminate

php artisan horizon:terminate

[program:horizon]
process_name=%(program_name)s
command=php /home/forge/app.com/artisan horizon
autostart=true
autorestart=true
user=forge
redirect_stderr=true
stdout_logfile=/home/forge/app.com/horizon.log

<?php
    namespace App\Jobs;
    use App\Video;use Illuminate\Bus\Queueable;
    use Illuminate\Queue\SerializesModels;
    use Illuminate\Queue\InteractsWithQueue;
    use Illuminate\Contracts\Queue\ShouldQueue;
    use Illuminate\Foundation\Bus\Dispatchable;
    class RenderVideo implements ShouldQueue{ 
       use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;  
     /**
     *  video 实例
     *
     * @var \App\Video
     */   
      public $video;   
    /**
     * 创建工作实例
     *
     * @param  \App\Video  $video
     * @return void
     */   
     public function __construct(Video $video) 
        {     
           $this->video = $video; 
         }   
    /**
     * 执行任务
     *
     * @return void
     */  
      public function handle() 
         {     
            //  
          }
     }

$video = App\Video::find(1);
App\Jobs\RenderVideo::dispatch($video);

class RenderVideo implements ShouldQueue{    
     /**
     * 获取分配给这个任务的标签
     *
     * @return array
     */    
     public function tags() 
        {    
            return ['render', 'video:'.$this->video->id]; 
        }
   }

Horizon::routeMailNotificationsTo('example@example.com');
Horizon::routeSlackNotificationsTo('slack-webhook-url', '#channel');
Horizon::routeSmsNotificationsTo('15556667777');

'waits' => [
    'redis:default' => 60,
  ],

/**
 * 定义应用程序的任务调度
 *
 * @param  \Illuminate\Console\Scheduling\Schedule  $schedule
 * @return void
 */
 protected function schedule(Schedule $schedule){
     $schedule->command('horizon:snapshot')->everyFiveMinutes();
     }

사용자 정의 태그

Notifications

🎜참고: 알림을 사용하기 전에 guzzlehttp/guzzle Composer 패키지를 프로젝트에 추가해야 합니다. Horizon 구성을 사용하여 SMS 알림을 보내는 경우 Nexmo 알림 드라이버 종속성장도 읽어야 합니다. . 🎜

과도한 대기 시간에 대한 임계값 구성

측정항목