분할 대기열과 항상 실행

Question

나는 사용자와 게시물의 데이터베이스 테이블을 가지고 있습니다. 내가하고 싶은 일은 각 사용자에 대해 별도의 대기열 작업이 실행중인 시스템을 설정하는 것입니다. 각 사용자를 통해

$users = User::all(); 

그리고 루프는 큐를 시작합니다 :

foreach ($users as $user) { 
    // dispatch queue job that goes through each user's posts 
} 

가 지금은 각 사용자에 대해 실행 큐 작업이

그래서 내가 무엇을 할 것 모든 사용자를 선택합니다. 그러나이 작업을 영원히 계속 실행해야하므로 사용자의 마지막 게시물에 도달하면 작업이 다시 시작되고 사용자의 최신 게시물로 돌아가서주기가 계속됩니다.

이 대기열 시스템을 어떻게 만듭니 까?

Answer 1

청취자가 붙을 끝에 이벤트를 브로드 캐스트 할 수 있습니다. 그러면 청취자는 작업을 다시 수행 할 작업을 파견합니다.

php artisan make:job LoopUserPosts 

$posts = $user->posts; 
$posts->each(function($post){ 
    //your work on your post 
    if($post->id === $posts->count()){ 
     // broadcast your event here 
     event(App\Events\UserPostsLoopEnded, [$post->user]); 
    } 
}); 

이벤트는 다음과 같이 보일 수 있습니다 :

php artisan make:event UserPostsLoopEnded 

class UserPostsLoopEnded extends Event 
{ 
    use SerializesModels; 

    public $user; 

    public function __construct(App\User $user) 
    { 
     $this->user = $user; 
    } 
} 

그런 다음 우리는 설정에 청취자가 필요합니다

php artisan make:listener HandleUserPostsLoopEnded --event="UserPostsLoopEnded" 

use App\Events\UserPostsLoopEnded; 

class HandleUserPostsLoopEnded 
{ 
    public function __construct() 


    public function handle(UserPostsLoopEnded $event) 
    { 
     //now we can just dispatch the job again 
     dispatch(App\Jobs\LoopUserPosts, [$event->user]   
    } 
} 

그런 다음 물론 당신은 attach the listener해야합니다. 계속 진행하여 App\Providers\EventServiceProvider을 연 다음 이벤트와 청취자를 $listen 배열에 추가해야합니다.

protected $listen = [ 
    //..... 
    'App\Events\UserPostsLoopEnded' => [ 
     'App\Listeners\HandleUserPostsLoopEnded', 
    ], 
]; 

이제 완전한 결론을 맺었습니다. 일단 작업이 끝나면 이벤트를 브로드 캐스트합니다. 청취자는 일단 해고되면 이벤트를 수신합니다. 그러면 리스너는 작업을 다시 보내 사용자에게 전달합니다.